django celery redis 消息unack 的异常出现场景

 

如若处理过程中出现异常,而没有回复ack 应答。通过后台就会看到有 unacked 的数据。

如果积压的多会导致程序无法继续消费数据(数量和消费者的线程数有关)。
解决办法 针对异常 做处理,捕捉到后 也回复ack应答。

程序断开于redis的链接后 unacked的消息状态会重新变为ready 等待消费。
代码更新后,server应用连接redis 就会重新消费掉消息。


 

相关文章:

  • 2021-11-29
  • 2022-12-23
  • 2021-12-19
  • 2021-10-02
  • 2021-07-30
  • 2021-06-16
  • 2022-12-23
  • 2023-02-22
猜你喜欢
  • 2021-09-25
  • 2021-11-22
  • 2022-12-23
  • 2022-12-23
  • 2021-11-29
  • 2022-12-23
  • 2023-01-10
相关资源
相似解决方案