Google PubSub：コンシューマへのメッセージ配信をカスタマイズするにはどうすればよいですか？

Question

私は、お客様のデータをpubsubに送信し、Javaの購読者と一緒に使用するシナリオを持っています。同じサブスクリプションに複数のサブスクライバを登録しています。同じcustomerIDのすべてのメッセージを同じ加入者にルーティングする方法はありますか？

私はGoogle Dataflowにセッションベースのウィンドウ機能があることを知っています。しかし、単純なJavaコンシューマーを使って達成できるかどうかを知りたかったのです。

Answer 1

現時点では、Google Cloud Pub/Subには特定のユーザに配信されたメッセージをフィルタリングする方法がありません。あなたが先験的にあなたが持っている加入者の数を知っているなら、あなたは自分でそれをすることができます。購読者と同じ数のトピックを作成し、顧客IDをそれぞれ異なるトピックにまとめることで、各顧客IDごとに適切なトピックにメッセージを公開することができます。各トピックごとに1つのサブスクリプションを作成し、各サブスクライバはこれらのサブスクリプションの1つからメッセージを受信します。

すべての顧客IDのデータを必要とするサブスクライバがある場合は、各トピックで追加のサブスクリプションを持つ必要があり、そのサブスクリプションはすべてのサブスクリプションからメッセージを受け取る必要があります。

10,000以上のトピックを作成したくない場合や、quotasに対して実行できない場合があります。