_example1

Documentation

Overview

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)

}