GCloud Pub/Sub Push Subscription：限制最大未完成消息

Question

在推送订阅配置中是否有办法限制未完成消息的最大数量。在高级订阅者文档 (https://cloud.google.com/pubsub/docs/push) 中，它说“在慢启动的情况下，Google Cloud Pub/Sub 开始时一次发送一条消息，并随着每次成功交付加倍，直到达到最大并发数未处理的消息。”我希望能够限制正在处理的消息的最大数量，这可以通过 pub/sub 配置来完成吗？

我还想了很多其他方法来有效地实现这一点，但似乎没有一个很好：

• 是否在我的推送端点中实现了一些信号量类型系统，一旦达到我的最大并发级别就会返回 429？

• 类似，但让它取消注册推送端点（将其转换为拉取订阅），直到处理完当前消息

我的推送端点都在 gae 上，所以 gae 配置中也可能有一些东西来限制同时推送订阅请求？

Answer 1

推送订阅不提供任何方式来限制未处理消息的数量。如果想要这种级别的控制，就必须使用pull subscriptions 和flow control。

返回 429 错误以限制未处理的消息可能会产生不良副作用。发生错误时，Cloud Pub/Sub 将降低向推送订阅者发送消息的速率。如果返回的 429 错误数量足够多，则订阅者完全有可能在一段时间内收到比它可以处理的消息数量更少的消息，而 Cloud Pub/Sub 会重新提高交付率。

从推送切换到拉取是可能的，但仍然可能不是一个好的解决方案。这实际上取决于推送订阅者超过所需未完成消息数量的频率。推送和拉取和返回之间的更改可能不会立即发生，这意味着订阅者仍可能在一段时间内超过所需的限制，并且在切换回推送订阅者时也可能会遇到接收新消息的延迟。