FilesExpand file tree

master

/

influx_cloud.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

55 lines (43 loc) · 1.46 KB

master

/

influx_cloud.py

Copy path

Top

File metadata and controls

• Code
• Blame

55 lines (43 loc) · 1.46 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

"""

Connect to InfluxDB 2.0 - write data and query them

"""

from datetime import datetime, timezone

from influxdb_client import Point, InfluxDBClient

from influxdb_client.client.write_api import SYNCHRONOUS

"""

Configure credentials

"""

influx_cloud_url = 'https://us-west-2-1.aws.cloud2.influxdata.com'

influx_cloud_token = '...'

bucket = '...'

org = '...'

with InfluxDBClient(url=influx_cloud_url, token=influx_cloud_token) as client:

kind = 'temperature'

host = 'host1'

device = 'opt-123'

"""

Write data by Point structure

"""

point = Point(kind).tag('host', host).tag('device', device).field('value', 25.3) \

.time(time=datetime.now(tz=timezone.utc))

print(f'Writing to InfluxDB cloud: {point.to_line_protocol()} ...')

write_api = client.write_api(write_options=SYNCHRONOUS)

write_api.write(bucket=bucket, org=org, record=point)

print()

print('success')

print()

print()

"""

Query written data

"""

query = f'from(bucket: "{bucket}") |> range(start: -1d) |> filter(fn: (r) => r._measurement == "{kind}")'

print(f'Querying from InfluxDB cloud: "{query}" ...')

print()

query_api = client.query_api()

tables = query_api.query(query=query, org=org)

for table in tables:

for row in table.records:

print(f'{row.values["_time"]}: host={row.values["host"]},device={row.values["device"]} '

f'{row.values["_value"]} °C')

print()

print('success')