我们如何在芹菜periodic_task中完成停止任务?

Question

撤销@periodic_task上的任务会发送Discarding revoked tasks & Due task to workers.

芹菜-工人-截图

[2018-09-17 12:23:50,864: INFO/MainProcess] Received task: cimexapp.tasks.add[xxxxxxx]
[2018-09-17 12:23:50,864: INFO/MainProcess] Discarding revoked task: cimexapp.tasks.add[xxxxxxx] [2018-09-17 12:24:00,865: INFO/Beat] Scheduler: Sending due task cimexapp.tasks.add (cimexapp.tasks.add) [2018-09-17 12:24:00,869: INFO/MainProcess] Received task: cimexapp.tasks.add[xxxxxxx]
[2018-09-17 12:24:00,869: INFO/MainProcess] Discarding revoked task: cimexapp.tasks.add[xxxxxxx] [2018-09-17 12:24:10,865: INFO/Beat] Scheduler: Sending due task cimexapp.tasks.add (cimexapp.tasks.add) [2018-09-17 12:24:10,868: INFO/MainProcess] Received task: cimexapp.tasks.add[xxxxxxx]
[2018-09-17 12:24:10,869: INFO/MainProcess] Discarding revoked task: cimexapp.tasks.add[xxxxxxx]

---

tasks.py

@periodic_task(run_every=timedelta(seconds=10),options={"task_id":"xxxxxxx"})
def add():
call(["ping","-c10","google.com"])

def stop():
x = revoke("xxxxxxx",terminate=True,signal="KILL")
print(x)
print('DONE')

我用一个名字创建了task_id，这样我就可以很容易地通过调用 id 来杀死它。

如何完全阻止它发送任务？ 我不想杀死所有工人

• 普基尔-9 -F'芹菜工人'
• 芹菜 - 项目名称控件关闭

---

• 我只想停止add()功能的任务/工作线程。

Answer 1

一种可能的方法是将任务存储在数据库中并动态添加删除任务。您可以使用数据库支持的芹菜节拍调度程序来实现相同目的。请参阅 https://django-celery-beat.readthedocs.io/en/latest/。定期任务数据库存储定期任务。您可以使用数据库命令(Django ORM(来操作定期任务。

这就是我处理动态任务(动态创建和停止任务(的方式。

from django_celery_beat.models import PeriodicTask, IntervalSchedule, CrontabSchedule
chon_schedule = CrontabSchedule.objects.create(minute='40', hour='08', day_of_week='*', day_of_month='*', month_of_year='*') # To create a cron schedule. 
schedule = IntervalSchedule.objects.create(every=10, period=IntervalSchedule.SECONDS) # To create a schedule to run everu 10 min.
PeriodicTask.objects.create(crontab=chon_schedule, name='name_to_identify_task',task='name_of_task') # It creates a entry in the database describing that periodic task (With cron schedule).
task = PeriodicTask.objects.create(interval=schedule, name='run for every 10 min', task='for_each_ten_min', ) # It creates a periodic task with interval schedule

每当您更新周期任务时，此表中的计数器也会 递增，告诉芹菜节拍服务重新加载 从数据库计划。

因此，您无需重新启动或终止节拍。 如果要在满足特定条件时停止任务，则

periodic_task = PeriodicTask.objects.get(name='run for every 10 min')
periodic_task.enabled = False
periodic_task.save()

如果启用为 False，则定期任务变为空闲状态。您可以通过使enable = True.

如果您不再需要该任务，则只需删除该条目即可。

创建项目模型对象时，也要创建定期任务。只需根据您的方案创建 cron 计划或间隔计划即可。然后创建PeriodicTask对象，您可以Project.namePeriodicTask名称(因此您可以轻松地将项目对象与PeriodicTask对象相关联。就是这样，从那一刻起，任务将通过芹菜节拍来处理。

如果要动态禁用或启用定期任务，只需在PeriodicTask中设置启用标志，如下所示

task = PeriodicTask.objects.get(name='task_name')
task.enabled = False
task.save()

Answer 2

在 Celery 4.2.2 中，您可以通过执行以下命令删除所有节拍任务

celery -A YourProjectName purge

请记住替换您的项目名称。 有关更多信息，请查看此页面