daemon e influxdb

This commit is contained in:
Sergio Álvarez 2016-02-14 20:58:41 +01:00
parent fe035a4732
commit 1e0dc6dd59
1 changed files with 39 additions and 2 deletions

View File

@ -4,6 +4,43 @@
# aquí iré metiendo la lectura de datos y guardado en algún sitio # aquí iré metiendo la lectura de datos y guardado en algún sitio
import serial import serial
import influxdb
import time
while True:
try:
influx = influxdb.InfluxDBClient("localhost", 8086, "root", "root", "hometv")
ser = serial.Serial("/dev/ttyACM0", 9600) # 9600 bauds ser = serial.Serial("/dev/ttyACM0", 9600) # 9600 bauds
while True: while True:
print(ser.readline()) line = ser.readline()
parts = line.decode('ascii').strip().split(" ")
if parts[0] != "D":
continue
influx.write_points([
{
"measurement": "humedad",
"tags": {
"location": "home"
},
"fields": {
"v": float(parts[1][2:])
}
},
{
"measurement": "temperatura",
"tags": {
"location": "home"
},
"fields": {
"real": float(parts[2][2:]),
"sensacion": float(parts[3][2:])
}
}
])
except Exception as e:
print(e)
time.sleep(60)