Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- @mqtt.on_connect()
- def handle_connect(client, userdata, flags, rc):
- mqtt.subscribe(data['mqtt_topic'])
- @mqtt.on_message()
- def handle_mqtt_message(client, userdata, message):
- data = dict(
- topic=message.topic,
- payload=message.payload.decode()
- )
- print(data)
- socketio.emit('mqtt_message', data=data)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement