You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

26 lines
751 B

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"),
json_body = [
"measurement": action,
"time": datetime.datetime.utcnow().replace(microsecond=0).isoformat(),
"fields": measurements,
except Exception as e:
print("Failed to write to influxdb: ", e)