From 1123b0db81b6057e113f16a1ddea15c36b7b3d79 Mon Sep 17 00:00:00 2001 From: pks Date: Sun, 27 Sep 2020 20:55:18 +0200 Subject: init --- mqtt-receiver.py | 27 +++++++++++++++++++++++++++ 1 file changed, 27 insertions(+) create mode 100644 mqtt-receiver.py (limited to 'mqtt-receiver.py') diff --git a/mqtt-receiver.py b/mqtt-receiver.py new file mode 100644 index 0000000..3d6cd8a --- /dev/null +++ b/mqtt-receiver.py @@ -0,0 +1,27 @@ +import json +import paho.mqtt.client as mqtt +import sys + + +def on_connect(client, userdata, flags, rc): + client.subscribe("#") # Subscribe to all topics + sys.stderr.write("Connected with result code {}\n".format(rc)) + sys.stderr.flush() + + +def on_message(client, userdata, msg): + msg_as_str = msg.payload.decode('utf-8') + try: + print("{}\t{}\t{}".format(msg.timestamp, msg.topic, json.loads(msg_as_str))) + sys.stdout.flush() + except Exception as e: + sys.stderr.write("Cannot parse message: '{}'\n".format(msg_as_str)) + sys.stderr.flush() + + +if __name__ == "__main__": + client = mqtt.Client() + client.on_connect = on_connect + client.on_message = on_message + client.connect("localhost", 1883, 60) + client.loop_forever() -- cgit v1.2.3