0
Я следовал за руководством по настройке RabbitMQ, установке сельдерея и выполнению файла через оболочку. Im теперь пытаясь научиться готовить периодические задачи, с тем же файлом, но независимо от того, что я делаю, я получаю эту ошибку: обе задачи/config находятся в корне.Django: Сельдерей: первые шаги с проблемами сельдерея
[2015-07-02 07:56:33,928: ERROR/MainProcess] Received unregistered task of type
'tasks.scrape'.The message has been ignored and discarded.
File "/home/apps/django/env/local/lib/python2.7/site- packages/celery/worker/consumer.py", line 455, in on_task_received strategies[name](message, body,
KeyError: 'tasks.scrape'
tasks.py
from celery import Celery
app = Celery('tasks', backend='amqp', broker='amqp://[email protected]//')
app.config_from_object('celeryconfig')
@app.task(name='scrape-odds')
def scrape(x,y):
return x + y
celeryconfig.py
from datetime import timedelta
from celery.schedules import crontab
CELERY_IMPORTS = ("tasks")
CELERY_ENABLE_UTC = True
CELERY_TIMEZONE = 'UTC'
CELERYBEAT_SCHEDULE = {
'scrape-odds': {
'task': 'tasks.scrape',
'schedule': timedelta(seconds=30),
'args': (16, 16)
},
}
Это может помочь вам http://www.hiddentao.com/archives/2012/01/27/processing-long-running-django-tasks-using-celery-rabbitmq-supervisord-monit/ – chandu