mqtt subscribe 获取

以下是Python中使用paho-mqtt库进行MQTT订阅的示例代码：

import paho.mqtt.client as mqtt

# 连接成功回调函数
def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    # 订阅主题
    client.subscribe("test/topic")

# 消息推送回调函数
def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))

# 创建MQTT客户端
client = mqtt.Client()

# 设置连接成功和消息推送回调函数
client.on_connect = on_connect
client.on_message = on_message

# 连接MQTT代理服务器
client.connect("broker.hivemq.com", 1883, 60)

# 循环监听MQTT消息
client.loop_forever()

在上面的代码中，我们使用paho-mqtt库创建了一个MQTT客户端，并设置了连接成功和消息推送的回调函数。在连接成功回调函数中，我们订阅了一个名为“test/topic”的主题。在消息推送回调函数中，我们打印出了接收到的消息的主题和内容。最后，我们使用`loop_forever()`函数循环监听MQTT消息。