In [1]:

    

import numpy as np
import matplotlib.pyplot as plt
import pandas as pd

from opengrid import config
c = config.Config()

%matplotlib inline
plt.rcParams['figure.figsize'] = 16,8


    

    




/usr/local/lib/python2.7/dist-packages/matplotlib/font_manager.py:273: UserWarning: Matplotlib is building the font cache using fc-list. This may take a moment.
  warnings.warn('Matplotlib is building the font cache using fc-list. This may take a moment.')

In [2]:

    

from opengrid.library.houseprint import houseprint


    

In [3]:

    

hp = houseprint.Houseprint()


    

    




Opening connection to Houseprint sheet
Opening spreadsheets
Parsing spreadsheets
24 Sites created
24 Devices created
75 sensors created
Houseprint parsing complete

In [4]:

    

hp.sync_tmpos()


    

    




---------------------------------------------------------------------------
OperationalError                          Traceback (most recent call last)
<ipython-input-4-da1439b0e71c> in <module>()
----> 1 hp.sync_tmpos()

/mnt/data/work/opengrid/code/og/opengrid/library/houseprint/houseprint.pyc in sync_tmpos(self)
    443             Add all Flukso sensors to the TMPO session and sync
    444         """
--> 445         tmpos = self.get_tmpos()
    446         tmpos.sync()
    447 

/mnt/data/work/opengrid/code/og/opengrid/library/houseprint/houseprint.pyc in get_tmpos(self)
    436             return self._tmpos
    437         else:
--> 438             self.init_tmpo()
    439             return self._tmpos
    440 

/mnt/data/work/opengrid/code/og/opengrid/library/houseprint/houseprint.pyc in init_tmpo(self, tmpos, path_to_tmpo_data)
    414 
    415             self._tmpos = tmpo.Session(path_to_tmpo_data)
--> 416             self._add_sensors_to_tmpos()
    417 
    418         print("Using tmpo database from {}".format(self._tmpos.db))

/mnt/data/work/opengrid/code/og/opengrid/library/houseprint/houseprint.pyc in _add_sensors_to_tmpos(self)
    425 
    426         for sensor in fluksosensors:
--> 427             self._tmpos.add(sensor.key, sensor.token)
    428 
    429     def get_tmpos(self):

/mnt/data/work/opengrid/code/tmpo-py/tmpo/__init__.pyc in wrapper(*args, **kwargs)
    133             self.dbcur.execute(SQL_TMPO_TABLE)
    134             # execute function
--> 135             result = func(*args, **kwargs)
    136             # commit everything and close connection
    137             self.dbcon.commit()

/mnt/data/work/opengrid/code/tmpo-py/tmpo/__init__.pyc in add(self, sid, token)
    174     def add(self, sid, token):
    175         try:
--> 176             self.dbcur.execute(SQL_SENSOR_INS, (sid, token))
    177         except sqlite3.IntegrityError:  # sensor entry exists
    178             pass

OperationalError: database is locked

In [16]:

    

df = hp.get_data(sensortype='water', head=pd.Timestamp('now') - pd.Timedelta(days=365))
#retain only positive values (sometimes there are meter resets)
df = df[df > 0]


    

In [17]:

    

for sensor in df.columns:
    plt.figure()
    ts = df[sensor].dropna()
    ax1=plt.subplot(121)
    plt.plot_date(ts.index, ts, '-', label=sensor)
    plt.ylabel('water consumption [l/min]')
    plt.legend()
    
    ax2=plt.subplot(122)
    plt.plot(np.sort(ts)[::-1], label=sensor)
    plt.ylabel('water JBDC [l/min]')
    plt.legend()


    

In [20]:

    

for sensor in df.columns:
    plt.figure()
    ts = df[sensor]
    ts=ts[ts>1]
    ts=ts[ts<30]
    ts.hist(bins=100)
    plt.title(hp.find_sensor(sensor).device.key + ' - ' + hp.find_sensor(sensor).description + ' - ' + sensor)


    

In [19]:

    

for sensor in df.columns:
        
    plt.figure()
    ts = df[sensor]
    ts=ts[ts>0.1]
    ts=ts[ts<30]
    
    hst, edges = np.histogram(ts, np.arange(0,20,0.5))
    hst_weighted = hst * edges[1:]
    plt.plot(np.arange(0,20,0.5)[1:], hst_weighted)
    #plt.plot(np.arange(0,20,0.25)[1:], hst)
    plt.title(hp.find_sensor(sensor).device.key + ' - ' + sensor)
    plt.ylabel('Water consumption (liter)')


    

In [ ]: