我有一个由组成的体系结构
- 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。