influxdb_v2_point_write_and_flux_query_quickstart.py

1import influxdb_client, os, time
2from influxdb_client import InfluxDBClient, Point, WritePrecision
3from influxdb_client.client.write_api import SYNCHRONOUS
4
5token = os.environ.get("INFLUXDB_TOKEN")
6org = "your-org"
7url = "http://localhost:8086"
8
9client = influxdb_client.InfluxDBClient(url=url, token=token, org=org)
10
11bucket="your-bucket"
12
13write_api = client.write_api(write_options=SYNCHRONOUS)
14
15for value in range(5):
16  point = (
17    Point("measurement1")
18    .tag("tagname1", "tagvalue1")
19    .field("field1", value)
20  )
21  write_api.write(bucket=bucket, org="your-org", record=point)
22  time.sleep(1) # separate points by 1 second
23
24query_api = client.query_api()
25
26query = """from(bucket: "your-bucket")
27 |> range(start: -10m)
28 |> filter(fn: (r) => r._measurement == "measurement1")"""
29
30tables = query_api.query(query, org="your-org")
31
32for table in tables:
33  for record in table.records:
34    print(f'Time: {record.get_time()} | Measurement: {record.get_measurement()} | Field: {record.get_field()} | Value: {record.get_value()}')