百度 IoTHub MQTT v3.1.1 开发

paho-mqtt 组件

$ pip3 install paho-mqtt

import paho.mqtt.client as mqtt

def cb_on_connect(client, userdata, flags, rc):
    if int(rc) == 4:
        print('ERROR: invalid username or password')

def cb_on_message(client, userdata, msg):
    print('Message:', str(msg.topic), str(msg.payload))

def cb_on_disconnect(client, client, userdata, rc):
    if int(rc) == 1:
        print('ERROR: not unique client id')

# triggered by callbacks
client = mqtt.Client(client_id, clean_session=True, transport='tcp')
client.on_connect = cb_on_connect
client.on_message = cb_on_message
client.on_disconnect = cb_on_disconnect

client.username_pw_set(username, password)
client.connect(iothub = 'bmqtt.mqtt.iot.bj.baidubce.com', port = 1883, keepalive = 60)

client.loop_forever()