iootpro ======= ``IootproTask.cpp`` |image0| Мы изготавливаем собственные контроллеры которые отправляют данные по *MQTT* в формате [``val``,\ ``unixtime``]. .. raw:: html
Описание работы узла -------------------- Код инициализирует *MQTT клиент* с уникальным идентификатором, который генерируется случайным образом в диапазоне от 1 до 1000. |image1| Клиент подключается к MQTT брокеру, используя предоставленные: \* **URL хоста** - адрес вашего MQTT брокера, который вы собираетесь прослушивать. ``host`` \* **Порт** - порт, по которому ведется прослушка топика ``port`` \* **Пользователь** - ``user`` \* **Пароль** - ``password`` \* **Топик** - “Подобие группы или канала в мессенджерах, на который вы подписываетесь, чтобы получать новости” - вещает тестировщик. ``topic`` Для прослушивания всех субтопиков пишем в поле *Топик*: ``#`` - **Qos** - качество обслуживания. Протокол MQTT поддерживает 3 уровня QoS. ``qos`` Если подключение успешно, клиент подписывается на указанный топик с заданным уровнем QoS. Входные данные ~~~~~~~~~~~~~~ .. code:: json [10, 1726808489.3189328] Данные на выход ~~~~~~~~~~~~~~~ .. code:: json { "DATA":{ "connection_status":true, "values":[ {"property-name":"someTopicioot", "source":"someTopicioot", "time":1726808489.3189328, "value":10} ] } } Пример использования узла ------------------------- Для рассылки сообщений используется *python* код в ``/doc_md/codes/producer_iootpro.py``. Он отправляет сообщения с периодичностью в 1 секунду на сервер *MQTT*. Соберём цепочку: |image2| Настроим узел: |image3| После включения нашего скрипта мы будем получать наши сообщения в консоли браузера. |image4| .. |image0| image:: ../../_img/ioot_icon.png .. |image1| image:: ../../_img/ioot_settings.png .. |image2| image:: ../../_img/ioot_chain.png .. |image3| image:: ../../_img/ioot_settings_test.png .. |image4| image:: ../../_img/ioot_socket.png