thesis_project/ inenvmon_server
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

reflect changes in message payload format

This commit is contained in:
2EEEB 2020-04-10 19:38:23 +02:00
parent 0fd0b012a5
commit 743aa2b383
Signed by: 2EEEB
GPG Key ID: 8F12BD6D9D435DB2
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
scripts/inenvmon_collector.py
View File

@ -5,6 +5,7 @@ import paho.mqtt.client as mqtt
import time
import datetime
import requests
#import ssl
MQTT_Broker = "127.0.0.1"
MQTT_Port =
@ -42,14 +43,14 @@ def on_connect(client, userdata, flags, rc):
def on_message(mosq, obj, msg):
try:
procdm = msg.payload.decode("unicode_escape").split(",")
if procdm[4] == -1:
procdm[4] = None;
if procdm[3] == -1:
procdm[3] = None;
except Exception as ex:
print("Fug: %s" % ex)
f = '%Y-%m-%d %H:%M:%S'
sql = "INSERT INTO envdata (timestamp, temp, hum, pres, co2) VALUES (%s, %s, %s, %s, %s)" % (str("\"%s\"") % datetime.datetime.now().strftime(f), str("\"%s\"") % procdm[1], str("\"%s\"") % procdm[2], str("\"%s\"") % procdm[3], str("\"%s\"") % procdm[4])
sql = "INSERT INTO envdata (timestamp, temp, hum, pres, co2) VALUES (%s, %s, %s, %s, %s)" % (str("\"%s\"") % datetime.datetime.now().strftime(f), str("\"%s\"") % procdm[0], str("\"%s\"") % procdm[1], str("\"%s\"") % procdm[2], str("\"%s\"") % procdm[3])
write_db(sql)
send_heartbeat()
@ -62,8 +63,8 @@ mqttc.on_message = on_message
mqttc.on_connect = on_connect
mqttc.on_subscribed = on_subscribed
mqttc.username_pw_set(MQTT_Auth['username'], MQTT_Auth['password])
#mqttc.tls_set(ca_certs="/etc/ssl/cert.pem", tls_version=ssl.PROTOCOL_TLSv1_2)
mqttc.username_pw_set(MQTT_Auth['username'], MQTT_Auth['password'])
mqttc.connect(MQTT_Broker, int(MQTT_Port), int(Keep_Alive_Interval))
mqttc.loop_forever()