iootpro

IootproTask.cpp

image0

Мы изготавливаем собственные контроллеры которые отправляют данные по MQTT в формате [val,unixtime].

Описание работы узла

Код инициализирует MQTT клиент с уникальным идентификатором, который генерируется случайным образом в диапазоне от 1 до 1000.

image1

Клиент подключается к MQTT брокеру, используя предоставленные: * URL хоста - адрес вашего MQTT брокера, который вы собираетесь прослушивать. host * Порт - порт, по которому ведется прослушка топика port * Пользователь - user * Пароль - password * Топик - “Подобие группы или канала в мессенджерах, на который вы подписываетесь, чтобы получать новости” - вещает тестировщик. topic

Для прослушивания всех субтопиков пишем в поле Топик: #

  • Qos - качество обслуживания. Протокол MQTT поддерживает 3 уровня QoS. qos

Если подключение успешно, клиент подписывается на указанный топик с заданным уровнем QoS.

Входные данные

[10, 1726808489.3189328]

Данные на выход

{
    "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