MQTT

Публикует полезную нагрузку входящего сообщения (DATA) в топик настроенного MQTT брокера.

Конфигурация узла:

• URL хоста - хоcт MQTT брокера

• Порт - порт MQTT брокера (по умолчанию используется порт контейнера докер 1883 или 9001)

• Пользователь - Логин пользователя

• Пароль - Пароль пользователя

• Топик - Имя топика, куда будут отправленны данные

• Qos - уровень качества обслуживания

• Retain - накопление сообщений

  Специальный флаг RETAIN. Данный флаг служит для индикации сохранения последнего принятого брокером сообщения. То есть флаг RETAIN=1 в сообщении PUBLISH от издателя сообщает брокеру о том, что сообщение по этой теме нужно сохранить и, когда новый подписчик присоединится к теме, отправить ему это сообщение.

Данные на вход узла

Подаются данные в формате json.

Вывод узла

Возвращает поступивший на вход узла json объект.

При каждой отправке сообщения брокеру в сокет выводится подобная информация:

{"id":1,"msg":{"status":true},"name":"test_mqtt_out","type":"status"}

Пример использования

1. Соберём цепочку или загрузим готовую test_mqtt_out.yaml.

2. Настроим конфигурацию узла, как показано на картинке:

Отправляем данные по адресу моста bridge в докере.

3. Добавим какой-нибудь файл с json данными в наш узел генератора. В схеме используется следующий файл: json     {"connection_status_msg":"Ok"}

4. Чтобы проверить правильность работы нашего узла, следует создать другую цепочку, которая будет считывать информацию с топика. Описание настройки можете прочитать их здесь.

5. Сохраняем нашу цепочку-приёмник и в сокете можем наблюдать следующее: