python调取mqtt

你可以使用Paho MQTT库来调用MQTT协议。首先，确保你已经安装了Paho MQTT库，可以使用以下命令安装：

pip install 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("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("mqtt.eclipse.org", 1883, 60)

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

在上面的示例中，我们首先创建了一个MQTT客户端对象。然后，设置了连接成功和接收消息的回调函数。接下来，我们连接到MQTT代理服务器，并通过循环不断监听消息。

当连接成功后，on_connect回调函数会被调用，并打印连接结果。当接收到消息时，on_message回调函数会被调用，并打印主题和消息内容。

你需要根据你所使用的MQTT代理服务器的地址和端口进行相应的修改。另外，你还可以根据需要添加发布消息的功能，使用`client.publish()`方法即可。