使用InfluxDB客户端库和SQL或InfluxQL查询数据
使用 InfluxDB 3 客户端库与 SQL 或 InfluxQL 查询存储在 InfluxDB 中的数据。 InfluxDB 3 客户端库是与您的应用程序集成的特定语言包。 执行查询并通过 Flight+gRPC 协议检索数据和元数据，然后使用您选择的语言中的工具处理数据。
使用 Go
使用 influxdb3-go Go 包和 SQL 或 InfluxQL 查询存储在 InfluxDB 中的数据。通过 Flight+gRPC 协议执行查询并检索数据，然后使用常见的 Go 工具处理数据。
import (
"context"
"github.com/InfluxCommunity/influxdb3-go/v2/influxdb3"
)
func Query() error {
client, err := influxdb3.New(influxdb3.ClientConfig{
Host: "https://cluster-host.com",
Token: "DATABASE_TOKEN",
Database: "DATABASE_NAME",
})
defer func(client *influxdb3.Client) {
err := client.Close()
if err != nil {
panic(err)
}
}(client)
query := `SELECT *
FROM home
WHERE time >= '2022-01-02T08:00:00Z'
AND time <= '2022-01-02T20:00:00Z'`
iterator, err := client.Query(context.Background(), query)
...
}
使用 Python
使用 influxdb_client_3 Python模块和SQL或InfluxQL查询存储在InfluxDB中的数据。通过Flight+gRPC协议执行查询并检索数据，然后使用常见的Python工具处理数据。
from influxdb_client_3 import InfluxDBClient3
# Instantiate an InfluxDB client
client = InfluxDBClient3(
host='cluster-host.com',
token='DATABASE_TOKEN',
database='DATABASE_NAME'
)
# Execute the query and return an Arrow table
table = client.query(
query="SELECT * FROM home",
language="sql"
)
# Return query results as a markdown table
print(table.to_pandas().to_markdown())