Skip to content

Instantly share code, notes, and snippets.

@marcozecchini
Created March 30, 2020 22:41
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save marcozecchini/7194e2ad2a95b309bd9a0b6359c65ce9 to your computer and use it in GitHub Desktop.
Save marcozecchini/7194e2ad2a95b309bd9a0b6359c65ce9 to your computer and use it in GitHub Desktop.
import paho.mqtt.client as mqtt
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
# Subscribing in on_connect() means that if we lose the connection and
# reconnect then subscriptions will be renewed.
client.subscribe("+/devices/+/up")
# The callback for when a PUBLISH message is received from the server.
def on_message(client, userdata, msg):
print(msg.topic+" "+str(msg.payload))
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.username_pw_set("TTN_APP_ID", "ttn-account-v2.ACCESS_KEY" )
client.connect("eu.thethings.network", 1883, 60)
# Blocking call that processes network traffic, dispatches callbacks and
# handles reconnecting.
# Other loop*() functions are available that give a threaded interface and a
# manual interface.
client.loop_forever()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment