I got python to subscribe to an MQTT broker from a CentOS 6 box.<\/p>\n
First off you need to install the mqtt libraries for python. \u00a0In this example we use the paho-mqtt libraries.<\/p>\n
You don’t use YUM, you use easy_install. \u00a0Here is the command<\/p>\n
easy_install paho-mqtt<\/pre>\nAfter that you can connect via python whether this is a script or in the interpreter<\/p>\n
Here is the script scrubbed of usernames and passwords<\/p>\n
import paho.mqtt.client as mqtt\r\n\r\ndef on_connect(mqttc, userdata, rc):\r\n print('connected...rc=' + str(rc))\r\n mqttc.subscribe(topic='home\/message<\/strong>', qos=0)\r\n\r\ndef on_disconnect(mqttc, userdata, rc):\r\n print('disconnected...rc=' + str(rc))\r\n\r\ndef on_message(mqttc, userdata, msg):\r\n print('message received...')\r\n print('topic: ' + msg.topic + ', qos: ' + \r\n str(msg.qos) + ', message: ' + str(msg.payload))\r\n\r\ndef on_subscribe(mqttc, userdata, mid, granted_qos):\r\n print('subscribed (qos=' + str(granted_qos) + ')')\r\n\r\ndef on_unsubscribe(mqttc, userdata, mid, granted_qos):\r\n print('unsubscribed (qos=' + str(granted_qos) + ')')\r\n\r\nmqttc = mqtt.Client()\r\nmqttc.on_connect = on_connect\r\nmqttc.on_disconnect = on_disconnect\r\nmqttc.on_message = on_message\r\nmqttc.on_subscribe = on_subscribe\r\nmqttc.on_unsubscribe = on_unsubscribe\r\nmqttc.username_pw_set('usernamehere<\/strong>', 'passwordhere<\/strong>')\r\nmqttc.connect(host='mqttbroker.example.local<\/strong>', port=1883)\r\nmqttc.loop_forever()<\/pre>\nThis was pretty easy for subscribing.<\/p>\n
Here is the code that matters, just need to inject what the script will do.<\/p>\n
def on_message(mqttc, userdata, msg):\r\n print('message received...')\r\n print('topic: ' + msg.topic + ', qos: ' + \r\n str(msg.qos) + ', message: ' + str(msg.payload))<\/pre>\nWas pretty easy to get this subscribe working, not sure how the publish will work.<\/p>\n","protected":false},"excerpt":{"rendered":"
I got python to subscribe to an MQTT broker from a CentOS 6 box. First off you need to install the mqtt libraries for python. \u00a0In this example we use the paho-mqtt libraries. You don’t use YUM, you use easy_install. … Continue reading