Cloud pubsub慢速投票率

Question

我有一个pubsub主题，有一个订阅，两个不同的订阅者正在从中抽取。使用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

为了提高你的拉动率，你需要一次有一个以上未完成的拉动请求。多少取决于你发布的速度和位置。你需要至少几个杰出的时刻。一旦其中一个返回，就创建另一个拉请求。这样，每当Cloud Pub/Sub准备好向您的订阅者发送消息时，您就会有等待接收消息的请求。