InfluxDBOperator
InfluxDBExecutes sql code in a specific InfluxDB database
Access Instructions
Install the InfluxDB provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
sqlRequiredthe sql code to be executed. Can receive a str representing a sql statement
influxdb_conn_idReference to Influxdb connection id.
Documentation
Executes sql code in a specific InfluxDB database
See also
For more information on how to use this operator, take a look at the guide: InfluxDBOperator