`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.

get_uri(self, conn)[source]¶

Function to add additional parameters to the URI based on SSL or other InfluxDB host requirements

get_conn(self)[source]¶

Function that initiates a new InfluxDB connection with token and organization name

query(self, query)[source]¶

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

query_to_df(self, query)[source]¶

Function to run the query and return a pandas dataframe Note: The bucket name should be included in the query

write(self, bucket_name, point_name, tag_name, tag_value, field_name, field_value, synchronous=False)[source]¶: Writes a Point to the bucket specified. Example: Point("my_measurement").tag("location", "Prague").field("temperature", 25.3)

create_organization(self, name)[source]¶: Function to create a new organization

delete_organization(self, org_id)[source]¶: Function to delete organization by organization id

create_bucket(self, bucket_name, description, org_id, retention_rules=None)[source]¶: Function to create a bucket for an organization

find_bucket_id_by_name(self, bucket_name)[source]¶: Function to get bucket id by name.

delete_bucket(self, bucket_name)[source]¶: Function to delete bucket by bucket name.