InfluxDBOperator¶

使用 InfluxDBOperator 以在 InfluxDB 資料庫中執行 SQL 命令。

使用運算子執行查詢的範例

tests/system/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,
    )