Influx_Client.py

import threading
import requests
from influxdb import InfluxDBClient

influx = InfluxDBClient('localhost', 8086, '', '', 'carDB')
influxLineString = ""
canFormatString = "CANData,user=%s,src=%d,pid=%s d1=%di,d2=%di %0.0f\n"

class Influx_Client():
    def __init__(self, panda_serial):
        self.user_id = panda_serial
        self.t = []

    def InsertData(self, CS, canData):
        try:
            canData.append([canData[-1][0], 0, "steer", CS.steerAngle//10])
            canData.append([canData[-1][0], 0, "APStatus", CS.lastAPStatus])
            canData.append([canData[-1][0], 0, "speed", CS.speed])
            def SendRequest(data=canData, influxLineString = ""):
                for d in data:
                    influxLineString += (canFormatString % (self.user_id,d[1],d[2],d[3]>>32,d[3] & 0xFFFFFFFF, d[0] * 1000000000))
                headers = { 'Content-type': 'application/octet-stream', 'Accept': 'text/plain' }
                influx.request("write",'POST', {'db':'carDB'}, influxLineString.encode('utf-8'), 204, headers)
            if len(self.t) > 0: print(self.t.pop(0))
            self.t.append(threading.Thread(target=SendRequest,).run())
        except:
            r = requests.post('http://localhost:8086/query?q=CREATE DATABASE carDB')