51 lines
1.0 KiB
Python
51 lines
1.0 KiB
Python
import pandas as pd
|
|
from peewee import *
|
|
from playhouse import sqlite_ext
|
|
from playhouse.sqlite_ext import SqliteExtDatabase
|
|
|
|
db = SqliteExtDatabase('pywatts.db')
|
|
|
|
|
|
class WeatherStation(Model):
|
|
longitude = IntegerField()
|
|
latitude = IntegerField()
|
|
location = CharField()
|
|
elevation = IntegerField()
|
|
city = CharField()
|
|
state = CharField()
|
|
id = CharField(unique=True)
|
|
|
|
class Meta:
|
|
database = db
|
|
|
|
|
|
class Result(Model):
|
|
station = ForeignKeyField(WeatherStation)
|
|
dc_output = sqlite_ext.JSONField()
|
|
temperature = sqlite_ext.JSONField()
|
|
wind_speed = sqlite_ext.JSONField()
|
|
|
|
class Meta:
|
|
database = db
|
|
|
|
|
|
def rows_to_df(indices):
|
|
temps = []
|
|
dcs = []
|
|
winds = []
|
|
|
|
db.connect()
|
|
|
|
for result in Result.select().where(Result.id << indices):
|
|
temps += result.temperature
|
|
dcs += result.dc_output
|
|
winds += result.wind_speed
|
|
|
|
db.close()
|
|
|
|
return pd.DataFrame(
|
|
{'temp': temps,
|
|
'dc': dcs,
|
|
'wind': winds
|
|
})
|