`airflow.providers.influxdb.hooks.influxdb`¶

This module allows to connect to a InfluxDB database.

Module Contents¶

Interact with InfluxDB.

class airflow.providers.influxdb.hooks.influxdb.InfluxDBHook(conn_id=default_conn_name, *args, **kwargs)[source]¶

Interact with InfluxDB.

Performs a connection to InfluxDB and retrieves client.

classmethod get_connection_form_widgets()[source]¶

Return connection widgets to add to connection form.

get_client(uri, kwargs)[source]¶

get_uri(conn)[source]¶

Add additional parameters to the URI based on InfluxDB host requirements.

Initiate a new InfluxDB connection with token and organization name.

query(query)[source]¶

Run the query.

Note: The bucket name should be included in the query.

query_to_df(query)[source]¶

Run the query and return a pandas dataframe.

Note: The bucket name should be included in the query.

write(bucket_name, point_name, tag_name, tag_value, field_name, field_value, synchronous=False)[source]¶

Write a Point to the bucket specified.

Example: Point("my_measurement").tag("location", "Prague").field("temperature", 25.3)

create_bucket(bucket_name, description, org_id, retention_rules=None)[source]¶: Create a bucket for an organization.