Python Flight SQL DBAPI 客户端
Python flightsql-dbapi Flight SQL DBAPI 库与使用 SQL 查询存储在 InfluxDB Clustered 数据库中的数据的 Python 应用程序集成。flightsql-dbapi 库使用 Flight SQL 协议来查询和检索数据。
使用 InfluxDB 3 客户端库
我们建议使用 influxdb3-python Python 客户端库，将 InfluxDB 3 与您的 Python 应用程序代码集成。
InfluxDB 3 客户端库封装了 Apache Arrow Flight 客户端，并为 写入、查询和处理存储在 InfluxDB Clustered 中的数据提供了便捷的方法。客户端库可以使用 SQL 或 InfluxQL 进行查询。
安装
用于 Python 的 flightsql-dbapi Flight SQL 库为 DB API 2 接口和 SQLAlchemy 方言提供了 Flight SQL。安装 flightsql-dbapi 也会安装 pyarrow 库，您将使用该库来处理 Arrow 数据。
在您的终端中，使用 pip 安装 flightsql-dbapi
pip install flightsql-dbapi
导入模块
flightsql-dbapi 包提供了 flightsql 模块。从该模块中，导入 FlightSQLClient 类方法
from flightsql import FlightSQLClient
flightsql.FlightSQLClient类：用于初始化客户端和与 Flight SQL 服务器交互的接口。
API 参考
类 FlightSQLClient
提供用于初始化客户端和与 Flight SQL 服务器交互的接口。
语法
__init__(self, host=None, token=None, metadata=None, features=None)
初始化并返回用于与服务器交互的 FlightSQLClient 实例。
初始化客户端
以下示例展示了如何将 Python 与 flightsql-dbapi 和 DB API 2 接口一起使用，以实例化为 InfluxDB 数据库配置的 Flight SQL 客户端。
from flightsql import FlightSQLClient
# Instantiate a FlightSQLClient configured for a database
client = FlightSQLClient(host='cluster-host.com',
token='DATABASE_TOKEN',
metadata={'database': 'DATABASE_NAME'},
features={'metadata-reflection': 'true'})
替换以下内容
实例方法
FlightSQLClient.execute
发送 Flight SQL RPC 请求以执行指定的 SQL 查询。
语法
execute(query: str, call_options: Optional[FlightSQLCallOptions] = None)
示例
# Execute the query
info = client.execute("SELECT * FROM home")
响应包含一个 flight.FlightInfo 对象，其中包含元数据和一个 endpoints: [...] 列表。每个端点包含以下内容
- 您可以检索查询结果数据的地址列表。
- 一个
ticket值，用于标识要检索的数据。
FlightSQLClient.do_get
传递 Flight Ticket（从 FlightSQLClient.execute 响应中获得）并检索由 Ticket 标识的 Arrow 数据。返回用于流式传输数据的 pyarrow.flight.FlightStreamReader。
语法
do_get(ticket, call_options: Optional[FlightSQLCallOptions] = None)
示例
以下示例展示了如何将 Python 与 flightsql-dbapi 和 pyarrow 一起使用，以查询 InfluxDB 并检索数据。
from flightsql import FlightSQLClient
# Instantiate a FlightSQLClient configured for a database
client = FlightSQLClient(host='cluster-host.com',
token='DATABASE_TOKEN',
metadata={'database': 'DATABASE_NAME'},
features={'metadata-reflection': 'true'})
# Execute the query to retrieve FlightInfo
info = client.execute("SELECT * FROM home")
# Extract the token for retrieving data
ticket = info.endpoints[0].ticket
# Use the ticket to request the Arrow data stream.
# Return a FlightStreamReader for streaming the results.
reader = client.do_get(ticket)
# Read all data to a pyarrow.Table
table = reader.read_all()
print(table)
do_get(ticket) 返回一个 pyarrow.flight.FlightStreamReader，用于流式传输 Arrow 记录批次。
要从流中读取数据，请调用以下 FlightStreamReader 方法之一
read_all()：将所有记录批次读取为pyarrow.Table。read_chunk()：读取下一个 RecordBatch 和元数据。read_pandas()：读取所有记录批次并将它们转换为pandas.DataFrame。
此页是否对您有帮助？
感谢您的反馈！
支持和反馈
感谢您成为我们社区的一份子！我们欢迎并鼓励您提供关于 InfluxDB Clustered 和本文档的反馈和错误报告。要获得支持，请使用以下资源
拥有年度或支持合同的客户可以联系 InfluxData 支持。