Google PubSub-使用Ack_id确认消息



我有一个由组成的体系结构

  • PubSub主题"A">
  • 主题"A"上的订阅"B"将消息推送到端点"X">
  • 由端点"X"触发的云函数"C",在Python中运行

每次在主题"a"上发布新消息时,订阅"B"都会将其推送到触发云功能"C"的端点"X"。

我面临的问题是信息的"确认"。我会在云函数"C"中添加一个步骤,以便用ack_id手动确认消息,但我发现的每个线程都不鼓励使用ack_id手工确认消息,我不知道如何用不同的方式。。。

有什么建议吗?如何手动确认消息?

提前感谢!

ps。这个体系结构是必要的,因为主题"A"和云功能"C"停留在不同的项目中

手动ack在推送模式下是无用的(Cloud Function直接插入主题,或者在主题上进行推送订阅(。要通过推送订阅确认消息,HTTP服务必须回答有效的HTTP代码。

若您使用请求订阅,则可以使用ack_id执行手动ack。

相关内容

  • 没有找到相关文章

最新更新