PubSub:如何设置没有指数退避的重试策略?

Mic*_* W. 2 google-cloud-platform google-cloud-pubsub google-cloud-run

我有一个推送订阅,可将消息发送到 Cloud Run 服务。如果 Cloud Run 服务未成功确认消息(否定确认),我希望以最大次数重新发送消息,重试之间的时间间隔始终相同(例如,重试 10 次,每次重试 1 分钟后)。

  1. 我知道我可以设置使用死信队列重新发送消息的最大次数(我也可以在没有死信队列的情况下设置此数字吗?因此,在没有消息的最大传递尝试次数后丢弃/删除消息去另一个队列吗?)。
  2. 另外,通过重试策略,我可以设置最小退避(例如 1 分钟)来决定第一次重试发生的时间,但之后 PubSub 的重试策略会使用一些指数延迟。我可以不在这里指定线性延迟(始终相同的时间间隔)吗?

这是否可以通过此处提到的 PubSub 推送订阅设置https://cloud.google.com/pubsub/docs/admin#using_subscription_properties实现?

预先感谢您的任何帮助。

Ric*_*o D 5

在回答您的问题之前,我们必须看看 pubsub 如何处理重试:

默认情况下,pubsub 会尝试发送消息,直到消息未被确认为止,因为 Pub/Sub 的设计是实现至少一次传递。消息的重新发送将根据设置的消息保留期限(10 分钟到 7 天)继续进行。

  1. 考虑到 pubsub 的行为,唯一的方法是使用您提到的死信队列。

  2. 重试策略是立即重试或指数退避延迟后重试。您无法在这两个选项上配置线性延迟。指数退避由 API 处理,并且根据此SO 答案可能会随着时间的推移而发生变化。如果您正在实施“nack”,则可能的解决方法是选择“立即重试”,并在执行“nack”之前在脚本上添加延迟。这样,您可以控制 nacked 消息的固定延迟。