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

fix(outputs.influxdb*): Support setting Host header (#14481)

This commit is contained in:
Sam Lai 2023-12-19 14:49:40 +00:00 committed by GitHub
parent 448260a90a
commit 08fd16f3df
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -509,7 +509,11 @@ func (c *httpClient) addHeaders(req *http.Request) error {
} }
for header, value := range c.config.Headers { for header, value := range c.config.Headers {
req.Header.Set(header, value) if strings.EqualFold(header, "host") {
req.Host = value
} else {
req.Header.Set(header, value)
}
} }
return nil return nil

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

@ -13,6 +13,7 @@ import (
"net/url" "net/url"
"path" "path"
"strconv" "strconv"
"strings"
"time" "time"
"github.com/influxdata/telegraf" "github.com/influxdata/telegraf"
@ -410,7 +411,11 @@ func (c *httpClient) requestBodyReader(metrics []telegraf.Metric) io.ReadCloser
func (c *httpClient) addHeaders(req *http.Request) { func (c *httpClient) addHeaders(req *http.Request) {
for header, value := range c.Headers { for header, value := range c.Headers {
req.Header.Set(header, value) if strings.EqualFold(header, "host") {
req.Host = value
} else {
req.Header.Set(header, value)
}
} }
} }