ConsumeGCPubSub 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-gcp-nar
説明¶
構成された Google Cloud PubSub サブスクリプションからメッセージを消費します。'Batch Size' プロパティは、1回のリクエストでサブスクリプションから取り出されるメッセージの最大数を指定します。Processing Strategy' プロパティは、各メッセージをそれぞれ独立した FlowFile にするのか、あるいはメッセージを一つの FlowFile にグループ化するのかを指定します。形式が許す限り、Demarcatorストラテジーを使用することで、最高のスループットが得られます。Recordを使用することで、データ形式を変換したり、スキーマを強制することができます。FlowFile ストラテジーを使うと、1つのメッセージにつき、 FlowFile が1つ生成され、メッセージの属性は FlowFile 属性となります。
入力要件¶
FORBIDDEN
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
GCP 認証情報 プロバイダーサービス |
Google Cloud Platform の認証情報の取得に使用する Controller Service。 |
メッセージ デマケーター |
PubSub クライアントはメッセージをバッチで受信するため、このプロセッサーには、 FlowFileswhich にすべてのメッセージをまとめて出力するオプションがあります。このプロパティでは、複数のメッセージを区切るための文字列 (UTF-8) を指定することができます。「改行」などの特殊文字を入力するには、 OS に応じて、 CTRL +Enter または Shift+Enter を使用します。 |
出力ストラテジー |
Kafka レコードを FlowFile レコードに出力する際に使用する形式。 |
加工ストラテジー |
PubSub 記録を処理し、シリアライズされた出力を FlowFiles に書き出すためのストラテジー。 |
Record Reader |
着信メッセージに使用するRecord Reader |
Record Writer |
FlowFiles 送信をシリアライズするために使用するRecord Writer。 |
api-endpoint |
[host:port]の形式で gRPC エンドポイントをオーバーライドします。 |
gcp-project-id |
Google Cloud Project ID |
gcp-pubsub-publish-batch-size |
クラウドサービスがバッチにバンドルするメッセージ数を示します。セットせずに空のままにすると、バッチで使用されるメッセージは1つだけです。 |
gcp-pubsub-subscription |
Google Cloud Pub/Sub サブスクリプションの名前 |
proxy-configuration-service |
ネットワークリクエストをプロキシするプロキシ構成Controller Serviceを指定します。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
success |
FlowFiles は、Google Cloud Pub/Sub 操作が成功すると、このリレーションシップにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
gcp.pubsub.ackId |
消費された Google Cloud PubSub メッセージの確認 ID。 |
gcp.pubsub.messageSize |
消費された Google Cloud PubSub メッセージのシリアライズされたサイズ。 |
gcp.pubsub.attributesCount |
もしあれば、消費された PubSub メッセージが持つ属性の数。 |
gcp.pubsub.publishTime |
メッセージが公開されたタイムスタンプ値 |
gcp.pubsub.subscription |
PubSub サブスクリプション名 |
ダイナミック属性 |
元のGoogle Cloud Publisherクライアントがメッセージの送信時に属性を追加した場合、このプロセッサーはリスト以外の0個以上の属性を書き込むことができます。 |