Google PubSub - 使用 ack_id 确认消息

Question

我的架构由：

• PubSub 主题'A'
• 订阅 'B' 主题 'A'，将消息推送到端点 'X'
• 云函数 'C' 由端点 'X' 触发，运行时间在 Python

每次在主题 'A' 上发布新消息时，订阅 'B' 都会将其推送到触发云函数 'C' 的端点 'X'。

我面临的问题是消息的 'acking'。 我会向云函数 'C' 添加一个步骤，以便使用 ack_id 手动确认消息，但我发现的每个线程都不鼓励使用 ack_id 手动确认消息而且我不知道如何用不同的方式做...

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

提前致谢！

ps。这种架构是必要的，因为主题 'A' 和 Cloud Function 'C' 处于不同的项目中

Answer 1

手动ack在push模式下是没用的（Cloud Function直接插在Topic上，或者push订阅在topic上）。要使用推送订阅确认消息，HTTP 服务必须回答 valid HTTP code.

如果您使用拉式订阅，您可以使用 ack_id 执行手动确认。