任务是一条消息，“周期性任务”以周期性间隔发送任务消息。发送的每个任务都将分配有唯一的ID。

revoke仅取消单个任务消息。要获取任务的ID，您必须保留跟踪发送的ID，但您也可以在发送任务时指定自定义ID。

我不确定您是否要取消单个任务消息，或者是否要停止定期任务发送更多消息，所以我将列出这两个任务的答案。

没有内置的方法可以保留定期任务发送的任务ID，但是您可以将每个任务的ID设置为定期任务的名称，这样该ID将引用随定期任务一起发送的任何任务(通常是最后一个)。您可以通过这种方式指定自定义ID，

使用@periodic_task装饰器：@periodic_task(options={"task_id": "my_periodic_task"})

def my_periodic_task():

pass

或使用CELERYBEAT_SCHEDULE设置：CELERYBEAT_SCHEDULE = {name: {"task": task_name,

"options": {"task_id": name}}}

如果要删除定期任务，只需从代码库中删除@periodic_task，或从CELERYBEAT_SCHEDULE中删除条目。如果您使用的是Django数据库调度程序，则必须删除定期任务在Django Admin界面中。

PS1：revoke不会停止已经启动的任务。它只会取消尚未开始的任务。您可以使用终止正在运行的任务revoke(task_id, terminate=True)。默认情况下，这会将TERM信号发送到如果您要发送其他信号(例如杀死)，请使用revoke(task_id, terminate=True, signal="KILL")。

PS2：撤消是一个远程控制命令，因此只有RabbitMQ支持和Redis经纪人运输。如果您希望您的任务支持取消，则应通过存储cancelled在数据库中标记并让任务在启动时检查该标记：from celery.task import Task

class RevokeableTask(Task):

"""Task that can be revoked.

Example usage:

@task(base=RevokeableTask)

def mytask():

pass

"""

def __call__(self, *args, **kwargs):

if revoke_flag_set_in_db_for(self.request.id):

return

super(RevokeableTask, self).__call__(*args, **kwargs)