In [28]:

    

import pandas as pd
from influxdb import DataFrameClient


    

In [42]:

    

#user = 'root'
#password = 'root'
host='localhost'
dbname='upp_bare_measure'
port=34000
bsize = 5000 #batch size
protocol = 'json'
#client = DataFrameClient(host, port, user, password, dbname)
client = DataFrameClient(host, port,'','',dbname)


    

In [43]:

    

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


    

    
Out[43]:





ResultSet({'(u'databases', None)': [{u'name': u'upp_bare_measure'}]})

In [44]:

    

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


    

    




gas
water
electricity

In [45]:

    

dbname='upp_bare_control'
client = DataFrameClient(host, port,'','',dbname)
client.create_database(dbname)
client.query("show databases")


    

    
Out[45]:





ResultSet({'(u'databases', None)': [{u'name': u'upp_bare_measure'}, {u'name': u'upp_bare_control'}]})

In [46]:

    

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


    

    




heating
temperature

In [ ]:

    

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