google-cloud-platform - 具有 Cloud pubsub 的 Cloud Functions 触发消息排队
问题描述
我们有一个带有 Pubsub 触发器的 Cloud Functions,它将根据消息调用 HTTP 端点上的应用程序。当我们需要更新后端应用程序时,我们希望 Cloud Functions 暂停消息并将消息排队,然后在应用程序启动时重新启动。
目前,我们正在 Stackdriver 中记录所有失败的消息,并在发布后重新提交。有没有更好的方法来做到这一点?
解决方案
您的系统必须能够应对中断(在执行更新或意外中断时由您管理)。因此,我建议您以相同的方式处理两者。
在部署 Cloud Functions(后台函数,与 PubSub 主题绑定)时设置重试参数。当您的 Cloud Functions 无法处理消息(应用程序不可用)时,会引发错误。稍后将重试该消息。
像这样,你没有什么可担心的。当消息可以传递时,它是,当它不能传递时,就会出现错误并重试消息。
推荐阅读
- javascript - Array.reduce - 对象的奇怪行为
- c++ - MsWord API - 如何将表格单元格的内容从一个转移到另一个
- mysql - mysql查询语法错误,在mysql8.0之后不能在UNION之前使用LIMIT?
- python - 带有默认字段的Django模型序列化问题
- ruby-on-rails - 在任何带有Passenger的来源(Bundler::GemNotFound)中都找不到i18n-1.1.1
- ios - 如何分配“UIImage”类型的值?输入“UIView?”
- angular - 使用 Angular 原理图创建新模块
- java - org.springframework.dao.DataIntegrityViolationException on API 调用
- java - 改造抛出错误预期 BEGIN_OBJECT 但 BEGIN_ARRAY 从数组列表到列表?
- android - 如何解决 java.lang.StringIndexOutOfBoundsException?