Как запускать задачи из Django Periodi c Task Object [django -celery-beat] - PullRequest
0 голосов
/ 12 января 2020

Django У Celery Beat есть опция в панели администратора, где вы можете запускать задачи напрямую, выбирая каждый отдельный PeriodicTask объект модели.

https://github.com/celery/django-celery-beat

enter image description here

from django_celery_beat.models import PeriodicTask

get_task = PeriodicTask.objects.get(id=1)
  • Для разных объектов зарегистрированы разные задачи. Как выполнить задачу сельдерея, взяв значения из объекта модели PeriodicTask?

1 Ответ

0 голосов
/ 12 января 2020
from celery.execute import send_task   
from django_celery_beat.models import PeriodicTask
import json

get_task = PeriodicTask.objects.get(id=1)
get_task_registed_taskname = get_task.task
get_task_kwargs = json.loads(get_task.kwargs)

send_task(get_task_registed_taskname,[],get_task_kwargs)
...