MQTT client

Description

For Python, we use the client library paho-mqtt. It is pretty easy to use and provides several examples to start with on their github repo.

A basic example that subscribes to /in and publishes to /out:

import paho.mqtt.client as mqtt

# connection callback
def on_connect(client, userdata, flags, rc):
   print("Connected with result code " + str(rc))

# message received callback
def on_message(client, userdata, msg):
   print(msg.topic + " " + str(msg.payload))
   client.publish("/out", "received an input...")

# set up the client
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect("mqtt.eclipse.org", 1883, 60) # address ip, port number, keep alive

# subscribe
client.subscribe("/in")

# process the MQTT business
client.loop_forever()

Ressources

The documentation of the paho-mqtt library can be found here.

The repo with our own clients can be used as a base to start.