PublishGCPubSub 2025.5.31.15¶
バンドル¶
org.apache.nifi | nifi-gcp-nar
説明¶
構成された Google Cloud PubSub トピックに受信フローファイルのコンテンツを公開します。プロセッサーは動的プロパティをサポートしています。もし動的プロパティがあれば、「属性」という形でメッセージと一緒に送られます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
GCP 認証情報 プロバイダーサービス |
Google Cloud Platform の認証情報の取得に使用する Controller Service。 |
入力バッチサイズ |
各プロセッサー呼び出しで処理される FlowFiles の最大数 |
最大メッセージサイズ |
Google PubSub メッセージの最大サイズ（バイト）。デフォルトは1 MB (1048576バイト) |
メッセージ派生ストラテジー |
受信した FlowFile を Google Cloud PubSub のエンドポイントにパブリッシュする際に使用するストラテジー。 |
Record Reader |
受信 FlowFiles に使用するRecord Reader |
Record Writer |
GCPubSub エンドポイントに送信する前にデータをシリアライズするために使用するRecord Writer。 |
api-endpoint |
[host:port]の形式で gRPC エンドポイントをオーバーライドします。 |
gcp-batch-bytes |
発行リクエストは、このバッチ・バイトしきい値プロパティとバッチ・サイズしきい値プロパティに基づいてトリガーされます。 |
gcp-project-id |
Google Cloud Project ID |
gcp-pubsub-publish-batch-delay |
バッチに使用する遅延しきい値を示します。この時間が経過すると（最初に追加された要素から数えて）、要素はバッチにまとめられ、送信されます。この値はあまり大きく設定すべきではなく、通常はミリ秒オーダーです。そうしないと、通話が完了しないように見えるかもしれません。 |
gcp-pubsub-publish-batch-size |
クラウドサービスがバッチにバンドルするメッセージ数を示します。セットせずに空のままにすると、バッチで使用されるメッセージは1つだけです。 |
gcp-pubsub-topic |
Google Cloud PubSub トピック名 |
proxy-configuration-service |
ネットワークリクエストをプロキシするプロキシ構成Controller Serviceを指定します。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
failure |
FlowFiles は、Google Cloud Pub/Sub オペレーションが失敗した場合、このリレーションシップにルーティングされます。 |
retry |
FlowFiles は、Google Cloud Pub/Sub 操作が失敗した場合、このリレーションシップにルーティングされます。 |
success |
FlowFiles は、Google Cloud Pub/Sub 操作が成功すると、このリレーションシップにルーティングされます。 |
属性の書き込み¶
名前 |
説明 |
|---|---|
gcp.pubsub.messageId |
構成された Google Cloud PubSub トピックに発行された pubsub メッセージの ID |
gcp.pubsub.count.records |
構成された Google Cloud PubSub トピックに公開された pubsub メッセージの数。 |
gcp.pubsub.topic |
メッセージが公開された Google Cloud PubSub のトピック名 |