go influxdb 批量写入 api
  mtfBvWHnJ7tD 2023年11月02日 45 0


a := []string{}
 
a1 := strings.Join(a, "\n")
reader := bytes.NewBuffer([]byte(a1))
cHttp := &http.Client{Timeout: 10 * time.Second}
resp, _ := http.NewRequest("POST", "http://localhost:8086/api/v2/write?org=org&bucket=test&precision=s", reader)
resp.Header.Add("Authorization", "Token 12345")
resp.Header.Set("Content-Type", "text/plain; charset=utf-8")
resp.Header.Set("Accept", "application/json")
_, _ = cHttp.Do(resp)


influxdbClient := influxdb2.NewClient("http://", "")
	influxdbClient.Options().SetPrecision(time.Second)
	writeAPI := influxdbClient.WriteAPIBlocking("org", "test")

	data := make(map[string]float64)
	data["1"] = 71.00
	data["2"] = 72.00
	data["3"] = 73.00
	data["4"] = 74.00

	var pList []*write.Point
	for k, v := range data {
		p := influxdb2.NewPoint("cpu",
			map[string]string{"id": "123", "cpu": k},
			map[string]interface{}{"s": v},
			time.Now())
		pList = append(pList, p)
	}
	fmt.Println(pList)
	_ = writeAPI.WritePoint(context.Background(), pList...)
	_ = writeAPI.Flush(context.Background())
	influxdbClient.Close()
【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

  1. 分享:
最后一次编辑于 2023年11月08日 0

暂无评论

推荐阅读
  m33FiQF5dk1h   2023年11月13日   22   0   0 重启IISjson
  0C74k909wmgc   2023年11月13日   31   0   0 pythonjson
  hs9CtFCuSvuL   2023年11月19日   27   0   0 DatabaseHCLjson
  EeGZtZT5Jsfk   2023年11月13日   30   0   0 请求头jsoncurl