我已经使用 Google Pubsub 设置了消息队列。一切正常。唯一的问题是所有任务都是同时运行的(好吧,目前只有 3 个任务)。由于它们在目标服务器上的权重相当大,因此存在一些问题。
我的解决方案是处理一项任务,等到它完成然后再次运行它。不幸的是,我没有在 Python 库中找到任何可以设置 MaxProcessing 的内容。
我该怎么做?
最佳答案
您可以按照“消息流控制”小节中的说明限制发送至客户端的未完成消息数量。我复制了下面的 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)
-丹尼尔
关于python - 使用 Python 客户端处理 Google Pub Sub 串行任务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52962863/