ConsumeGCPubSub 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-gcp-nar
설명¶
구성된 Google Cloud PubSub 구독의 메시지를 소비합니다. ‘Batch Size’ 속성은 한 번의 요청으로 구독에서 가져올 최대 메시지 수를 지정합니다. ‘Processing Strategy’ 속성은 각 메시지를 고유한 FlowFile 로 할지 아니면 메시지를 1개의 FlowFile 로 그룹화할지 지정합니다. Demarcator 전략을 사용하면 형식이 허용하는 경우 최상의 처리량을 제공할 수 있습니다. 레코드를 사용하면 데이터 형식을 변환하고 스키마 적용을 수행할 수 있습니다. FlowFile 전략을 사용하면 메시지당 FlowFile 1개가 생성되며 메시지의 특성은 FlowFile 특성이 됩니다.
입력 요구 사항¶
FORBIDDEN
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
GCP 자격 증명 공급자 서비스 |
컨트롤러 서비스는 Google 클라우드 플랫폼 자격 증명을 얻는 데 사용됩니다. |
Message Demarcator |
PubSub 클라이언트는 메시지를 일괄적으로 수신하기 때문에, 이 프로세서는 FlowFileswhich 에 단일 일괄 처리된 모든 메시지를 출력하는 옵션을 가지고 있습니다. 이 속성을 사용하면 여러 메시지를 구분하는 데 사용할 문자열(UTF-8로 해석됨)을 제공할 수 있습니다. ‘new line’과 같은 특수 문자를 입력하려면 OS 에 따라 CTRL+Enter 또는 Shift+Enter를 사용합니다. |
Output Strategy |
Kafka 레코드를 FlowFile 레코드로 출력하는 데 사용되는 형식입니다. |
Processing Strategy |
PubSub 레코드 처리 및 직렬화된 출력을 FlowFiles 에 쓰기 전략 |
Record Reader |
수신 메시지에 사용할 Record Reader |
Record Writer |
전송 FlowFiles 을 직렬화하기 위해 사용할 Record Writer입니다. |
api-endpoint |
[호스트:포트] 형식으로 gRPC 엔드포인트를 재정의합니다 |
gcp-project-id |
Google Cloud Project ID |
gcp-pubsub-publish-batch-size |
클라우드 서비스가 배치로 함께 묶어야 하는 메시지 수를 나타냅니다. 설정하지 않고 비워두면 배치에 1개의 메시지만 사용됩니다 |
gcp-pubsub-subscription |
Google Cloud Pub/Sub 구독의 이름 |
프록시 구성 서비스 |
네트워크 요청을 프록시할 프록시 구성 컨트롤러 서비스를 지정합니다. |
관계¶
이름 |
설명 |
|---|---|
성공 |
FlowFiles 은 성공적인 Google Cloud Pub/Sub 작업 후 이 관계로 라우팅됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
gcp.pubsub.ackId |
소비된 Google Cloud PubSub 메시지의 인증 ID |
gcp.pubsub.messageSize |
소비된 Google Cloud PubSub 메시지의 직렬화된 크기 |
gcp.pubsub.attributesCount |
소비된 PubSub 메시지의 특성 수(있는 경우) |
gcp.pubsub.publishTime |
메시지가 게시된 타임스탬프 값 |
gcp.pubsub.subscription |
PubSub 구독 이름 |
Dynamic Attributes |
원래 Google Cloud 게시자 클라이언트가 메시지를 보내는 동안 메시지에 특성을 추가한 경우 이 프로세서는 목록에 있는 특성 외에 0개 이상의 특성을 기록할 수 있습니다 |