PublishMQTT
Описание
Публикует сообщение в тему MQTT.
Теги
publish, MQTT, IOT
Свойства
| Название | Описание |
|---|---|
| Broker URI | URI (ы), которые используются для подключения к брокеру MQTT (например, tcp://localhost:1883). Поддерживаются схемы 'tcp', 'ssl', 'ws' и 'wss'. Для использования 'ssl' необходимо задать свойство SSL Context Service. Если задан список URI, разделённых запятыми (например, tcp://localhost:1883,tcp://localhost:1884), процессор будет использовать алгоритм циклического перебора для подключения к брокерам в случае сбоя подключения. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| MQTT Specification Version | Версия спецификации MQTT при подключении к брокеру. Подробнее см. в описании допустимых значений. |
| Username | Имя пользователя, используемое при подключении к брокеру Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Password | Пароль, используемый при подключении к брокеру Чувствительный параметр: true |
| SSL Context Service | Служба SSL-контекста, используемая для предоставления информации о сертификате клиента для TLS/SSL-соединений. |
| Session state | Начать ли новый сеанс или возобновить предыдущий. Подробнее см. в описании допустимых значений. |
| Session Expiry Interval | По истечении этого интервала брокер закроет сеанс клиента и очистит состояние сеанса.This Property is only considered if all of the following conditions are met:The [Session state] Property has a value of "Resume Session".The [MQTT Specification Version] Property has a value of "v5.0". |
| Client ID | идентификатор клиента MQTT для использования. Если значение не задано, будет сгенерирован UUID. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Topic | Тема для публикации сообщения. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Retain Message | Следует ли устанавливать флаг сохранения в сообщении MQTT. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Quality of Service (QoS) | Качество обслуживания (QoS) для отправки сообщения. Принимает три значения: «0», «1» и «2»; «0» означает «не более одного раза», «1» означает «не менее одного раза», «2» означает «ровно один раз». Язык выражений разрешен для поддержки публикации сообщений с разным качеством обслуживания, но конечное значение свойства должно быть равно «0», «1» или «2». Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Record Reader | Средство чтения записей для разбора входящего файла Flow на записи. |
| Record Writer | Средст во записи записей для сериализации записей перед их публикацией в виде сообщения MQTT. |
| Message Demarcator | С помощью этого свойства можно публиковать несколько сообщений из одного FlowFile. Это свойство позволяет вам указать строку (интерпретируемую как UTF-8), которая будет использоваться для разделения содержимого потокового файла. Это необязательное свойство; если оно не указано и если не определено средство чтения/записи записей, каждый потоковый файл будет опубликован в виде отдельного сообщения. Чтобы ввести специальный символ, такой как "новая строка", используйте CTRL+Enter или Shift+Enter в зависимости от операционной системы. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Connection Timeout (seconds) | Максимальный интервал времени, в течение которого клиент будет ожидать установления сетевого соединения с сервером MQTT. Значение по умолчанию — 30 секунд. Значение 0 отключает обработку тайм-аута, то есть клиент будет ждать, пока сетевое соединение не будет установлено успешно или не будет установлено. |
| Keep Alive Interval (seconds) | Defines the maximum time interval between messages sent or received. It enables the client to detect if the server is no longer available, without having to wait for the TCP/IP timeout. The client will ensure that at least one message travels across the network within each keep alive period. In the absence of a data-related message during the time period, the client sends a very small "ping" message, which the server will acknowledge. A value of 0 disables keepalive processing in the client. |
| Last Will Message | Сообщение, отправляемое в качестве последней воли клиента. |
| Last Will Topic | Тема, в которую отправляется последняя воля клиента.This Property is only considered if the [Last Will Message] Property has a value specified. |
| Last Will Retain | Сохранять ли последнюю волю клиента.This Property is only considered if the [Last Will Message] Property has a value specified. |
| Last Will QoS Level | Уровень качества обслуживания, используемый при публикации сообщения «Последняя воля».This Property is only considered if the [Last Will Message] Property has a value specified. |
Взаимосвязи
- success: Файлы потоков, которые успешно отправлены по назначению, передаются в эту связь.
- failure: Файлы потока, которые не удалось отправить в пункт назначения, передаются в эту связь.