python如何订阅mqtt消息

在Python中，可以使用paho-mqtt库来订阅MQTT消息。下面是一个简单的例子：

1. 首先，需要安装paho-mqtt库。可以使用pip命令进行安装：

pip install paho-mqtt

2. 接下来，可以使用以下代码来订阅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))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

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

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

在这个例子中，我们定义了两个回调函数on_connect和on_message。在on_connect中，我们连接到MQTT服务器，并订阅了一个主题"test/topic"。在on_message中，我们打印出接收到的消息的主题和内容。最后，我们创建了一个mqtt.Client对象，并将回调函数绑定到该对象上，然后连接到MQTT服务器并开始循环监听消息。

当有消息发布到"test/topic"主题时，我们的程序就会接收到该消息，并执行on_message函数。