Как запустить MQTT-клиент в фоновом режиме в Python?

Question

Я пытаюсь подключиться к DroneKit-SITL и поддерживаю работу MQTT-Broker с loop_forever ().Всякий раз, когда я получаю сообщение через MQTT, я хочу отправлять команды дрону через API python dronekit.В то же время я хочу отправлять данные дронов другим клиентам через MQTT каждые 5 секунд.

Как я могу позволить моему dronekit-sitl-class и mqtt-broker-class взаимодействовать друг с другом?Должен ли каждый из них выполняться в потоке или процессе?

Answer 1

Я исправил проблему, запустив цикл в отдельном потоке следующим образом:

clientloop_thread = Thread(target=self.connect)
clientloop_thread.start()

def connect(self):
    self._client.loop_forever()