diff --git a/plugins/outputs/datadog/datadog.go b/plugins/outputs/datadog/datadog.go index 6d7531eb5..65b7ab751 100644 --- a/plugins/outputs/datadog/datadog.go +++ b/plugins/outputs/datadog/datadog.go @@ -8,6 +8,7 @@ import ( "net/http" "net/url" "sort" + "strings" "github.com/influxdata/telegraf" "github.com/influxdata/telegraf/internal" @@ -100,6 +101,7 @@ func (d *Datadog) Write(metrics []telegraf.Metric) error { } } + redactedApiKey := "****************" ts.Series = make([]*Metric, metricCounter) copy(ts.Series, tempSeries[0:]) tsBytes, err := json.Marshal(ts) @@ -108,13 +110,13 @@ func (d *Datadog) Write(metrics []telegraf.Metric) error { } req, err := http.NewRequest("POST", d.authenticatedUrl(), bytes.NewBuffer(tsBytes)) if err != nil { - return fmt.Errorf("unable to create http.Request, %s\n", err.Error()) + return fmt.Errorf("unable to create http.Request, %s\n", strings.Replace(err.Error(), d.Apikey, redactedApiKey, -1)) } req.Header.Add("Content-Type", "application/json") resp, err := d.client.Do(req) if err != nil { - return fmt.Errorf("error POSTing metrics, %s\n", err.Error()) + return fmt.Errorf("error POSTing metrics, %s\n", strings.Replace(err.Error(), d.Apikey, redactedApiKey, -1)) } defer resp.Body.Close()