airflow.providers.influxdb.operators.influxdb3

Operator for executing SQL queries in InfluxDB 3.x.

Classes

InfluxDB3Operator

Execute SQL query in InfluxDB 3.x database.

Module Contents

class airflow.providers.influxdb.operators.influxdb3.InfluxDB3Operator(*, sql, influxdb3_conn_id='influxdb3_default', **kwargs)[source]

Bases: airflow.providers.common.compat.sdk.BaseOperator

Execute SQL query in InfluxDB 3.x database.

See also

For more information on how to use this operator, take a look at the guide: InfluxDB3Operator

Parameters:
template_fields: collections.abc.Sequence[str] = ('sql',)[source]
influxdb3_conn_id = 'influxdb3_default'[source]
sql[source]
execute(context)[source]

Execute SQL query and return results as JSON-serializable list of dictionaries.

Parameters:

context (airflow.sdk.definitions.context.Context) – Airflow context

Returns:

List of dictionaries representing query results

Return type:

list[dict[str, Any]]

Was this entry helpful?