使用 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())
此页面是否对您有帮助？
感谢您的反馈！
支持和反馈
感谢您成为我们社区的一份子！我们欢迎并鼓励您提供关于 InfluxDB Clustered 和本文档的反馈和错误报告。要获得支持，请使用以下资源
拥有年度合同或支持合同的客户可以联系 InfluxData 支持。