PutTCP 프로세서
PutTCP 프로세서
PutTCP는 직렬화된 FlowFile 또는 레코드를 TCP로 설정 가능한 대상에 보내고 선택적으로 TLS를 지원하는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle org.apache.nifi | nifi-standard-nar
설명
직렬화된 FlowFile 또는 레코드를 TCP로 설정 가능한 대상에 보내며 TLS 지원을 선택할 수 있어요.
Tags egress, put, remote, tcp
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| Character Set | 보내는 데이터의 문자 집합을 지정해요. |
| Connection Per FlowFile | 각 FlowFile의 내용을 개별 연결로 보낼지 여부를 지정해요. |
| Hostname | 대상 호스트명 또는 IP 주소예요. |
| Idle Connection Expiration | 사용되지 않고 열린 상태로 유지된 뒤 연결을 닫기 전까지의 시간이에요. 0초면 이 기능이 비활성화돼요. |
| Max Size of Socket Send Buffer | 사용할 소켓 전송 버퍼의 최대 크기예요. 이는 운영체제에 소켓 버퍼를 얼마나 크게 할지 알려주는 제안이에요. 이 값이 너무 낮게 설정되면 데이터를 읽기 전에 버퍼가 가득 차서 들어오는 데이터가 버려질 수 있어요. |
| Outgoing Message Delimiter | 같은 TCP 스트림으로 메시지를 보낼 때 사용할 구분자를 지정해요. 구분자는 스트림으로 전송되는 각 FlowFile 메시지에 추가되어 수신자가 한 메시지가 끝나고 다음 메시지가 시작되는 지점을 알 수 있게 해요. 사용자는 오류를 피하기 위해 FlowFile 내용에 구분자 문자가 포함되지 않도록 해야 해요. 개행 문자를 사용하려면 'n'을, 탭 문자에는 't'를, 캐리지 리턴에는 'r'을 입력할 수 있어요. |
| Port | 대상 포트 번호예요. |
| Record Reader | 입력 FlowFile에서 레코드를 읽는 데 사용할 Controller Service를 지정해요. |
| Record Writer | 구성된 소켓 주소에 레코드를 쓰는 데 사용할 Controller Service를 지정해요. |
| SSL Context Service | TLS 소켓 통신을 활성화할 SSL Context Service를 지정해요. |
| Timeout | 대상에 연결하고 통신하는 타임아웃이에요. UDP에는 적용되지 않아요. |
| Transmission Strategy | 입력 FlowFile을 읽고 대상 소켓 주소로 메시지를 전송하는 데 사용하는 전략을 지정해요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | 대상으로 보내지 못한 FlowFile이 이 관계로 나가요. |
| success | 대상으로 성공적으로 보내진 FlowFile이 이 관계로 나가요. |
기록되는 속성 (Writes attributes)
| 속성 | 설명 |
|---|---|
| record.count.transmitted | 구성된 대상 주소로 전송된 레코드 수예요. |