In [220]:

    

import pandas
from disaggregator import utils


    

    
Out[220]:





<module 'disaggregator.utils' from '../disaggregator/utils.py'>

In [232]:

    

reload(utils)


    

    
Out[232]:





<module 'disaggregator.utils' from '../disaggregator/utils.py'>

In [1]:

    

import sys
sys.path.append('../')


    

In [14]:

    

import disaggregator.PecanStreet as pecan


user_name = 'USERNAME'
pw='PASSWORD'
host = "db.wiki-energy.org"
port = "5432"
db = "postgres"
db_url = "postgresql"+"://"+user_name+":"+pw+"@"+host+":"+port+"/"+db

table = {'curated':'\"PecanStreet_CuratedSets\"','raw':'\"PecanStreet_RawData\"','shared':'\"PecanStreet_SharedData\"'}


    

In [227]:

    

reload(pecan)


    

    
Out[227]:





<module 'disaggregator.PecanStreet' from '../disaggregator/PecanStreet.py'>

In [228]:

    

pecan.set_url(db_url)


    

In [31]:

    

pecan.eng


    

    
Out[31]:





Engine(postgresql://stomkins:***@db.wiki-energy.org:5432/postgres)

In [41]:

    

schema = 'shared'


    

In [47]:

    

tables= pecan.get_table_names(schema)


    

In [53]:

    

[i,a] = pecan.get_table_metadata(schema,str(tables[0]))


    

In [66]:

    

query = 'select * from {0}.{1} where dataid={2}'.format(pecan.schema_names[schema], tables[0],i[0])
df = pecan.get_dataframe(query).fillna(0)


    

In [120]:

    

temp = pecan.clean_dataframe(df,schema,[])
test = pecan.get_month_traces(schema,tables[0],i[0])


    

In [125]:

    

test[3].series.name


    

    
Out[125]:





u'air3'

In [229]:

    

test_all = pecan.get_app_traces_all(schema,tables[0],'air1',i)


    

In [233]:

    

utils.pickle_object(test_all,'air_{}'.format(tables[0]))


    

In [226]:

    

test_all[0].series.name


    

    
Out[226]:





'air1'

In [ ]: