小编Abh*_*ngh的帖子

如何在python上使用PAHO-MQTT订阅多个主题

我正在尝试使用单个订户客户端订阅三个不同的主题。但是使用下面提到的代码,我只能从一台服务器获取数据。请在我的代码中建议蚂蚁修改,可以实施该修改以从不同的发布者客户端获取所需的数据。

# Define Variables
MQTT_BROKER = "10.97.143.44"
MQTT_PORT = 11883
MQTT_TOPIC = [("Server1/kpi1"),("Server2/kpi2"),("Server3/kpi3")


def on_connect(client, userdata, flags, rc):
    if rc == 0:
        print("Connected to broker")
        global Connected                #Use global variable
        Connected = True                #Signal connection
    else:
        print("Connection failed")

def on_message(client, userdata, message):
    data = message.payload
    receive=data.decode("utf-8")
    m_decode = json.loads(receive)
    #print(m_decode)
    #print (m_decode['Server_name'])
    print ("Message received: "  + str(m_decode))


Connected = False   #global variable for the state of the connection

client = mqttClient.Client("Python")               #create new instance
client.on_connect= on_connect                      #attach function to …
Run Code Online (Sandbox Code Playgroud)

publish-subscribe python-3.x mqtt

5
推荐指数
1
解决办法
3681
查看次数

标签 统计

mqtt ×1

publish-subscribe ×1

python-3.x ×1