From f68b890f9043ff6a92a16c63fceaeeb02a51ded4 Mon Sep 17 00:00:00 2001 From: dan Date: Sun, 5 Sep 2021 15:59:36 -0400 Subject: [PATCH] Initial Commit. Connects to MQTT and listens for assigned topics. --- main.py | 18 ++++++++++++++++++ requirements.txt | 1 + 2 files changed, 19 insertions(+) create mode 100644 main.py create mode 100644 requirements.txt diff --git a/main.py b/main.py new file mode 100644 index 0000000..445dc19 --- /dev/null +++ b/main.py @@ -0,0 +1,18 @@ +import paho.mqtt.client as mqtt + + +def on_message(client, userdata, message): + print(str(message.payload.decode("utf-8"))) + + +mqttBroker = 'icyn30.duckdns.org' +mqttPort = 1888 + +client = mqtt.Client("Notifer") + +client.connect(mqttBroker, mqttPort) + +client.subscribe("/Test/test") +client.on_message = on_message + +client.loop_forever() diff --git a/requirements.txt b/requirements.txt new file mode 100644 index 0000000..ebd4492 --- /dev/null +++ b/requirements.txt @@ -0,0 +1 @@ +paho-mqtt==1.5.1