Параллельная обработка сообщений MQTT с использованием Python ⇐ Python

[Anonymous]

У меня есть скрипт Python (paho-mqtt), который подписывается на тему у брокера MQTT и получает данные датчиков (около 600 сообщений в секунду). Размер полезных данных составляет примерно 60-70 КБ, и они отправляются в сокет, устанавливая соединение TCP/IP.
Ранее я использовал качество обслуживания-0 в своем скрипте и из-за этого некоторые сообщения отбрасывались.
Теперь я обновил службу до Python-3 и использовал многопоточность для более быстрой обработки сообщений. Кроме того, я использую в сценарии качество обслуживания-1. Это решило мою проблему с отбрасыванием сообщений, но скрипту требуется много времени для обработки сообщений, что вызывает беспокойство.
Как лучше всего решить эту проблему и какие-либо предложения по этому поводу с этим можно справиться, это будет оценено по достоинству. Буду рад узнать новое. Возможные обходные пути, о которых я думаю:

• Я попробовал использовать библиотеку asynio (столкнулся с проблемами конкуренции, поскольку создал только одно сокетное соединение)
• публикация этих сообщений в очереди (RMQ) вместо отправки их в сокет.

Подробнее здесь: https://stackoverflow.com/questions/793 ... ing-python