Как создать пользовательскую периодическую задачу в celery в django

Я хочу создать шедулер в то время как API был получен удар после этого я должен создать после этого я должен остановить седуляр в другом api был получить удар

API1 --> запускаем периодическую задачу celery cron на 3 минуты

API2 --> остановить периодическую задачу сельдерея как

[django_celery_beat][1]

from django_celery_beat.models import PeriodicTask, IntervalSchedule

# executes every 10 seconds.
>>> schedule, created = IntervalSchedule.objects.get_or_create(
...     every=10,
...     period=IntervalSchedule.SECONDS,
... )

>>> PeriodicTask.objects.create(
...     interval=schedule,                  # we created this above.
...     name='Importing contacts',          # simply describes this periodic task.
...     task='proj.tasks.import_contacts',  # name of task.
... )

Я использую этот пакет в своем проекте, вы можете попробовать это.

Вернуться на верх