使用SQS撤消Celery任务

我正在使用Celery + Kombu和Amazon SQL。目标是能够删除已安排的某个特定日期时间的任务。我试了使用SQS撤消Celery任务

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

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

来源

2012-03-21 AlexA

我遇到同样的问题。你找到解决方案吗？ – 2012-04-16 15:21:56

我已经恢复到Django-Celery。除非你使用RabbitMQ，否则最好为自己的任务提供一个定制的解决方案。例如。不是执行任务，而是建立一个由两部分组成的系统：调度程序任务，用于扫描您的潜在任务表并在时间到期时执行它们。无需撤销，您可以决定在需要时不执行任务。 – AlexA 2012-04-16 19:39:34

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

来源

2012-04-17 14:23:40 AlexA

使用SQS撤消Celery任务

回答

相关问题