tobru
/
pylokid
1
0
Fork 0
Code Pull Requests Releases Activity

publish data as JSON over MQTT

This commit is contained in:
Tobias Brunner 2018-01-04 21:29:03 +01:00
parent 152aa3d4b6
commit d3ca3fe1d0
1 changed files with 5 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
library/mqtt.py
View File

@ -3,6 +3,7 @@
""" MQTT Functions """
import logging
import json
import paho.mqtt.client as mqtt
class MQTTClient:
@ -34,23 +35,12 @@ class MQTTClient:
if f_type == 'Einsatzausdruck_FW':
try:
self.mqtt_client.publish(topic + 'typ', 'Einsatzauftrag')
#self.mqtt_client.publish(topic + 'einsatz', pdf_data['einsatz'])
#self.mqtt_client.publish(
# topic + 'datumzeit',
# pdf_data['datum'] + ' - ' + pdf_data['zeit']
#)
#self.mqtt_client.publish(topic + 'sondersignal', pdf_data['sondersignal'])
#self.mqtt_client.publish(
# topic + 'adresse',
# pdf_data['strasse'] + ', ' + pdf_data['ort']
#)
#self.mqtt_client.publish(topic + 'hinweis', pdf_data['hinweis'])
#self.mqtt_client.publish(topic + 'bemerkungen', pdf_data['bemerkungen'])
self.mqtt_client.publish(topic + 'json', json.dumps(pdf_data))
## Publish the PDF blob
#pdf_fh = open(pdf_file, 'rb')
#pdf_binary = pdf_fh.read()
#self.mqtt_client.publish(topic + 'pdf', bytes(pdf_binary))
pdf_fh = open(pdf_file, 'rb')
pdf_binary = pdf_fh.read()
self.mqtt_client.publish(topic + 'pdf', bytes(pdf_binary))
except IndexError as err:
self.logger.info('[%s] Cannot publish information: %s', f_id, err)
elif f_type == 'Einsatzprotokoll':