learn/

package main import ( "fmt" "log" "time" client "github.com/influxdata/influxdb1-client/v2" ) func connInflux() client.Client { cli, err := client.NewHTTPClient(client.HTTPConfig{ Addr: "http://172.18.21.76:8086", Username: "admin", Password: "yozosoft", }) if err != nil { log.Fatal(err) } _, ret, err := cli.Ping(time.Second * 5) if err != nil { fmt.Println(err) return nil } fmt.Println(ret) return cli } // insert func writesPoints(cli client.Client) { bp, err := client.NewBatchPoints(client.BatchPointsConfig{ Database: "test", Precision: "s", //精度，默认ns }) if err != nil { log.Fatal(err) } tags := map[string]string{"cpu": "ih-cpu"} fields := map[string]interface{}{ "idle": 201.1, "system": 43.3, "user": 86.6, } pt, err := client.NewPoint("cpu_usage", tags, fields, time.Now()) if err != nil { log.Fatal(err) } bp.AddPoint(pt) err = cli.Write(bp) if err != nil { log.Fatal(err) } log.Println("insert success") } func main() { conn := connInflux() writesPoints(conn) }