带有 SQS 代理和死信队列的芹菜
Celery with SQS broker & dead letter queue
我正在尝试弄清楚如何配置 celery 以在消息按配置通过 max_retries 后移动消息到死信队列。
目前正在删除（确认）超过max_retries的消息。
有这样的选择吗？
目前，据我所知，这是不可能的，但很快 Celery should be able to do it。您已经可以测试我链接到的 Celery 问题中提到的 PR 的分支，看看它是否按您预期的那样工作。
根据 DejanLekic 的回答，我创建了一个带有本地 SQS 的 docker 化项目，展示了他想要的解决方案
这里可以看到https://github.com/galCohen88/celery_sqs_redis_backend
我正在尝试弄清楚如何配置 celery 以在消息按配置通过 max_retries 后移动消息到死信队列。
目前正在删除（确认）超过max_retries的消息。
有这样的选择吗？
目前，据我所知，这是不可能的，但很快 Celery should be able to do it。您已经可以测试我链接到的 Celery 问题中提到的 PR 的分支，看看它是否按您预期的那样工作。
根据 DejanLekic 的回答，我创建了一个带有本地 SQS 的 docker 化项目，展示了他想要的解决方案
这里可以看到https://github.com/galCohen88/celery_sqs_redis_backend