Initial Commit. Connects to MQTT and listens for assigned topics.

This commit is contained in:
dan
2021-09-05 15:59:36 -04:00
commit f68b890f90
2 changed files with 19 additions and 0 deletions

18
main.py Normal file
View File

@@ -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()