Python paho-mqtt Подключение к брокеру MQTT - PullRequest
Новая
       74

Python paho-mqtt Подключение к брокеру MQTT

0 голосов
/ 11 сентября 2018

Я использую этот скрипт на Python для реализации подписчика Paho (MQTT), но я не могу получать ответные сообщения. Я могу подписаться на командную строку mqtt brokerin с помощью mosquitto_sub -t "" -d -h -p 8883 --psk foo --psk-identity bar --insecure --tls-version tlsv1

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))

    # Subscribing in on_connect() means that if we lose the connection and
    # reconnect then subscriptions will be renewed.
    client.subscribe("*********")

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

client.connect("*********", 8883, 60)

client.loop_forever()

Когда я запускаю выше сценария python, он не отвечает ни на какую ошибку или сообщение, а продолжает цикл, я также запускаю его построчно, а когда я запускаю client.connect("*********", 8883, 60), тогда он показывает только 0 . обратите внимание, что здесь без psk и psk-identity мы не можем подключиться к брокеру.

Спасибо

...