python - 是否可以在同步拉取 pubsub 时取消确认消息
问题描述
我正在通过订阅提取 pubsub 消息,并且需要在处理之前确认这些消息,因为我正在进行多处理,并且由于 grpc 模块而引发 SSL 损坏错误。
我想事先确认所有消息并取消确认以防出现错误,我知道我们可以为异步拉取执行此操作,但是有没有办法在同步拉取中也可以实现取消确认?
我正在使用官方 python 模块从订阅中提取
解决方案
我想unack
你的意思是在 Python API 参考中nack
解释:
在 Pub/Sub 中,术语ack代表“确认”。
...
也可以nack一条消息,这是相反的......
相同的文档包含部分Pulling a Subscription Synchronously
,其中解释了如何nack
使用modify_ack_deadline()
:
如果你想对一些接收到的消息 (...)进行nack ,你可以使用modify_ack_deadline()方法并将它们的确认截止日期设置为零。这将导致它们被此客户端丢弃,并且后端将尝试重新传递它们。
推荐阅读
- llvm - 在 LLVM 中注册跟踪
- c# - 如何在场景中给文本一个固定的位置?
- apache - 当使用 merlin/dnsmasq 别名而不是主机名时,Apache 的响应时间截然不同
- next.js - useRouter - 查询对象为空
- sql - 在 sqlalchemy 中过滤关系连接
- scala - 连接到 Redis Elasticache 实例,启用了传输中加密,无需使用 Scala 进行身份验证
- swashbuckle.aspnetcore - Swashbuckle 正在使用 System.Collections.Generic.KeyValuePair 架构生成无效的 JSON
- java - 如何在 java 应用程序中为文本字段编写退格代码?
- android-studio - Android Studio 因签名拒绝安装应用
- google-cloud-platform - 在没有云存储的情况下将大型 csv 直接加载到 Big Query 中?