PublishGCPubSub 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-gcp-nar
설명¶
수신 flowfile의 내용을 구성된 Google Cloud PubSub 토픽에 게시합니다. 프로세서는 동적 속성을 지원합니다. 동적 속성이 있는 경우 메시지와 함께 ‘속성’의 형태로 전송됩니다.
입력 요구 사항¶
REQUIRED
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
GCP 자격 증명 공급자 서비스 |
컨트롤러 서비스는 Google 클라우드 플랫폼 자격 증명을 얻는 데 사용됩니다. |
입력 배치 크기 |
각 프로세서 호출에 대해 처리되는 최대 FlowFiles 개수 |
최대 메시지 크기 |
Google PubSub 메시지의 최대 크기(바이트)입니다. 기본값은 1 MB (1048576 바이트) |
Message Derivation Strategy |
이 전략은 수신 FlowFile 을 Google Cloud PubSub 엔드포인트에 게시하는 데 사용되었습니다. |
Record Reader |
수신 FlowFiles 에 사용할 Record Reader |
Record Writer |
GCPubSub 엔드포인트로 보내기 전에 데이터를 직렬화하기 위해 사용할 Record Writer입니다 |
api-endpoint |
[호스트:포트] 형식으로 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 |
클라우드 서비스가 배치로 함께 묶어야 하는 메시지 수를 나타냅니다. 설정하지 않고 비워두면 배치에 1개의 메시지만 사용됩니다 |
gcp-pubsub-topic |
Google 클라우드 PubSub 항목의 이름 |
프록시 구성 서비스 |
네트워크 요청을 프록시할 프록시 구성 컨트롤러 서비스를 지정합니다. |
관계¶
이름 |
설명 |
|---|---|
실패 |
FlowFiles 은 Google Cloud Pub/Sub 작업이 실패할 경우 이 관계로 라우팅됩니다. |
retry |
FlowFiles 은 이 관계로 라우팅되며, Google Cloud Pub/Sub 작업이 실패했지만 작업을 다시 시도하면 성공할 수 있습니다. |
성공 |
FlowFiles 은 성공적인 Google Cloud Pub/Sub 작업 후 이 관계로 라우팅됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
gcp.pubsub.messageId |
구성된 Google Cloud PubSub 항목에 게시된 pubsub 메시지의 ID |
gcp.pubsub.count.records |
구성된 Google Cloud PubSub 항목에 게시된 pubsub 메시지 개수 |
gcp.pubsub.topic |
메시지가 게시된 Google Cloud PubSub 항목의 이름 |