バッチ メッセージでは、カスタムバッチ設定を使用してパブリッシャー クライアントを作成し、それを使用して一部のメッセージをパブリッシュします。
このドキュメントでは、トピックにパブリッシュされたメッセージでのバッチ メッセージの使用について説明します。
準備
パブリッシュ ワークフローを構成する前に、次のタスクを完了していることを確認してください。
- トピックとパブリッシュのワークフローについて学びます。
- トピックを作成します。
必要なロール
トピックにメッセージをパブリッシュするために必要な権限を取得するには、トピックに対する Pub/Sub パブリッシャー(roles/pubsub.publisher
)IAM ロールを付与するよう管理者に依頼してください。ロールの付与の詳細については、アクセス権の管理をご覧ください。
必要な権限は、カスタムロールや他の事前定義ロールから取得することもできます。
トピックとサブスクリプションを作成または更新するには、追加の権限が必要です。
バッチ メッセージを使用する
パブリッシャーのバッチ メッセージ設定を構成する方法については、以下のコードサンプルをご覧ください。
C++
このサンプルを試す前に、クイックスタート: クライアント ライブラリの使用の C++ の設定手順を実施してください。詳細については、Pub/Sub C++ API リファレンス ドキュメントをご覧ください。
C#
このサンプルを試す前に、クイックスタート: クライアント ライブラリの使用の C# の設定手順を実施してください。詳細については、Pub/Sub C# API リファレンス ドキュメントをご覧ください。
Go
このサンプルを試す前に、クイックスタート: クライアント ライブラリの使用の Go の設定手順を実施してください。詳細については、Pub/Sub Go API リファレンス ドキュメントをご覧ください。
Java
このサンプルを試す前に、クイックスタート: クライアント ライブラリの使用の Java の設定手順を実施してください。詳細については、Pub/Sub Java API リファレンス ドキュメントをご覧ください。
Node.js
このサンプルを試す前に、クイックスタート: クライアント ライブラリの使用の Node.js の設定手順を実施してください。詳細については、Pub/Sub Node.js API リファレンス ドキュメントをご覧ください。
Node.js
このサンプルを試す前に、クイックスタート: クライアント ライブラリの使用の Node.js の設定手順を実施してください。詳細については、Pub/Sub Node.js API リファレンス ドキュメントをご覧ください。
PHP
このサンプルを試す前に、クイックスタート: クライアント ライブラリの使用の PHP の設定手順を実施してください。詳細については、Pub/Sub PHP API リファレンス ドキュメントをご覧ください。
Python
このサンプルを試す前に、クイックスタート: クライアント ライブラリの使用の Python の設定手順を実施してください。詳細については、Pub/Sub Python API リファレンス ドキュメントをご覧ください。
Ruby
このサンプルを試す前に、クイックスタート: クライアント ライブラリの使用の Ruby の設定手順を実施してください。詳細については、Pub/Sub Ruby API のリファレンス ドキュメントをご覧ください。
バッチ メッセージングを無効にする
クライアント ライブラリでバッチ処理をオフにするには、max_messages
の値を 1 に設定します。
バッチ メッセージングと順序が指定された配信
順序付けされた配信では、バッチ内のメッセージの確認応答に失敗した場合、確認応答されていないメッセージよりも前に送信されたメッセージを含むバッチのすべてのメッセージを再配信することになります。
バッチ メッセージングの割り当てと上限
バッチ メッセージングを構成する前に、パブリッシュのスループット割り当てやバッチの最大サイズなどの要素の影響を考慮してください。ハイレベルなクライアント ライブラリでは、バッチ リクエストが指定された制限内に収まることが保証されます。
- 実際のメッセージ サイズが 1,000 バイトより小さい場合でも、コスト上考慮されるリクエストの最小サイズは 1,000 バイトです。
- Pub/Sub には、単一のバッチ パブリッシュ リクエストに対して 10 MB のサイズまたは 1,000 メッセージの上限があります。
詳細については、Pub/Sub の割り当てと上限をご覧ください。
次のステップ
詳細なパブリッシュのオプションを構成する方法については、以下をご覧ください。