dom
/
telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Buffer metrics from failed writes in influxdb2 output if token is invalid (#5792)

This commit is contained in:
Greg 2019-05-01 17:46:52 -06:00 committed by Daniel Nelson
parent 2e6701b44e
commit 3592433b06
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
plugins/outputs/influxdb_v2/http.go
View File

@ -228,10 +228,11 @@ func (c *httpClient) writeBatch(ctx context.Context, bucket string, metrics []te
} }
switch resp.StatusCode { switch resp.StatusCode {
case http.StatusBadRequest, http.StatusUnauthorized, case http.StatusBadRequest, http.StatusRequestEntityTooLarge:
http.StatusForbidden, http.StatusRequestEntityTooLarge:
log.Printf("E! [outputs.influxdb_v2] Failed to write metric: %s\n", desc) log.Printf("E! [outputs.influxdb_v2] Failed to write metric: %s\n", desc)
return nil return nil
case http.StatusUnauthorized, http.StatusForbidden:
return fmt.Errorf("failed to write metric: %s", desc)
case http.StatusTooManyRequests, http.StatusServiceUnavailable: case http.StatusTooManyRequests, http.StatusServiceUnavailable:
retryAfter := resp.Header.Get("Retry-After") retryAfter := resp.Header.Get("Retry-After")
retry, err := strconv.Atoi(retryAfter) retry, err := strconv.Atoi(retryAfter)

2
plugins/outputs/influxdb_v2/influxdb.go
View File

@ -165,7 +165,7 @@ func (i *InfluxDB) Write(metrics []telegraf.Metric) error {
log.Printf("E! [outputs.influxdb_v2] when writing to [%s]: %v", client.URL(), err) log.Printf("E! [outputs.influxdb_v2] when writing to [%s]: %v", client.URL(), err)
} }
return errors.New("could not write any address") return err
} }
func (i *InfluxDB) getHTTPClient(ctx context.Context, url *url.URL, proxy *url.URL) (Client, error) { func (i *InfluxDB) getHTTPClient(ctx context.Context, url *url.URL, proxy *url.URL) (Client, error) {