【发布时间】：2019-11-19 15:15:42
【问题描述】：
我们将 Celery 与 SQS 代理一起使用，问题是在任务失败后，第一个失败的工作人员不会消耗另一个任务
设置是具有 SQS 队列的单个工作人员，未配置结果后端。
在调试 Kombu SQS 传输时，我注意到 can_consume 方法返回 false https://github.com/celery/kombu/blob/master/kombu/transport/virtual/base.py#L191
这意味着传递的失败消息不会被删除
有人知道是什么原因造成的吗？
【问题讨论】：
标签： python celery amazon-sqs