MQTT async worker в Django
В моем Django-приложении мне нужно подключиться к MQTT-брокеру из нескольких мест.
Было бы здорово, если бы я мог создать своего рода MQTT рабочий, который будет работать в фоновом режиме/отдельном потоке, и я смогу использовать этот рабочий для публикации/подписки на сообщения, и мне не придется создавать отдельное MQTT соединение для каждой функции.
Пример:
- Создайте MQTT worker с деталями соединения. При запуске, это соединение запускается и обрабатывается, перезапускается, если соединение потеряно, и т.д... (возможно, использовать Celery для этого?) .
- Создать функции, которые доступны внутри моих Django проектов для публикации и подписки. Публикация кажется более простой, но я не уверен насчет подписки.
Я нашел mqttasgi, но не знаю, подойдет ли он для моих нужд.