tasks.py:
from celery import Celery
from django.http import HttpResponse
from anyjson import serialize
celery = Celery('tasks', broker='amqp://guest@localhost//')
#@celery.task
def add(request):
x = int(request.GET['x'])
y = int(request.GET['y'])
result = x+y
response = {'status': 'success', 'retval': result}
return HttpResponse(serialize(response), mimetype='application/json')
после запуска воркера я попробовал диспетчер http:
from celery.task.http import URL
res = URL('http://localhost/add').get_async(x=10, y=10)
res.state
'PENDING'
и получил ошибку вроде [2013-04-03 06: 39: 54,791: ERROR / MainProcess] Получена незарегистрированная задача типа u'celery.task.http.HttpDispatchTask '. Сообщение было проигнорировано и отклонено.
Вы не забыли импортировать модуль, содержащий эту задачу? Или, может быть, вы используете относительный импорт? Подробнее: http://docs.celeryq.org/en/latest/userguide/tasks.html#names
Полное содержание тела сообщения было: {u'utc': True, u'chord': None, u'args': [u'http://localhost/add', u'GET'], u'retries': 0, u'expires': None, u'task': u'celery.task.http.HttpDispatchTask', u'callbacks': None, u'errbacks': None, u'taskset': None, u'kwargs': {u'y': 10, u'x': 10}, u'eta': None, u'id': u'29f83cc9-ba5a-4008-9d2d-6f7bb24b0cfc'} (288b)
Отслеживание (последний вызов последним): File "/usr/local/gdp/python2.7.2/lib/python2.7/site-packages/celery-3.0.13-py2.7.egg/celery/worker/consumer.py", line 435, in on_task_received
strategies[name](message, body, message.ack_log_error)
KeyError: u'celery.task.http.HttpDispatchTask'
