2015-07-02 4 views
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) 
    }, 
} 
+0

Это может помочь вам http://www.hiddentao.com/archives/2012/01/27/processing-long-running-django-tasks-using-celery-rabbitmq-supervisord-monit/ – chandu

ответ

1

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

Смежные вопросы