#!/usr/bin/env python import paho.mqtt.client as paho # pip install paho-mqtt def on_message(mosq, userdata, msg): print "%s (qos=%s, r=%s) %s" % (msg.topic, str(msg.qos), msg.retain, str(msg.payload)) mqtt = paho.Client() mqtt.on_message = on_message mqtt.connect("localhost", 1883, 60) mqtt.subscribe("linux/+", 0) mqtt.loop_forever()