Tweet
SELECT difference(last("value")) FROM "autogen"."data" WHERE ("device" = 'SDM1.1' AND "type" = 'Import') AND $timeFilter GROUP BY time(1d) fill(null)
SELECT mean("prelievo_immissione") + mean("solare") as "consumo" FROM
(SELECT mean("value") as "prelievo_immissione" FROM "autogen"."data" WHERE ("device" = 'SDM1.1' AND "type" = 'PowerL1') AND $timeFilter GROUP BY time($__interval) fill(previous)),
(SELECT mean("value") as "solare" FROM "autogen"."data" WHERE ("device" = 'SDM1.2' AND "type" = 'PowerL1') AND $timeFilter GROUP BY time($__interval) fill(previous))
GROUP BY time($__interval) fill(null)
QUERY a + b ( sub-query AS a ), ( sub-query AS b )
#
# script in python realizzato da Cattaneo Fabrizio ( portalsole.it ) per importare l'ultimo feed scritto in emoncms ed inviarlo ad una installazione di InfluxDb
# questo programma va schedulato con lo scheduler di Linux ( es. 1 volta al minuto )
# servono le librerie x Influxdb :
# sudo apt-get install python-influxdb
#
import urllib
import time;
from influxdb import InfluxDBClient
timestamp = int(time.time())
timestamp=timestamp*1000000000 #timestamp in nanosecond pro influx
API= "0aee8ab02cee81xaxax11222xcaxa11b9" # emoncms API key
def feedval(feedid):
data_url="http://localhost/emoncms/feed/value.json?apikey=" + API + "&id=" + str(feedid)
# read in the data from emoncms
try:
sock = urllib.urlopen(data_url)
data_str = sock.read()
sock.close
return float(data_str)
except Exception, detail:
print "Error ", detail
pw1=feedval(191) #get potenza solare termico
pw2=feedval(104626) #get potenza prodotta PDC from emoncms
pw4=feedval(167) #get potenza fotovoltaico from emoncms
pw5=feedval(104669) #get potenza consumata PDC in riscalamento
pw6=feedval(179) #get potenza totale consumata
pw7=feedval(172) #get potenza scambiata
tk=feedval(186)*100 #get temperatura pannelli TK
ts=feedval(187)*100 #get temperatura TS
tr=feedval(188)*100 #get temperatura TR
ta=feedval(104558)*100 #get temperatura esterna
t2=feedval(104625)*100 #get temperatura ingresso PDC
t3=feedval(104624)*100 #get temperatura uscita PDC
t5=feedval(104581)*100 #get temperatura ACS
q1=feedval(104620)*100 #get portata acqua al solare
q2=feedval(104627)*100 #get portata acqua riscaldamento
pm10=feedval(104682)*100 #get livello polveri PM10 esterno
pm25=feedval(104685)*100 #get livello polveri PM2.5 esterno
#dati impianto in isola:
soc=feedval(104640) #get battery SOC
Vbat=feedval(171)*100 #get battery voltage
Ibat=feedval(104632) #get battery current
Ipv=feedval(104629) #get PV current
load=feedval(104600) #get current to load
client = InfluxDBClient(host='localhost', port=8086)
client.switch_database('test')
json_body = [
{
"measurement": "Potenze",
"time": timestamp,
"fields": {
"pw1": pw1,
"pw2": pw2,
"pw4": pw4,
"pw5": pw5,
"pw6": pw6,
"pw7": pw7
}
}
]
client.write_points(json_body)
json_body = [
{
"measurement": "Temperature",
"time": timestamp,
"fields": {
"tk": tk,
"ts": ts,
"tr": tr,
"ta": ta,
"t2": t2,
"t3": t3,
"t5": t5
}
}
]
client.write_points(json_body)
json_body = [
{
"measurement": "Isola",
"time": timestamp,
"fields": {
"soc": soc,
"Vbat": Vbat,
"Ibat": Ibat,
"Ipv": Ipv,
"load": load
}
}
]
client.write_points(json_body)
json_body = [
{
"measurement": "Varie",
"time": timestamp,
"fields": {
"q1": q1,
"q2": q2,
"pm10": pm10,
"pm25": pm25
}
}
]
client.write_points(json_body)
molto affascinante ! 
mbmd run -a /dev/ttyUSB0 -d sdm:1,sdm:2 -r 5s
mbmd run -a /dev/ttyUSB0 -d sdm:1,sdm:2 -r 5s --influx-url http://localhost:8086 --influx-database test
Commenta