python - 使用 SQS 撤销 Celery 任务

Question

我将 Celery + Kombu 与 Amazon SQL 一起使用。目标是能够删除已经为某个特定日期时间安排的任务。我试过了

from celery.task.control import revoke
revoke(task_id)

但这并没有改变任何东西。是否没有为 SQS 传输实施撤销？它背后是否有一些设计决策，或者它只是一个应该由一些“DeleteMessage”代码行来实现的缺乏功能？

Answer 1

除非您使用的是 RabbitMQ，否则最好使用自定义解决方案来撤销任务。例如，不是执行任务，而是构建一个由两个组件组成的系统：调度程序任务，它扫描您的潜在任务表并在时间到来时执行它们。不需要撤销，你可以在需要的时候决定不执行任务。