我是这样运行的:
redis公司:
redis-server.exe—日志级别详细信息
celery :
celery 工人-a clr-l信息
哪里 clr.py
包含:
import os
from celery import Celery
# Because Windows sucks...
os.environ.setdefault('FORKED_BY_MULTIPROCESSING', '1')
_CELERY_CONFIG_ = {
'BROKER_URL': 'redis://localhost:6379/0',
'CELERY_RESULT_BACKEND': 'redis://localhost:6379/0',
}
celery = Celery('tasks', config_source=_CELERY_CONFIG_)
当我跑的时候 flask shell
试着用celery 挖来挖去,看看效果如何:
>>> from clr import celery
>>> @celery.task
... def hello():
... return 'hello from celery'
...
>>> hello.delay().get()
...
celery.exceptions.NotRegistered: 'tasks.hello'
运行时任务列表为空 celery
命令,所以我看到celery 只有在文件中有它们的时候才会注册。。有没有办法绕过这个问题,让我新定义的任务正常工作?
我试过了 celery.register_task(TaskInAClass)
但我最终还是犯了同样的错误。。。
我将非常感谢你的帮助!
暂无答案!
目前还没有任何答案,快来回答吧!