InfluxDBOperator¶

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

An example of running the query using the operator:

airflow/providers/influxdb/example_dags/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,
)