celery - Celery 中的回滚支持

Question

我打算使用 celery 作为我项目的任务管理组件。它几乎具有我的项目所需的所有功能。我将有一组可以独立执行或按指定顺序执行的任务。在顺序任务中，如果中间任务之一失败，我希望能够执行清理/回滚。我想知道 celery 中是否有开箱即用的功能可以做同样的事情，或者是否有任何可用的解决方法。

Answer 1

Celery 不支持任何类似于回滚的东西。您的任务应该是小的原子步骤，中间步骤不应该破坏您的数据库。

如果您需要还原更改，您可以创建执行相反操作的任务，并在 celery 重试执行其中一项任务时调用它。