Я пытаюсь создать программу на Python, которая получает и отправляет сообщения на мой сервер mqtt со многих устройств (шлюз).То, что я хотел бы сделать, это когда я получаю сообщение от устройства, убедитесь, что адрес этого устройства уже подписан, чтобы я мог получать внешнее сообщение на это устройство и направить его на это конкретное устройство.
Прямо сейчаскаждый раз, когда я получаю данные с устройства, я повторно подписываюсь на тему, не зная, подписано ли оно уже.
if (time.time() - last_sent_message) >= 0.25:
message = daemon.memcache_read()
if message:
daemon.serial_print(message)
#daemon.udp_send(message)
try:
mqttc.publish("to_" + message[8:17], message)
mqttc.subscribe("from_" + message[8:17], 0)
except:
pass
last_sent_message = time.time()