ListenUDPRecord
Описание
Прослушивает дейтаграммы на указанном порту и считывает сод ержимое каждой дейтаграммы с использованием настроенного считывателя записей. Каждая запись затем записывается в FlowFile с использованием настроенного записывающего устройства. Этот процессор можно ограничить прослушиванием дейтаграмм от определенного удаленного хоста и порта, указав соответствующие свойства.
Теги
ingest, udp, listen, source, record
Свойства
| Название | Описание |
|---|---|
| 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 | Указывает набор символов для получаемых данных. |
| Poll Timeout | Время ожидания при опросе внутренней очереди на наличие дополнительных дейтаграмм. Если после ожидания в течение настроенного времени ожидания дейтаграммы не будут найдены, процессор выдаст все полученные до этого момента записи. |
| Batch Size | Максимальное количество дейтаграмм, которые можно записать в виде записей в один файл FlowFile. Размер пакета будет достигнут только в том случае, если данные поступают чаще, чем через тайм-аут опроса. |
| Record Reader | Устройство чтения записей, используемое для чтения содержимого входящих дейтаграмм. |
| Record Writer | Записывающее устройство Record, используемое для сериализации данных перед записью в файл потока. |
| Sending Host | IP-адрес или имя удалённого хоста. Будут приниматься только дейтаграммы с указанного удалённого хоста и этого порта. Повышает производительность. Может быть системным свойством или переменной среды. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Sending Host Port | Порт, используемый удалённым хостом для отправки дейтаграмм. Будут приниматься только дейтаграммы с указанного удалённого хоста и с этого порта. Повышает производительность. Может быть системным свойством или переменной среды. Поддерживает язык выражений: true (будет оцениваться тольк о с использованием переменных среды) |
Взаимосвязи
- success: Сообщения, успешно полученные, будут отправлены по этому каналу.
- parse.failure: Если датаграмма не может быть проанализирована с помощью настроенного считывателя записей, содержимое сообщения будет направлено в это отношение в виде отдельного файла потока.