# -*- coding: utf-8 -*- import paho.mqtt.client as mqtt _host = "192.168.0.2" _qos = 0 topic = "mqtt/topic/test" def on_connect(client, userdata, flag, rc): client.subscribe(topic, qos = _qos) def on_message(client, userdata, message): print message.topic + " " + str(message.payload) def main(): mqtt_client = mqtt.Client(protocol = mqtt.MQTTv31) mqtt_client.on_connect = on_connect mqtt_client.on_m