ListenTCPRecord
Описание
Прослушивает входящие TCP-подключения и считывает данные с каждого подключения, используя настроенный считыватель записей, и записывает записи в FlowFile с использованием настроенного записывающего устройства. Выбор типа считывателя записей определяет, как клиенты должны отправлять данные. Например, при использовании считывателя Grok для чтения логов клиент может поддерживать открытое подключение и непрерывно передавать данные, но при использовании считывателя JSON клиент не может отправлять массивы JSON-документов и затем повторно отправлять другой массив по тому же подключению. Записи будут считываться с соединения в блокирующем режиме, и тайм-аут будет настроен в соответствии с указанным временем ожидания. Если истечет время ожидания чтения или возникнет другая ошибка, соединение будет закрыто, и любые считанные записи будут обработаны в соответствии с настроенной стратегией ошибок чтения (отброс или передача).
Теги
listen, tcp, record, tls, ssl
Свойства
| Название | Описание |
|---|---|
| Local Network Interface | Имя локального сетевого интерфейса, используемого для ограничения прослушивания конкретной локальной сети. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Port | Порт для прослушивания связи. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
| Max Size of Socket Buffer | Максимальный размер буфера сокета, который следует использовать. Это рекомендация для операционной системы, указывающая, каким должен быть размер буфера сокета. Если это значение установлено слишком низким, буфер может заполниться до того, как данные будут считаны, и входящие данные будут отброшены. |
| Max Number of TCP Connections | Максимальное количе ство одновременных TCP-подключений, которые можно принять. В случаях, когда клиенты поддерживают соединение открытым, количество параллельных задач для процессора должно соответствовать максимальному количеству допустимых TCP-подключений, чтобы каждая задача обрабатывала отдельное соединение. |
| Read Timeout | Время ожидания до истечения срока действия при чтении из соединения. |
| Record Reader | Устройство чтения записей, используемое для входящих Flow-файлов |
| Record Writer | Устройство записи записей, используемое для сериализации данных перед записью в Flow-файл |
| Read Error Strategy | Указывает, как обрабатывать ошибку при чтении следующей записи из соединения, когда предыдущие записи уже были прочитаны из соединения. |
| Record Batch Size | Максимальное количество записей для записи в один FlowFile. |
| SSL Context Service | Служба контроллера, используемая для получения контекста SSL. Если это свойство задано, сообщения будут приниматься по защищенному соединению. |
| Client Auth | Политика аутентификации клиента, используемая для контекста SSL. Используется только в том случае, если предоставляется служба контекста SSL. |
Взаимосвязи
- success: Сообщения, полученные успешно, будут отправлены в эту связь.