InfluxDBOperator¶

使用 InfluxDBOperator 在 InfluxDB 数据库中执行 SQL 命令。

使用操作符运行查询的示例

tests/system/providers/influxdb/example_influxdb_query.py[源代码]

    query_influxdb_task = InfluxDBOperator(
        influxdb_conn_id="influxdb_conn_id",
        task_id="query_influxdb",
        sql='from(bucket:"test-influx") |> range(start: -10m, stop: {{ds}})',
        dag=dag,
    )