98 lines
2.4 KiB
Python
98 lines
2.4 KiB
Python
|
|
||
|
|
import logging
|
||
|
|
|
||
|
|
import time
|
||
|
|
|
||
|
|
import datetime
|
||
|
|
|
||
|
|
import urllib.parse
|
||
|
|
|
||
|
|
import http.client
|
||
|
|
|
||
|
|
from influxdb import InfluxDBClient
|
||
|
|
|
||
|
|
from oko_user_config import *
|
||
|
|
|
||
|
|
oko_influxdb_query = "select last(temperature), humidity, light, windspeed, pressure from weather where device='"
|
||
|
|
|
||
|
|
def read_data_from_influxdb():
|
||
|
|
# temp, hum, wind, pres, date
|
||
|
|
ret = [ 0.0, 0.0, 0.0, 0.0, "" ]
|
||
|
|
|
||
|
|
client = InfluxDBClient(oko_server, oko_server_port, oko_user, oko_password, oko_dbname)
|
||
|
|
|
||
|
|
query = oko_influxdb_query + oko_weatherstation_name + "';"
|
||
|
|
print(query)
|
||
|
|
|
||
|
|
qres = client.query(query)
|
||
|
|
print(qres)
|
||
|
|
|
||
|
|
tdata = qres.raw['series'][0]['values'][0]
|
||
|
|
|
||
|
|
print(tdata)
|
||
|
|
|
||
|
|
ret[0] = tdata[1] # temp
|
||
|
|
ret[1] = tdata[2] # hum
|
||
|
|
ret[2] = tdata[4] * 1000 # wind km/h to m/s
|
||
|
|
ret[3] = tdata[5] # pres
|
||
|
|
ret[4] = tdata[0] # date
|
||
|
|
|
||
|
|
print(ret)
|
||
|
|
return ret
|
||
|
|
|
||
|
|
def send_data_to_openweather(temp, hum, wind, pres, date):
|
||
|
|
|
||
|
|
# http://api.openweathermap.org/data/3.0/stations?appid=
|
||
|
|
http.client.HTTPSConnection.debuglevel = 1
|
||
|
|
conn = http.client.HTTPSConnection("api.openweathermap.com")
|
||
|
|
|
||
|
|
logging.basicConfig()
|
||
|
|
logging.getLogger().setLevel(logging.DEBUG)
|
||
|
|
requests_log = logging.getLogger("requests.packages.urllib3")
|
||
|
|
requests_log.setLevel(logging.DEBUG)
|
||
|
|
requests_log.propagate = True
|
||
|
|
|
||
|
|
url = "/data/3.0/stations?appid=" + openweather_api_key
|
||
|
|
|
||
|
|
data = '[{"station_id":"' + openweather_station_id + '",' + \
|
||
|
|
'"dt":' + str(date) + '",' + \
|
||
|
|
'"temperature":"' + str(temp) + '",' + \
|
||
|
|
'"wind_speed":"' + str(wind) + '",' + \
|
||
|
|
'"pressure":"' + str(pres) + '",' + \
|
||
|
|
'"humidity":"' + str(hum) + '"' + \
|
||
|
|
'}]'
|
||
|
|
|
||
|
|
header = { "Content-Type" : "application/json" }
|
||
|
|
|
||
|
|
print(url)
|
||
|
|
print(data)
|
||
|
|
print(header)
|
||
|
|
|
||
|
|
#conn.request("POST", url, urllib.parse.urlencode(data), header)
|
||
|
|
conn.request("POST", url, data, header)
|
||
|
|
|
||
|
|
res = conn.getresponse()
|
||
|
|
print(res.read())
|
||
|
|
|
||
|
|
def date_to_str(date):
|
||
|
|
date = date.replace("T", " ")[0:19]
|
||
|
|
ret = int(time.mktime(datetime.datetime.strptime(date, "%Y-%m-%d %H:%M:%S").timetuple()))
|
||
|
|
return ret
|
||
|
|
|
||
|
|
if __name__ == "__main__":
|
||
|
|
|
||
|
|
data = [ 0.0, 0.0, 0.0, 0.0, 0 ]
|
||
|
|
|
||
|
|
data = read_data_from_influxdb()
|
||
|
|
|
||
|
|
temp = data[0]
|
||
|
|
hum = data[1]
|
||
|
|
wind = data[2]
|
||
|
|
pres = data[3]
|
||
|
|
date = data[4]
|
||
|
|
|
||
|
|
tdate = date_to_str(date)
|
||
|
|
|
||
|
|
send_data_to_openweather(temp, hum, wind, pres, tdate)
|
||
|
|
|