ListenUDPRecord 2025.10.9.21¶
번들¶
org.apache.nifi | nifi-standard-nar
설명¶
지정된 포트에서 데이터그램 패킷을 수신 대기하고 구성된 Record Reader를 사용하여 각 데이터그램의 내용을 읽습니다. 그러면 구성된 Record Writer를 사용하여 각 레코드가 흐름 파일에 기록됩니다. 이 프로세서는 송신 호스트 및 송신 호스트 포트 속성을 지정하여 특정 원격 호스트 및 포트에서 데이터그램을 수신하도록 제한할 수 있으며, 그렇지 않으면 모든 호스트 및 포트에서 데이터그램을 수신합니다.
입력 요구 사항¶
FORBIDDEN
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
문자 세트 |
수신된 데이터의 문자 세트를 지정합니다. |
로컬 네트워크 인터페이스 |
특정 LAN 에 대한 수신을 제한하는 데 사용할 로컬 네트워크 인터페이스의 이름입니다. |
메시지 큐의 최대 크기 |
기본 채널에서 프로세서로 전송되는 메시지를 버퍼링하는 데 사용되는 내부 큐의 최대 크기입니다. 이 값을 높게 설정하면 수신 메시지가 급증하는 동안 더 많은 메시지를 메모리에 버퍼링할 수 있지만 프로세서가 사용하는 총 메모리가 증가합니다. |
소켓 버퍼의 최대 크기 |
사용해야 하는 소켓 버퍼의 최대 크기입니다. 이것은 소켓 버퍼의 크기를 나타내는 운영 체제에 대한 제안입니다. 이 값을 너무 낮게 설정하면 데이터를 읽기 전에 버퍼가 가득 차서 수신 데이터가 삭제될 수 있습니다. |
Port |
통신을 위해 수신 대기할 포트입니다. |
수신 버퍼 크기 |
메시지를 수신하는 데 사용되는 각 버퍼의 크기입니다. 수신 메시지의 예상 크기에 따라 이 값을 적절히 조정하십시오. |
batch-size |
단일 FlowFile 에 레코드로 쓸 수 있는 최대 데이터그램 수입니다. 배치 크기는 폴링 시간 초과보다 더 자주 데이터가 수신되는 경우에만 달성됩니다. |
poll-timeout |
내부 큐에서 더 많은 데이터그램을 폴링할 때 대기할 시간입니다. 구성된 시간 제한을 기다린 후에도 데이터그램을 찾지 못하면 프로세서는 해당 시점까지 획득한 모든 레코드를 방출합니다. |
record-reader |
수신 데이터그램의 내용을 읽는 데 사용할 Record Reader입니다. |
record-writer |
플로우 파일에 쓰기 전에 데이터를 직렬화하기 위해 사용할 Record Writer입니다. |
sending-host |
IP 또는 원격 호스트의 이름을 입력합니다. 지정된 전송 호스트 포트와 이 호스트의 데이터그램만 허용됩니다. 성능을 향상합니다. 시스템 속성 또는 환경 변수일 수 있습니다. |
sending-host-port |
원격 호스트가 데이터그램을 전송하는 데 사용하는 포트입니다. 지정된 발신 호스트와 이 포트에서 보낸 데이터그램만 허용됩니다. 성능을 향상합니다. 시스템 속성 또는 환경 변수일 수 있습니다. |
관계¶
이름 |
설명 |
|---|---|
parse.failure |
구성된 Record Reader를 사용하여 데이터그램을 구문 분석할 수 없는 경우, 메시지의 내용은 이 관계로 자체적인 개별 FlowFile 로 라우팅됩니다. |
성공 |
성공적으로 수신된 메시지는 이 관계로 전송됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
udp.sender |
메시지를 보내는 호스트입니다. |
udp.port |
메시지가 수신된 발신 포트입니다. |
record.count |
플로우 파일에 기록된 레코드의 수입니다. |
mime.type |
플로우 파일에 레코드를 작성하는 데 사용되는 작성기의 MIME 유형입니다. |