ListenUDP
Описание
Прослушивает дейтаграммы на указанном порту. По умолчанию для каждой дейтаграммы создается FlowFile, однако для большей пропускной способности можно увеличить свойство Max Batch Size для указания числа дейтаграмм, объединяемых в один FlowFile. Этот процессор можно ограничить прослушиванием дейтаграмм от определенного удаленного хоста и порта, указав соответствующие свойства.
Теги
ingest, udp, listen, source
Свойства
| Название | Описание |
|---|---|
| Local Network Interface | Имя локального сетевого интерфейса, используемого для огр аничения прослушивания конкретной локальной сети. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Port | The port to listen on for communication. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Receive Buffer Size | Размер каждого буфера, используемого для получения сообщений. Отрегулируйте это значение в соответствии с ожидаемым размером входящих сообщений. |
| Max Size of Message Queue | Максимальный размер внутренней очереди, используемой для буферизации сообщений, передаваемых из базового канала в процессор. Если установить это значение выше, в памяти будет буферизироваться больше сообщений во время всплесков входящих сообщений, но увеличится общий объём памяти, используемой процессором. |
| Max Size of Socket Buffer | Максимальный размер буфера сокета, который следует использовать. Это рекомендация для операционной системы, указывающая, каким должен быть размер буфера сокета. Если это значение установлено слишком низким, буфер может заполниться до того, как данные будут считаны, и входящие данные будут отброшены. |
| Character Set | Указывает набор символов для получаемых данных. |
| Max Batch Size | The maximum number of messages to add to a single FlowFile. If multiple messages are available, they will be concatenated along with the <Message Delimiter> up to this configured maximum number of messages |
| Batching Message Delimiter | Указывает разделитель, который следует устанавливать между сообщениями при объединении нескольких сообщений (см. свойство <Максимальный размер пакета>). |
| Sending Host | IP-адрес или имя удаленного хоста. Будут приниматься только дейтаграммы с указанного порта хоста-отправителя и этого хоста. Повышает производительность. Может быть системным свойством или переменной среды. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Sending Host Port | Порт, используемый удалённым хостом для отправки дейтаграмм. Будут приниматься только дейтаграммы с указанного удалённого хоста и этого порта. Повышает производительность. Может быть системным свойством или переменной среды. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
Взаимосвязи
- success: Сообщения, успешно полученные, будут отправлены по этому каналу.