无法限制 Pub/Sub 启动的 Cloud Run 实例的数量

Question

情况： 我试图让 Pub/Sub 中的一条消息由 Cloud Run 的 1 个实例处理。其他消息将由另一个 Cloud Run 实例处理。每条消息都会触发在 Cloud Run 实例中运行大约 100 秒的繁重计算。

目前，Cloud Run 配置为最大并发请求数 = 1，最小/最大实例数为 0/5。订阅设置为允许 600 秒的 Ack 截止日期。

问题： 每条消息似乎都在触发多个 Cloud Run 实例启动。我相信这是由于 CPU 利用率高导致 Cloud Run 启动额外的实例来帮助处理。不幸的是，这些新实例试图处理相同的确切消息，导致意外结果。

问题： 有没有办法强制 Cloud Run 只让 1 个实例处理一条消息，而不管 CPU 利用率和其他潜在因素如何？

相关代码片段：

import base64
import json

from fastapi import FastAPI, Request, Response

app = FastAPI()

@app.post("/")
async def handleMessage(request: Request):

  envelope = await request.json()

  # Basic data validation
  if not envelope:
      msg = "no Pub/Sub message received"
      print(f"error: {msg}")
      return Response(content=msg, status_code=400)

  if not isinstance(envelope, dict) or "message" not in envelope:
      msg = "invalid Pub/Sub message format"
      print(f"error: {msg}")
      return Response(content=msg, status_code=400)

  message = envelope["message"]

  if isinstance(message, dict) and "data" in message:
      data = json.loads(base64.b64decode(message["data"]).decode("utf-8").strip())

  try:
      # Do computationally heavy operations here
      # Will run for about 100s

      return Response(status_code=204)

  except Exception as e:
      print(e)

谢谢！

Answer 1

我找到了问题。

显然，Pub/Sub 保证“至少一次”交付，这意味着它可以向订阅者多次交付消息。因此，订阅者（在我的例子中是 Cloud Run）有责任优雅地处理此类场景（幂等性）。