基于Google PubSub与自动扩容Compute Engine的Python任务调度技术问询

最近在业务场景里用Google PubSub做任务调度，最多会生成2000条消息，这些消息交给运行在Google Compute Engine（GCE）Docker容器里的Python脚本处理。

因为单条消息的处理时长在30秒到5分钟不等，我特意把确认截止时间设为600秒（10分钟），确保消息有足够的时间处理完成，避免因为超时被重新投递。

附上核心的代码片段：

from google.cloud import pubsub_v1
from google.cloud.pubsub_v1.subscriber.message import Message

def handle_message(message: Message):
    # 这里编写具体的消息处理逻辑
    # 处理完成后一定要调用ack确认，避免消息重复投递
    message.ack()

内容的提问来源于stack exchange，提问作者Matthias