insert influx data.

insert.py

#!/usr/bin/env python
#coding:utf8
from datetime import datetime
from influxdb import InfluxDBClient
import fileinput
import ast

client = InfluxDBClient("localhost", 8086, 'guest', 'guest', 'twER')
files = open('temp').read().splitlines()
points =[]
columns = ['pending_bed', 'pending_icu', 'hospital_sn', 'full_reported', 'time', 'pending_doctor', 'pending_ward']
for line in fileinput.input(files):
  line = line.replace('false', 'False').replace('true',"True").replace('update_time','time').rstrip('\n')
  try:
    line = ast.literal_eval(line)
    if isinstance(line['time'], str) and "null" in line['time']:
      f_time = fileinput.filename()[:-1] + "0"
      line['time'] = datetime.strptime(f_time, "%Y-%m-%d_%H-%M").strftime("%s")
    line['time'] = int(line['time'])
    points.append( [line[col] for col in columns] )
  except StandardError as e:
    print "{0} pass line, error: {1}".format(line, e)

json_body = [{"points":points, "name":'ER', "columns":columns}]
print len(points)
print client.write_points(json_body)