influxdb_client_quickstart_write_point_and_flux_query.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 = "https://us-east-1-1.aws.cloud2.influxdata.com"
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   
15point = Point("measurement1") \
16  .tag("tagname1", "tagvalue1") \
17  .field("field1", 0.6) \
18  .time(time.time_ns(), WritePrecision.NS)
19
20write_api.write(bucket=bucket, org="your-org", record=point)
21
22query_api = client.query_api()
23
24query = """from(bucket: "your-bucket")
25 |> range(start: -10m)
26 |> filter(fn: (r) => r._measurement == "measurement1")"""
27tables = query_api.query(query, org="your-org")
28
29for table in tables:
30    for record in table.records:
31        print(f'Time: {record.get_time()} Value: {record.get_value()} Measurement: {record.get_measurement()}')