InfluxDB v2 Go 客户端库

使用 InfluxDB Go 客户端库 将数据写入 InfluxDB 3 Core 数据库。

本指南假定您对 Go 和 InfluxDB 有一定的了解。如果您是初学者，请参阅 InfluxDB 入门。

开始之前

1. 安装 Go 1.13 或更高版本.

2. 将客户端包添加到您的项目依赖项中。

   # Add InfluxDB Go client package to your project go.mod
   go get github.com/influxdata/influxdb-client-go/v2

3. 请确保 InfluxDB 正在运行并且您可以连接到它。有关连接到 InfluxDB 3 Core 集群时要使用的 URL 的信息，请联系您的 InfluxData 客户代表。

InfluxDB Go 客户端库的样板代码

使用 Go 库从 InfluxDB 写入和查询数据。

1. 在您的 Go 程序中，导入必要的包并指定可执行程序的入口点。

   package main
   
   import (
       "context"
       "fmt"
       "time"
   
       "github.com/influxdata/influxdb-client-go/v2"
   )

2. 为您的 InfluxDB 数据库 (bucket)、组织 (必需，但将被忽略) 和 数据库令牌 定义变量。

   bucket := "DATABASE_NAME"
   org := "ignored"
   token := "DATABASE_TOKEN"
   // Store the URL of your InfluxDB instance
   url := "https://:8181"

3. 创建 InfluxDB Go 客户端，并传入 url 和 token 参数。

   client := influxdb2.NewClient(url, token)

4. 使用 WriteAPIBlocking 方法创建一个**写入客户端**，并传入 org 和 bucket 参数。

   writeAPI := client.WriteAPIBlocking(org, bucket)

使用 Go 将数据写入 InfluxDB

使用 Go 库将数据写入 InfluxDB。

1. 创建一个 point，并使用 API writer 结构体的 WritePoint 方法将其写入 InfluxDB。

2. 关闭客户端以刷新所有待处理的写入并完成。

   p := influxdb2.NewPoint("stat",
     map[string]string{"unit": "temperature"},
     map[string]interface{}{"avg": 24.5, "max": 45},
     time.Now())
   writeAPI.WritePoint(context.Background(), p)
   client.Close()

完整的示例写入脚本

package main

import (
      "context"
      "fmt"
      "time"

      "github.com/influxdata/influxdb-client-go/v2"
)

func main() {
    bucket := "DATABASE_NAME"
    org := "ignored"
    token := "DATABASE_TOKEN"
    // Store the URL of your InfluxDB instance
    url := "https://:8181"
    // Create new client with default option for server url authenticate by token
    client := influxdb2.NewClient(url, token)
    // User blocking write client for writes to desired bucket
    writeAPI := client.WriteAPIBlocking(org, bucket)
    // Create point using full params constructor
    p := influxdb2.NewPoint("stat",
        map[string]string{"unit": "temperature"},
        map[string]interface{}{"avg": 24.5, "max": 45},
        time.Now())
    // Write point immediately
    writeAPI.WritePoint(context.Background(), p)
    // Ensures background processes finishes
    client.Close()
}