Code : Tout sélectionner
import scriptUtilities
import json
import urllib2
import datetime
import time
def readWind(yApi, windDirectionKw, minWindKw, avgWindKw, maxWindKw):
try:
pioupiouAnswer = json.load(urllib2.urlopen("http://api.pioupiou.fr/v1/live/532?format=json"))
except Exception as e:
print 'Error requesting data to pioupiou website', e.message
return
if pioupiouAnswer[u'data'][u'status'][u'state'] != u'on':
print 'Station is OFF'
return
if datetime.datetime.strptime(pioupiouAnswer[u'data'][u'measurements'][u'date'], "%Y-%m-%dT%H:%M:%S.%fZ") < (datetime.datetime.utcnow() - datetime.timedelta(minutes=30)):
print 'Measure is too old'
return
windDirection = pioupiouAnswer[u'data'][u'measurements'][u'wind_heading']
minWind = pioupiouAnswer[u'data'][u'measurements'][u'wind_speed_min']
avgWind = pioupiouAnswer[u'data'][u'measurements'][u'wind_speed_avg']
maxWind = pioupiouAnswer[u'data'][u'measurements'][u'wind_speed_max']
print "Wind direction =", windDirection, ", min speed =", minWind, ", avg speed =", avgWind, ", max speed =", maxWind
# Direction
yApi.writeKeyword(windDirectionKw, str(windDirection))
# Speeds : convert to m/s
if minWind is not None:
yApi.writeKeyword(minWindKw, str(minWind * 1000 / 3600))
if avgWind is not None:
yApi.writeKeyword(avgWindKw, str(avgWind * 1000 / 3600))
if maxWind is not None:
yApi.writeKeyword(maxWindKw, str(maxWind * 1000 / 3600))
def yMain(yApi):
windDirectionKw = yApi.getKeywordId('Vent - direction', 'direction')
minWindKw = yApi.getKeywordId('Vent minimum', 'speed')
avgWindKw = yApi.getKeywordId('Vent moyen', 'speed')
maxWindKw = yApi.getKeywordId('Vent maximum', 'speed')
while(True):
readWind(yApi, windDirectionKw, minWindKw, avgWindKw, maxWindKw)
time.sleep(1800)