In [1]:

    

import pandas as pd
from influxdb import DataFrameClient


    

In [6]:

    

user = 'root'
password = 'root'
dbname = 'base42'
host='localhost'
port=32769
bsize = 5000 #batch size
# Temporarily avoid line protocol time conversion issues #412, #426, #431.
protocol = 'json'
client = DataFrameClient(host, port, user, password, dbname)


    

In [7]:

    

client.create_database(dbname)
client.query("show databases")


    

    
Out[7]:





ResultSet({'(u'databases', None)': [{u'name': u'_internal'}, {u'name': u'demodb'}, {u'name': u'base42'}]})

In [8]:

    

for measure in ['gas','water','electricity','heating','temperature']:
    df=pd.read_csv('data/'+measure+'_ft.csv',parse_dates=True,index_col='ts').drop('measurement_unit',axis=1)
    client.write_points(df, measure, protocol=protocol, tag_columns=['monitor_id'], field_columns=['measurement'], batch_size=bsize)
    print(measure)


    

    




gas
water
electricity
heating
temperature

In [ ]:

    

print("Delete database: " + dbname)
client.drop_database(dbname)