store.py

from influxdb import InfluxDBClient
from influxdb.client import InfluxDBClientError

class InfluxWriter(object):
    def __init__(self):
        self.client = InfluxDBClient(
            "influxsrv.hyperpilot", 8086, "root", "root", "be_controller")
        try:
            self.client.create_database("be_controller")
        except InfluxDBClientError:
            pass #Ignore

    def write(self, time, hostname, controller, data):
        try:
            self.client.write_points([{
                "time": time,
                "tags": {
                    "hostname": hostname,
                },
                "measurement": controller,
                "fields": data,
            }])
        except InfluxDBClientError as e:
            print("Store:ERROR: Error writing to influx: " + str(e))