Джанго с сельдереем: получение статуса выполняемой задачи

В настоящее время я тестирую Django с сельдереем.

Периодическая задача настроена с помощью crontab для запуска следующей задачи:

from __future__ import absolute_import

from celery import task
import time

@task
def add(x, y):
    print "Start : %s" % time.ctime()
    time.sleep(120)
    print "End : %s" % time.ctime()
    return x + y

Модель:

from django.db import models
from djcelery.models import CrontabSchedule
from djcelery.models import TaskState

class Manager(models.Model):
    cron = models.ForeignKey(CrontabSchedule)

    def app_status(self):
        return self.cron.schedule.app.tasks

    app_status.admin_order_field = 'app status'

Теперь я хотел бы иметь доступ к состоянию текущей или последней задачи. С оболочкой Django я могу получить следующее:

>>> import django
>>> from extractionapp.models import Manager
>>> Manager.objects.all()[0].app_status()
{'celery.chain': <@task: celery.chain of proj:0x1022f1a90>, 'celery.chord': <@task: celery.chord of proj:0x1022f1a90>, 'proj.celery.debug_task': <@task: proj.celery.debug_task of proj:0x1022f1a90>, 'celery.chunks': <@task: celery.chunks of proj:0x1022f1a90>, 'celery.chord_unlock': <@task: celery.chord_unlock of proj:0x1022f1a90>, 'celery.group': <@task: celery.group of proj:0x1022f1a90>, 'celery.backend_cleanup': <@task: celery.backend_cleanup of proj:0x1022f1a90>, 'celery.map': <@task: celery.map of proj:0x1022f1a90>, 'celery.starmap': <@task: celery.starmap of proj:0x1022f1a90>}

Однако я не могу получить доступ к задаче добавления из этого, ни к ее состоянию. Вызов задачи по имени тоже не работает:

Manager.objects.all()[0].app_status()['extractionapp.tasks.add'] Трассировка (последний последний вызов): Файл "", строка 1, в Файле "/Users/antoinebrunel/seo/lib/ python2.7/site-packages/celery/app/registry.py", строка 26, в отсутствует поднять self.NotRegistered(key) NotRegistered: 'extractionapp.tasks.add'

Итак, как я могу получить доступ к состоянию текущей задачи, назначенной cron? Я это вижу из админа через Home › Djcelery › Tasks, но как это получить из кода?

Большое спасибо!


django celery celery-task django-celery djcelery
person Antoine Brunel    schedule 25.05.2015    source источник

Ответы (1)


arrow_upward
3
arrow_downward

Из оболочки Джанго:

>>> from celery import Celery
>>> app = Celery('proj')
>>> i = app.control.inspect()
>>> i.active()
{u'celery@HeyHeyHey': [{u'args': u'[2, 2]', u'time_start': 448519.58944676, u'name': u'extractionapp.tasks.add', u'delivery_info': {u'priority': None, u'redelivered': False, u'routing_key': u'celery', u'exchange': u'celery'}, u'hostname': u'celery@HeyHeyHey', u'acknowledged': True, u'kwargs': u'{}', u'id': u'05fa4347-a222-45f3-9ee0-f3c261a21a24', u'worker_pid': 23999}]}

Источник: http://celery.readthedocs.org/en/latest/userguide/workers.html#dump-of-currently-executing-tasks

person Antoine Brunel    schedule 25.05.2015