Как подписаться и опубликовать sh параллельно в Paho-MQTT python? - PullRequest
Новая
       81

Как подписаться и опубликовать sh параллельно в Paho-MQTT python?

0 голосов
/ 17 марта 2020



Я работаю с клиентом paho-mqtt и спрашиваю, может ли кто-нибудь из вас помочь мне подписаться и публиковать сообщения параллельно.
Моя настройка: У меня есть пара датчиков, записывающих данные в InfluxDB. Используя подписки с некоторыми параметрами (время, начало записи), я могу впоследствии получить сенсорные данные из InfluxDB. Я написал скрипт, который подписывается на все сенсоры / # и передает мне список всех доступных сенсоров в моей системе, что приводит меня непосредственно к моему вопросу:

Мой Проблема: Теперь у меня есть список всех моих доступных датчиков: themes_list : 

 1. sensors/device1/temperature
 2. sensors/device2/gyroscope
 3. sensors/device1/gyroscope


также у меня есть список, содержащий правильные параметры для мой запрос InfluxDB: list_request 

 1. {"response":"sensors/device1/temperature","start":"2020-07T13:27:53Z","duration":"80s","interval":"1s"}
 2. {"response":"sensors/device2/gyroscope","start":"2020-07T13:27:53Z","duration":"80s","interval":"1s"}
 3. {"response":"sensors/device1/gyroscope","start":"2020-07T13:27:53Z","duration":"80s","interval":"1s"}


Теперь рабочий процесс, о котором я читал и использовал с тех пор, будет следующим: 

for i in topics_list: <br>
 1. connect client
 2. subscribe topic i
 3. publish message i


Мне интересно, кто-нибудь из вас сейчас, как инициализировать, подключать, публиковать sh и подписываться параллельно, и таким образом повысить производительность.

...