Google PubSub：如何自定義消息分發給消費者？

Question

我有一個場景，我們將發送客戶數據到pubsub並與java用戶一起使用它。我有多個訂閱者訂閱了相同的訂閱。有沒有辦法將同一個customerID的所有消息路由到同一個用戶？

我知道Google Dataflow具有基於會話的窗口。不過，我想知道我們是否可以使用簡單的Java消費者實現它。

Answer 1

目前，Google Cloud Pub/Sub無法過濾傳遞給特定訂閱者的郵件，如果你事先知道你擁有的用戶數量，你可以自己設定。您可以創建與訂閱者數量相同的主題，然後將客戶ID分成不同的主題，將消息發佈到每個客戶ID的正確主題。您需要爲每個主題創建一個訂閱，並且每個訂閱者都會收到來自其中一個訂閱的消息。

缺點是，如果您有任何需要所有客戶ID的數據的訂閱者，那麼您必須爲每個主題訂閱額外的訂閱，並且訂閱者必須從所有訂閱中獲取消息。

請記住，您不會創建超過10,000個主題，否則您可能會遇到quotas。