如何从python解释器内部定义celery 任务?正在获取[celery .例外.未注册]

hujrc8aj  于 2021-06-10  发布在  Redis
关注(0)|答案(0)|浏览(247)

我是这样运行的:
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) 但我最终还是犯了同样的错误。。。
我将非常感谢你的帮助!

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题