Paho Python Mqtt on_message не вызывается - PullRequest
0 голосов
/ 15 июня 2019

Привет! Я использую Python Mqtt-Client Python для получения значения IR-Senor, публикуемого с платы IoT (NodeMCU).Это мой код

# Defining logging call-back for debugging.
def on_log(client,userdata,level,buf):
    print(str(level)+" "+str(buf))

# Defining call-back to be called upon connection of client with broker.
def on_connect(client,userdata,flags,rc):
    print("Connected to broker with result code "+str(rc));
    # Subscribing to required topic.
    client.subscribe(MQTT_CONST['bell_topic'])

# Defining call-back for when message is published to a subscribed topic.
def on_message(client,userdata,msg):
    print(str(msg.payload))

# Attaching callbacks to Client.
client = mqtt.Client(client_id='Python_Client')
client.on_log = on_log
client.on_connect = on_connect
client.on_message = on_message
client.username_pw_set(MQTT_CONST['mqtt_user_name'],MQTT_CONST['mqtt_password'])

# Connecting to Broker.
client.connect(MQTT_CONST['mqtt_broker_address'],MQTT_CONST['mqtt_port'],60)
client.loop_forever()

Я уверен, что MQTT-клиент Arduino на микроконтроллере работает нормально, поскольку я использовал другое приложение, которое подписалось на тему датчика и получало полезную нагрузку, отправленную с микроконтроллера, совершенно нормально.

По какой-то причине я не могу сделать это на моей Linux-машине, используя python.Что я делаю неправильно?Я использую mqtt.beebotte.com:1883, если это имеет какое-либо значение.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...