CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

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.
This commit is contained in:
Greg 2020-12-21 09:14:10 -07:00 committed by GitHub
parent f067b4b75a
commit a7dff56dde
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
plugins/outputs/influxdb/http.go
View File

@ -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 { 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) loc, err := makeWriteURL(c.config.URL, db, rp, c.config.Consistency)
if err != nil { if err != nil {
return err return fmt.Errorf("failed making write url: %s", err.Error())
} }
reader, err := c.requestBodyReader(metrics) 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) req, err := c.makeWriteRequest(loc, reader)
if err != nil { if err != nil {
return err return fmt.Errorf("failed making write req: %s", err.Error())
} }
resp, err := c.client.Do(req.WithContext(ctx)) resp, err := c.client.Do(req.WithContext(ctx))
if err != nil { if err != nil {
internal.OnClientError(c.client, err) internal.OnClientError(c.client, err)
return err return fmt.Errorf("failed doing req: %s", err.Error())
} }
defer resp.Body.Close() 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) req, err := http.NewRequest("POST", url, body)
if err != nil { 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") req.Header.Set("Content-Type", "text/plain; charset=utf-8")