Go和InfluxDB
免费使用此InfluxDB集成使用Go客户端库和InfluxDB构建IoT、分析和云应用程序。
为什么使用InfluxDB Go客户端库?
InfluxDB是一个以API为先的时间序列数据库,适用于您的Go语言应用程序。使用InfluxDB开源Go API客户端在您的应用程序中编写和查询数据,甚至管理您的InfluxDB实例。
主要功能
- 提供对InfluxDB所有写入和读取功能、设置以及管理实例等高级功能的API访问。
- 使用InfluxDB行协议或点数据结构写入数据
- 异步或同步写入数据
- 自动在失败时重试请求
- 参数化查询(仅限InfluxDB Cloud)
- 检查服务器状态
- 健康 - 关于服务器状态的详细信息,包括版本字符串(开源软件)
- 就绪 - 服务器运行时间信息(开源软件)
- ping - 服务器是否运行
入门指南
读取
写入
package main
import (
"context"
"fmt"
influxdb2 "github.com/influxdata/influxdb-client-go/v2"
)
func main() {
url := "https://us-west-2-1.aws.cloud2.influxdata.com"
token := "my-token"
org := "my-org"
bucket := "my-bucket"
client := influxdb2.NewClient(url, token)
queryAPI := client.QueryAPI(org)
query := fmt.Sprintf(`from(bucket: "%v") |> range(start: -1d)`, bucket)
result, err := queryAPI.Query(context.Background(), query)
if err != nil {
panic(err)
}
for result.Next() {
record := result.Record()
fmt.Printf("%v %v: %v=%v\n", record.Time(), record.Measurement(), record.Field(), record.Value())
}
client.Close()
}
有关更多信息,请参阅文档。