mirror of
https://github.com/pommi/python-itho-wpu.git
synced 2024-11-14 12:42:15 +01:00
26 lines
750 B
Python
26 lines
750 B
Python
|
import datetime
|
||
|
|
import os
|
||
|
|
|
||
|
|
|
||
|
|
def export_to_influxdb(action, measurements):
|
||
|
|
from influxdb import InfluxDBClient
|
||
|
|
|
||
|
|
influx_client = InfluxDBClient(
|
||
|
|
host=os.getenv('INFLUXDB_HOST', 'localhost'),
|
||
|
|
port=os.getenv('INFLUXDB_PORT', 8086),
|
||
|
|
username=os.getenv('INFLUXDB_USERNAME', 'root'),
|
||
|
|
password=os.getenv('INFLUXDB_PASSWORD', 'root'),
|
||
|
|
database=os.getenv('INFLUXDB_DATABASE')
|
||
|
|
)
|
||
|
|
json_body = [
|
||
|
|
{
|
||
|
|
"measurement": action,
|
||
|
|
"time": datetime.datetime.utcnow().replace(microsecond=0).isoformat(),
|
||
|
|
"fields": measurements,
|
||
|
|
}
|
||
|
|
]
|
||
|
|
try:
|
||
|
|
influx_client.write_points(json_body)
|
||
|
|
except Exception as e:
|
||
|
|
print('Failed to write to influxdb: ', e)
|