クラウドpubsub低速ポーリングレート

Question

私は1つのサブスクリプションでpubsubトピックを持ち、2人の異なるサブスクライバがそれから引き出しています。 stackdriverを使って、サブスクリプションに〜1000のメッセージがあることがわかります。 各加入者は、次のポーリング・ループを実行します：

client = pubsub.Client() 
topic = client.topic(topic_name) 
subscription = pubsub.Subscription(subscription_name) 

while True: 
    messages = subscription.pull(return_immediately=True, max_messages=100, client=client) 
    print len(messages) 
    # put messages in local queue for later processing. Those processes will ack the subsription 

私の問題は、遅い投票率である - 私は、私は毎回のみいくつかのメッセージを取得していますポーリングされるのを待っているメッセージをたくさん持っているにもかかわらず。また、メッセージがなくてもたくさんの返信が返ってきます。 stackdriverによると、私のメッセージの引き出し速度は〜1.5メッセージ/秒です。

私はreturn_immediately=Falseを使用することを試みたが、それはそれを少し改善 - ない私が持っていることを期待する率 - プル率は〜2.5メッセージ/秒、それでもに増加しました。

任意のアイデアをどのように引き上げ速度を上げるには？どのpubsub投票ベストプラクティス？

Answer 1

プルレートを向上させるには、一度に複数のプルプル要求を行う必要があります。どのくらいの速さで、どのくらいの場所からあなたが公開するかによって異なります。あなたは常に少なくともいくつかの未解決のものが必要になります。そのうちの1人が戻ったらすぐに、別のプルリクエストを作成します。こうすることで、Cloud Pub/Subがメッセージを購読者に配信する準備が整うと、メッセージの受信を待っているという要求があります。