ConsumeMQTT
Описание
Подписывается на тему и получает сообщения от брокера MQTT.
Теги
subscribe, MQTT, IOT, consume, listen
Свойства
| Название | Описание |
|---|---|
| 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 (будет оцениваться только с использованием переменных среды) |
| Group ID | Идентификатор группы потребителей MQTT для использования. Если идентификатор группы не задан, клиент будет подключаться как отдельный потребитель. |
| Topic Filter | Фильтр тем MQTT для обозначения тем, на которые следует подписаться. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Quality of Service (QoS) | Качество обслуживания (QoS) для получения сообщения. Принимает значения '0', '1' или '2'; '0' для 'не более одного раза', '1' для 'не менее одного раза', '2' для 'ровно один раз'. |
| Record Reader | Средство чтения записей для разбора полученных сообщений MQTT на записи. |
| Record Writer | Средство записи записей для сериализации записей перед их записью в файл Flow. |
| Add attributes as fields | Если для этого свойства установлено значение true, в каждую запись будут добавлены поля по умолчанию: _topic, _qos, _isDuplicate, _isRetained.This Property is only considered if the [Record Reader] Property has a value specified. |
| Message Demarcator | С помощью этого свойства вы можете выводить файлы Flow, содержащие несколько сообщений. Это свойство позволяет указать строку (интерпретируемую как UTF-8) для разделения нескольких сообщений. Это необязательное свойство; если оно не указано и если не определено считывающее/записывающее устройство, каждое полученное сообщение будет выводиться в виде одного файла Flow. Чтобы ввести специальный символ, например «новую строку», используйте 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. |
| Max Queue Size | Сообщения MQTT всегда отправляются подписчикам по определенной теме, независимо от того, как часто планируется запуск процессора. Если "Расписание выполнения" значительно отстает от скорости, с которой сообщения поступают на этот процессор, то во внутренней очереди этого процессора может произойти резервное копирование. Это свойств о определяет максимальное количество сообщений, которые этот процессор будет хранить в памяти одновременно во внутренней очереди. Эти данные были бы потеряны в случае перезапуска NiFi. |
Взаимосвязи
- parse.failure: Если сообщение не может быть проанализировано с помощью настроенного считывателя записей, содержимое сообщения будет направлено в это отношение в виде отдельного файла Flow.
- Message: Вывод сообщения MQTT