write_influxdb.py

#from influxdb import InfluxDBClient
from influxdb.influxdb08 import InfluxDBClient
import fileinput
import json
import ast

client = InfluxDBClient('IP', 8086, 'ID', 'pw', 'twer')

for line in fileinput.input():
    line = line.replace('false','False').replace('true','True').replace('update_time','time').rstrip('\n')
    line = ast.literal_eval(line)
    line['time'] = int(line['time'])
    print line
    d = {}
    points = []
    columns = []
    for k,v in line.items():
        points.append(v)
	columns.append(k)
    d['name'] = 'ER'
    d['points'] = points
    d['columns'] = columns
    json_body = [{'points':[points], 'name':'ER', 'columns':columns}]
    print json_body
    client.write_points(json_body)

grep -e "{" ~/mbox | grep -e "}" |grep -v "null" | sed 's/.* ({ .* }).*/\1/g' | python write_influxdb.py