python - 使用 Python 客户端处理 Google Pub Sub 串行任务

Question

我已经使用 Google Pubsub 设置了消息队列。一切正常。唯一的问题是所有任务都是同时运行的(好吧，目前只有 3 个任务)。由于它们在目标服务器上的权重相当大，因此存在一些问题。

我的解决方案是处理一项任务，等到它完成然后再次运行它。不幸的是，我没有在 Python 库中找到任何可以设置 MaxProcessing 的内容。

我该怎么做？

Answer 1

您可以按照“消息流控制”小节中的说明限制发送至客户端的未完成消息数量。我复制了下面的 python 的最小示例。 https://cloud.google.com/pubsub/docs/pull#subscriber-flow-control-python

from google.cloud import pubsub_v1

# TODO project_id = "Your Google Cloud Project ID"

# TODO subscription_name = "Your Pub/Sub subscription name"

subscriber = pubsub_v1.SubscriberClient()
subscription_path = subscriber.subscription_path(
    project_id, subscription_name)

def callback(message):
    print('Received message: {}'.format(message.data))
    message.ack()

# TODO max_messages_outstanding = 1

# Limit the subscriber to only have ten outstanding messages at a time.
flow_control = pubsub_v1.types.FlowControl(
    max_messages=max_messages_outstanding)
subscriber.subscribe(
    subscription_path, callback=callback, flow_control=flow_control)

-丹尼尔