PutRecord 프로세서
PutRecord 프로세서
PutRecord는 지정한 RecordReader로 들어오는 flowfile에서 레코드를 읽어 Record Destination Service가 지정한 대상으로 보내는 OpenFlow 프로세서예요.
출처: Snowflake 문서
본문
이 프로세서는 일반 사용 가능(Generally Available) 상태예요. OpenFlow Snowflake 배포는 AWS, Azure, GCP 상용(Commercial) 리전의 모든 계정에서 사용할 수 있고, OpenFlow BYOC 배포는 AWS 상용 리전의 모든 계정에서 사용할 수 있어요.
Bundle org.apache.nifi | nifi-standard-nar
설명
PutRecord 프로세서는 지정된 RecordReader를 사용해 들어오는 flow file에서 (여러 개일 수 있는) 레코드를 입력받아, Record Destination Service(즉 record sink)가 지정한 대상으로 보내요.
Tags put, record, sink
입력 요구 사항 필수(REQUIRED)
민감 동적 속성 지원 아니요(false)
속성 (Properties)
| 속성 | 설명 |
|---|---|
| put-record-include-zero-record-results | 들어오는 FlowFile에서 읽은 레코드가 없으면 빈 레코드 집합을 전송할지 여부를 지정해요. 원래 FlowFile은 여전히 success로 라우팅되지만, 전송이 발생하지 않으면 provenance SEND 이벤트는 생성되지 않아요. |
| put-record-reader | 들어오는 데이터를 읽는 데 사용할 Controller Service를 지정해요. |
| put-record-sink | 쿼리 결과 레코드를 어떤 대상에 기록할지 지정하는 Controller Service예요. |
관계 (Relationships)
| 이름 | 설명 |
|---|---|
| failure | 레코드를 전송하지 못했고 연산을 재시도해도 실패할 FlowFile이 이 관계로 라우팅돼요. |
| retry | 레코드를 전송하지 못했지만 연산을 다시 시도하면 성공할 수 있는 원래 FlowFile이 이 관계로 라우팅돼요. |
| success | 레코드가 성공적으로 전송된 원래 FlowFile이 이 관계로 라우팅돼요. |