Как мы выполнили стоп-задачи в celery Period_Task?

Вот как я обрабатывал динамические задачи (динамически создавать и останавливать задачи).

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

Всякий раз, когда вы обновляете PeriodicTask, счетчик в этой таблице также увеличивается, что указывает службе celery beat перезагружать расписание из базы данных.

Так что вам не нужно перезапускать или убивать бит. Если вы хотите остановить задачу, когда выполняются определенные критерии, тогда

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

Если для параметра включено значение False, периодическая задача становится бездействующей. Вы можете снова сделать его активным, сделав enable = True.

Если вам больше не нужна задача, вы можете просто удалить запись.

При создании объекта модели проекта также создайте периодическую задачу. Просто создайте расписание cron или интервальное расписание на основе вашего сценария. Затем создайте объект PeriodicTask, вы можете дать имя от Project.name до PeriodicTask (чтобы вы могли легко связать объект проекта с объектом PeriodicTask. Вот и все, с этого момента задача будет обрабатываться celery beat.

Если вы хотите отключить или включить периодическую задачу динамически, просто установите флаг «включено» в PeriodicTask следующим образом.

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