首页 > 解决方案 > Paho MQTT 客户端导入?

问题描述

我不希望每次导入 MQTT 客户端对象时,它都会创建一个新实例。我不太了解 Paho MQTT 库,但是我希望通过单个 MQTT 客户端对象执行我的所有任务。

#mqtt.py
import paho.mqtt.client as mqtt

#The callback for connecting to CloudMQTT broker
def on_connect(client, userdata, flags, rc):
    print("Connecting to CloudMQTT broker: "+ mqtt.connack_string(rc))

# The callback for when a PUBLISH message is received from the server.
def on_message(client, userdata, message):
    print("Received message '" + str(message.payload) + "' on topic '"
        + message.topic  + "' with QoS " + str(message.qos))


client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.username_pw_set('****', '****')
client.connect('****', ****),

我的第一个终端控制台:

>>> from mqtt import client
>>> client
<paho.mqtt.client.Client object at 0x7fc7c4e3ce48>

我的第二个终端控制台:

>>> from mqtt import client
>>> client
<paho.mqtt.client.Client object at 0x7f437ea56e48>

标签: pythonpaho

解决方案


推荐阅读