Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

InfluxDBOperator

Use the InfluxDBOperator to execute SQL commands in a InfluxDB database.

An example of running the query using the operator:

tests/system/influxdb/example_influxdb_query.py[source]


    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,
    )

Was this entry helpful?