GCP Pub Sub：批量处理消息

Question

在 GAE 应用程序中，我们希望批量处理 Pub Sub 消息，例如：每 10 秒读取订阅上的所有待处理消息并批量处理它们（因为这样会更有效率）。同步的subscriber.pull() 可以很好地让我们读取一批待处理的消息。问题是我接下来要做什么？睡 10 秒再读一遍？但这需要一个永久性的后台任务，这在 App Engine 中很难设置。每分钟（或每小时）由 cron 调用的端点，它运行多个周期 [读取和处理消息，睡眠 10 秒] 周期一小时，然后退出？有更好的主意吗？

Answer 1

您可以使用 Cloud Scheduler 每分钟调用一次您的 App Engine 端点。此端点读取 pubsub 订阅一段时间（比如说 45 秒）处理消息，然后返回 200 HTTP 代码。

如果你想按 10s 的时间窗口阅读，你需要在你身边构建流程。继续每分钟调用一次端点（这是无服务器模式，该过程仅在请求处理中执行），但端点监听订阅 10 秒，处理消息，睡眠 10 秒，然后重复 5 次，然后返回 200 HTTP 代码。