Go和InfluxDB

免费使用此InfluxDB集成

使用Go客户端库和InfluxDB构建IoT、分析和云应用程序。

为什么使用InfluxDB Go客户端库?

InfluxDB是一个以API为先的时间序列数据库,适用于您的Go语言应用程序。使用InfluxDB开源Go API客户端在您的应用程序中编写和查询数据,甚至管理您的InfluxDB实例。

主要功能

  • 提供对InfluxDB所有写入和读取功能、设置以及管理实例等高级功能的API访问。
  • 使用InfluxDB行协议或点数据结构写入数据
  • 异步或同步写入数据
  • 自动在失败时重试请求
  • 参数化查询(仅限InfluxDB Cloud)
  • 检查服务器状态
    • 健康 - 关于服务器状态的详细信息,包括版本字符串(开源软件)
    • 就绪 - 服务器运行时间信息(开源软件)
    • ping - 服务器是否运行

入门指南

使用Go和InfluxDB入门

本教程向您展示了如何使用InfluxDB Go客户端库,创建到数据库的连接,并从中存储和查询数据。

了解更多

使用InfluxDB Go客户端入门

想要快速并发获取数据并轻松进行二进制部署的应用程序?那么请使用InfluxDB Go客户端。

了解更多

读取

写入


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()
}

有关更多信息,请参阅文档。

项目URL   Go客户端库文档

相关资源

InfluxDb-cloud-logo

最强大的时间序列
数据库作为服务

免费开始
Influxdbu

开发者教育

为时间序列应用程序开发者提供培训。

查看所有教育