Используя Python Paho-MQTT, я пытаюсь получить ровно 1 сообщение от темы, а затем выйти. Если сообщения не получены через 5 секунд, то я хочу сделать тайм -аут и выйти. Проблема, которую у меня есть, заключается в том, что этот код всегда ждет 5 секунд, даже если сообщение было получено раньше. Если я удалю линию Sleep () , то она вообще не получает никаких сообщений.import paho.mqtt.client as mqtt
import logging
import time
def on_message(client, userdata, message):
logging.info(f"Received message: {message.payload}")
client.loop_stop()
logging.basicConfig(level=logging.DEBUG, format="%(asctime)s [%(levelname)s] %(message)s")
mqttc = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
mqttc.enable_logger()
mqttc.on_message = on_message
mqttc.connect("mqtt.eclipseprojects.io")
mqttc.subscribe("#")
mqttc.loop_start()
time.sleep(5)
logging.info('Complete!')
< /code>
output: < /p>
2025-01-28 01:39:33,511 [DEBUG] Sending CONNECT (u0, p0, wr0, wq0, wf0, c1, k60) client_id=b''
2025-01-28 01:39:33,511 [DEBUG] Sending SUBSCRIBE (d0, m1) [(b'#', 0)]
2025-01-28 01:39:33,632 [DEBUG] Received CONNACK (0, 0)
2025-01-28 01:39:33,634 [DEBUG] Received SUBACK
2025-01-28 01:39:33,634 [DEBUG] Received PUBLISH (d0, q0, r1, m0), 'AhoyDTU0600-Streusser/version', ... (6 bytes)
2025-01-28 01:39:33,634 [INFO] Received message: b'0.8.83'
2025-01-28 01:39:38,517 [INFO] Complete!
Подробнее здесь: https://stackoverflow.com/questions/793 ... op-timeout
