ConsumeBoxEvents 프로세서

이 문서는 Snowflake OpenFlow의 ConsumeBoxEvents 프로세서에 대한 참조 문서예요. 업로드, 수정, 삭제 등 Box의 모든 이벤트를 소비하고, 그 내용을 JSON 배열로 출력해요.

출처: Snowflake 문서

본문

기능 — 일반 제공 (Generally Available)

Openflow Snowflake 배포는 AWS, Azure, GCP Commercial 리전의 모든 계정에서 사용할 수 있어요.

Openflow BYOC 배포는 AWS Commercial 리전의 모든 계정에서 사용할 수 있어요.

번들 (Bundle)

그룹	NAR
org.apache.nifi	nifi-box-nar

설명 (Description)

Box에서 모든 이벤트를 소비해요. 이 프로세서는 업로드, 수정, 삭제 등의 이벤트를 캡처하는 데 사용할 수 있어요. 이벤트 내용은 JSON 배열로 'success' 관계로 전달돼요. NiFi 재시작 시 또는 큐 용량을 초과하면 이벤트가 유실될 수 있어요. Box 스트림의 마지막 알려진 위치는 프로세서 상태에 저장되며, 프로세서가 재시작될 때 마지막 알려진 위치에서 스트림을 재개하는 데 사용돼요.

태그 (Tags)

box, storage

입력 요구사항 (Input Requirement)

FORBIDDEN

민감한 동적 속성 지원 (Supports Sensitive Dynamic Properties)

아니요 (false)

속성 (Properties)

속성	설명
Box Client Service	Box API 연결을 얻는 데 사용하는 Controller Service예요.
Queue Capacity	기본 스트림에서 프로세서로 전달되는 이벤트를 버퍼링하는 데 사용하는 내부 큐의 최대 크기예요. 이 값을 높게 설정하면 메시지 유입이 급증할 때 더 많은 메시지를 메모리에 버퍼링할 수 있지만, 급증 중에 프로세서가 사용하는 총 메모리가 늘어나요.

상태 관리 (State management)

범위	설명
CLUSTER	Box 스트림의 마지막 알려진 위치는 프로세서 상태에 저장되며, 프로세서가 재시작될 때 마지막 알려진 위치에서 스트림을 재개하는 데 사용돼요.

관계 (Relationships)

이름	설명
success	성공적으로 수신된 이벤트가 이 관계로 전달돼요.

참고 (See also)

org.apache.nifi.processors.box.FetchBoxFile
org.apache.nifi.processors.box.ListBoxFile
org.apache.nifi.processors.box.PutBoxFile

ConsumeBoxEvents 프로세서