airflow.providers.influxdb.hooks.influxdb¶
此模块允许连接到 InfluxDB 数据库。
类¶
与 InfluxDB 交互。 |
模块内容¶
- class airflow.providers.influxdb.hooks.influxdb.InfluxDBHook(conn_id=default_conn_name, *args, **kwargs)[source]¶
基类：
airflow.hooks.base.BaseHook与 InfluxDB 交互。
执行与 InfluxDB 的连接并获取客户端。
- 参数：
influxdb_conn_id – 对 Influxdb 连接 ID 的引用。
- query(query)[source]¶
运行查询。
注意：存储桶名称应包含在查询中。
- 参数：
query – InfluxDB 查询
- 返回：
列表
- 返回类型：
list[influxdb_client.client.flux_table.FluxTable]
- query_to_df(query)[source]¶
运行查询并返回 pandas 数据帧。
注意：存储桶名称应包含在查询中。
- 参数：
query – InfluxDB 查询
- 返回：
pd.DataFrame
- 返回类型：