From a7dff56ddea2acf9fc4ec9bf6e2314cb49bea05d Mon Sep 17 00:00:00 2001 From: Greg <2653109+glinton@users.noreply.github.com> Date: Mon, 21 Dec 2020 09:14:10 -0700 Subject: [PATCH] Add more verbose errors to influxdb output (#6061) Looks like ear/959 has already been resolved, but these additional information for the errors still seems useful. I just re-based the change and merging. --- plugins/outputs/influxdb/http.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/plugins/outputs/influxdb/http.go b/plugins/outputs/influxdb/http.go index 57e3e918b..87c5a89b0 100644 --- a/plugins/outputs/influxdb/http.go +++ b/plugins/outputs/influxdb/http.go @@ -316,7 +316,7 @@ func (c *httpClient) Write(ctx context.Context, metrics []telegraf.Metric) error func (c *httpClient) writeBatch(ctx context.Context, db, rp string, metrics []telegraf.Metric) error { loc, err := makeWriteURL(c.config.URL, db, rp, c.config.Consistency) if err != nil { - return err + return fmt.Errorf("failed making write url: %s", err.Error()) } reader, err := c.requestBodyReader(metrics) @@ -327,13 +327,13 @@ func (c *httpClient) writeBatch(ctx context.Context, db, rp string, metrics []te req, err := c.makeWriteRequest(loc, reader) if err != nil { - return err + return fmt.Errorf("failed making write req: %s", err.Error()) } resp, err := c.client.Do(req.WithContext(ctx)) if err != nil { internal.OnClientError(c.client, err) - return err + return fmt.Errorf("failed doing req: %s", err.Error()) } defer resp.Body.Close() @@ -426,7 +426,7 @@ func (c *httpClient) makeWriteRequest(url string, body io.Reader) (*http.Request req, err := http.NewRequest("POST", url, body) if err != nil { - return nil, err + return nil, fmt.Errorf("failed creating new request: %s", err.Error()) } req.Header.Set("Content-Type", "text/plain; charset=utf-8")