influxdb_write.py

import influxdb

host = 'my.influxdb.server'
port = 8086
dbname = 'my_db'

def write_dicts(measurement, tagDict, fieldDict):
    myclient = influxdb.InfluxDBClient(host=host, port=port, database=dbname)
    # data is a list of points
    data = []
    # p is a point, which includes a measurement, tags, and fields (and optionally time)
    p={}
    p['measurement']=measurement
    p['tags']=tagDict
    p['fields']=fieldDict

    # Append our point to data
    data.append(p)
    myclient.write_points(data, time_precision='s')

if __name__ == "__main__":
    # example for testing
    tagDict={'tag1':'yes', 'tag2':'green'}
    fieldDict={'val1':22.33, 'val2':-42.42}
    write_dicts('my_measure', tagDict, fieldDict)