PublishGCPubSub

PublishGCPubSub

들어오는 flowfile의 내용을 구성된 Google Cloud PubSub 토픽으로 게시하는 프로세서예요. 동적 속성을 지원해요.

출처: Snowflake 문서 — PublishGCPubSub

본문

번들 (Bundle)

org.apache.nifi | nifi-gcp-nar

설명

들어오는 flowfile의 내용을 구성된 Google Cloud PubSub 토픽으로 게시해요. 이 프로세서는 동적 속성을 지원하는데, 동적 속성이 있으면 'attributes' 형태로 메시지와 함께 전송돼요.

태그

gcp, google, google-cloud, message, publish, pubsub

입력 요구 사항 (Input Requirement)

REQUIRED — 입력 FlowFile이 필요해요.

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

false — 지원하지 않아요.

속성 (Properties)

속성 설명
GCP Credentials Provider Service Google Cloud Platform 자격 증명을 얻기 위한 Controller Service예요.
Input Batch Size 프로세서 호출마다 처리되는 최대 FlowFile 수예요.
Maximum Message Size Google PubSub 메시지의 최대 크기(바이트)예요. 기본값은 1MB(1048576바이트)예요.
Message Derivation Strategy 들어오는 FlowFile을 Google Cloud PubSub 엔드포인트로 게시하는 데 사용하는 전략이에요.
Record Reader 들어오는 FlowFile에 사용할 Record Reader예요.
Record Writer GCPubSub 엔드포인트로 보내기 전에 데이터를 직렬화하는 데 사용할 Record Writer예요.
api-endpoint [host:port] 형식으로 gRPC 엔드포인트를 재정의해요.
gcp-batch-bytes 이 Batch Bytes Threshold 속성과 Batch Size Threshold 속성 중 먼저 충족되는 조건에 따라 게시 요청이 트리거돼요.
gcp-project-id Google Cloud Project ID예요.
gcp-pubsub-publish-batch-delay 배칭에 사용할 지연 임계값을 나타내요. 이 시간이 경과하면(첫 요소가 추가된 시점부터) 요소가 배치로 묶여 전송돼요. 이 값은 너무 높게 설정하면 안 되며 보통 밀리초 단위여야 해요. 그렇지 않으면 호출이 완료되지 않는 것처럼 보일 수 있어요.
gcp-pubsub-publish-batch-size 클라우드 서비스가 배치로 묶어야 하는 메시지 수를 나타내요. 설정하지 않고 비워두면 배치에 메시지 하나만 사용돼요.
gcp-pubsub-topic Google Cloud PubSub 토픽의 이름이에요.
proxy-configuration-service 네트워크 요청을 프록시할 Proxy Configuration Controller Service를 지정해요.

관계 (Relationships)

이름 설명
failure Google Cloud Pub/Sub 연산이 실패하면 FlowFile이 이 관계로 라우팅돼요.
retry Google Cloud Pub/Sub 연산이 실패했지만 다시 시도하면 성공할 수 있으면 FlowFile이 이 관계로 라우팅돼요.
success Google Cloud Pub/Sub 연산 성공 후 FlowFile이 이 관계로 라우팅돼요.

쓰기 속성 (Writes attributes)

이름 설명
gcp.pubsub.messageId 구성된 Google Cloud PubSub 토픽에 게시된 pubsub 메시지의 ID예요.
gcp.pubsub.count.records 구성된 Google Cloud PubSub 토픽에 게시된 pubsub 메시지 수예요.
gcp.pubsub.topic 메시지가 게시된 Google Cloud PubSub 토픽의 이름이에요.

더 보기 (See also)

  • org.apache.nifi.processors.gcp.pubsub.ConsumeGCPubSub

더 알아보기 (Learn more)