diff --git a/plugins/outputs/influxdb_v2/http.go b/plugins/outputs/influxdb_v2/http.go index 12826ff92..4f1cd32dd 100644 --- a/plugins/outputs/influxdb_v2/http.go +++ b/plugins/outputs/influxdb_v2/http.go @@ -267,9 +267,9 @@ func makeWriteURL(loc url.URL, org, bucket string) (string, error) { case "unix": loc.Scheme = "http" loc.Host = "127.0.0.1" - loc.Path = "v2/write" + loc.Path = "/api/v2/write" case "http", "https": - loc.Path = path.Join(loc.Path, "v2/write") + loc.Path = path.Join(loc.Path, "/api/v2/write") default: return "", fmt.Errorf("unsupported scheme: %q", loc.Scheme) } diff --git a/plugins/outputs/influxdb_v2/http_internal_test.go b/plugins/outputs/influxdb_v2/http_internal_test.go index 5df51fc85..748519a7b 100644 --- a/plugins/outputs/influxdb_v2/http_internal_test.go +++ b/plugins/outputs/influxdb_v2/http_internal_test.go @@ -21,11 +21,11 @@ func TestMakeWriteURL(t *testing.T) { }{ { url: genURL("http://localhost:9999"), - act: "http://localhost:9999/v2/write?bucket=telegraf&org=influx", + act: "http://localhost:9999/api/v2/write?bucket=telegraf&org=influx", }, { url: genURL("unix://var/run/influxd.sock"), - act: "http://127.0.0.1/v2/write?bucket=telegraf&org=influx", + act: "http://127.0.0.1/api/v2/write?bucket=telegraf&org=influx", }, { err: true,