python - Celery SQS 任务失败后不会执行

Question

我们将 Celery 与 SQS 代理一起使用，问题是任务失败后，第一个失败的工作人员不会消耗另一个

该设置是具有 SQS 队列的单个工作人员，未配置结果后端。

在调试 Kombu SQS 传输时，我注意到该can_consume方法返回 false https://github.com/celery/kombu/blob/master/kombu/transport/virtual/base.py#L191

这意味着传递的失败消息不会被删除

有谁知道可能导致它的原因？

标签： pythonceleryamazon-sqs

Answer 1

创建了一个错误修复 PR，它将在 celery==4.4.0 上发布

https://github.com/celery/celery/pull/5843