xec*_*ute 6 python rabbitmq celery
我正在将 Celery 与 RabbitMQ 一起使用，并且我有一个包含 4 个任务和一个组的链。该组位于链的顶部，其中包含大约 1k 个任务。
我有死信队列设置，它可以按预期处理各个任务。
每当组内的任务失败时，它就会进入死信队列，但链的其余部分丢失。
链：
我希望组中的所有这些任务并行运行，如果有任何事情发生，请转到死信队列，并将链任务与其一起移动（这可能是在组中的所有任务都运行之后）。有没有办法做到这一点？如果不是，那么实现包含一个组的可恢复链的替代方法是什么？
链本身正在寻找来自组的回调，如果组失败，其余任务将失败并“丢失”
链的定义：链原语让我们将签名链接在一起，以便一个在另一个之后被调用，本质上形成了一个回调链。
如果我理解正确，您可以通过定义异常在接下来的任务中处理此回调。
作为类似问题的参考：（即使主要任务失败也运行和弦回调）
来源：https ://docs.celeryproject.org/en/stable/userguide/canvas.html#chains
（我会发表评论，但我没有足够的声誉，希望这有帮助！）
| 归档时间： |
|
| 查看次数： |
139 次 |
| 最近记录： |