tests.system.influxdb.example_influxdb3¶

Example DAG demonstrating InfluxDB 3.x integration.

This example shows how to: 1. Write data points to InfluxDB 3.x 2. Query data using SQL

Attributes¶

`query_task`
`ENV_ID`
`DAG_ID`
`write_task`
`test_run`

Functions¶

write_to_influxdb3()

Write sample data to InfluxDB 3.x.

Module Contents¶

tests.system.influxdb.example_influxdb3.write_to_influxdb3()[source]¶: Write sample data to InfluxDB 3.x.

tests.system.influxdb.example_influxdb3.query_task[source]¶

tests.system.influxdb.example_influxdb3.ENV_ID[source]¶

tests.system.influxdb.example_influxdb3.DAG_ID = 'influxdb3_example_dag'[source]¶

tests.system.influxdb.example_influxdb3.write_task = None[source]¶

tests.system.influxdb.example_influxdb3.test_run[source]¶

Was this entry helpful?