Commit e9abe7b8 authored by Node- 门 忠鑫's avatar Node- 门 忠鑫

修改influxdb 生成ip和database.name

parent dafb0fdf
...@@ -8,7 +8,7 @@ import ( ...@@ -8,7 +8,7 @@ import (
func NewClient() client.Client { func NewClient() client.Client {
conf := client.HTTPConfig{ conf := client.HTTPConfig{
Addr: "http://localhost:8086", Addr: "http://172.20.6.29:8086",
} }
con, err := client.NewHTTPClient(conf) con, err := client.NewHTTPClient(conf)
......
...@@ -31,7 +31,7 @@ func msgInfluxProcess(traceMsgs []TraceMsg) { ...@@ -31,7 +31,7 @@ func msgInfluxProcess(traceMsgs []TraceMsg) {
defer func() { _ = c.Close() }() defer func() { _ = c.Close() }()
points, err := client.NewBatchPoints(client.BatchPointsConfig{ points, err := client.NewBatchPoints(client.BatchPointsConfig{
Database: "udp", Database: "monitor",
}) })
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment