Реагирования в MQTT с Python

Question

Я, имеющим немного задержки-вопрос в моем MQTT Python (v2.7) скрипте, который мне интересно ...

Поэтому у меня есть один запрос устройства функции для другое устройство. Назовем их A и B.

Итак, A отправляет сообщение MQTT, чтобы что-то сделать, а B выполняет эту функцию. У меня есть Отправить его обычным способом публикации. Здесь нет проблем.

B получает изданное сообщение с частью:

def on_message(client, userdata, msg): 
    if msg.topic == "action": 
      >> then do something here << 

Также кажется, нет никаких проблем здесь. Он получает сообщение, и он выполняет действие.

Проблема получает здесь, когда я пытаюсь сообщить, что он собирается, который выглядит следующим образом:

def on_message(client, userdata, msg): 
    if msg.topic == "action": 
      >> then do something here << 
      client.publish("report", payload=message1, qos=2, retain=False) 
      >> then do some more action here << 
      client.publish("report", payload=message2, qos=2, retain=False) 

Проблема заключается не в том, что он не делает действия или что он не делает действие, но, похоже, он будет делать то и другое, а скорее в очень странном порядке, например:

action 
action 
(several seconds wait) 
message1 
message2 

Это не похоже на правду? Как я могу заставить сценарий отправить сообщение до того, как он выполнит вторую часть?

Answer 1

Работает должным образом.

Сетевой цикл представляет собой единственный поток, который уже обрабатывает входящее сообщение. Публикации помещаются в очередь до тех пор, пока функция on_message не завершится, а затем сетевой цикл будет обрабатывать эти поставленные в очередь.

Answer 2

Стек TCP асинхронен. Когда вы вызываете для отправки данных, это не означает, что он немедленно отключается. За вашим кодом работает цикл событий. Если вы хотите что-то сделать последовательно, вы должны разбить свои последовательные задачи на отдельные функции и называть их следующим on_publish(), когда сообщение действительно отправлено.

Answer 3

Я был в состоянии отправлять сообщения, используя библиотеку:

import paho.mqtt.publish as mqttc 

и с использованием:

mqttc.single("report", payload=message1, qos=2, hostname=XXXX, port=XXXX) 

, который будет следовать естественному течению сценария и до сих пор посылают сообщение.