芹菜任务延迟导致键错误



按照芹菜开始使用Django指令,我可以运行任务,但不能使用delay((异步运行同一任务。

我在Django项目中添加了以下需求:

celery==4.3.0
redis==3.3.11
django-celery-results==1.1.2
psycopg2==2.7.3.1
django-cors-headers~=3.1.0

在pop_model项目目录中创建了这个celery.py:

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'pop_model.settings.local')
app = Celery('pop_model')
# namespace='CELERY' means all celery-related configuration keys
# should have a `CELERY_` prefix.
app.config_from_object('django.conf:settings', namespace='CELERY')
# Load task modules from all registered Django app configs.
app.autodiscover_tasks()

@app.task(bind=True)
def debug_task(self):
print('Request: {0!r}'.format(self.request))

将此代码插入项目init.py:

from __future__ import absolute_import, unicode_literals
# This will make sure the app is always imported when
# Django starts so that shared_task will use this app.
from .celery import app as celery_app
__all__ = ('celery_app',)

在项目设置中配置了cors并添加了这些设置:

CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'django-db' # defined in django_celery_results
CELERY_ACCEPT_CONTENT = ['json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'

我可以启动redis,然后使用以下命令运行芹菜:

export DJANGO_SETTINGS_MODULE=pop_model.settings.local
celery worker -A pop_model --loglevel=info

在蟒蛇3的外壳中,我得到了以下结果:

>>> from pop_model.celery import debug_task
>>> debug_task()
Request: <Context: {'args': (), 'kwargs': {}}>
>>> task=debug_task.delay()
Traceback (most recent call last):
File "/Users/janee/.virtualenvs/pop-model/lib/python3.6/site-packages/kombu/utils/objects.py", line 42, in __get__
return obj.__dict__[self.__name__]
KeyError: 'backend'

我不知道如何解决缺少的backend密钥,因为在设置文件中定义了CELERY_RESULT_BACKEND。

普通Python shell和manage.py shell之间的唯一区别是它在DJANGO_settings_module环境变量中导出设置模块(project_name.settings(。

如果您使用正确的环境变量运行相同的解释器,您应该不会看到任何变化。然后,可能是你的pop_model.settings.local路径没有返回一个合适的设置模块供你的应用程序锁定,或者你使用了一个修改过的manage.py脚本(我想是为了分离开发环境(,其中正确加载了设置模块。

您应该能够使用调用您的函数

./manage.py shell

从您的项目目录中,使用虚拟环境的相同intelpreter。这也可以工作,因为DJANGO_SETTING_MODULE需要一个存在于解释器搜索路径中的路径(此处详细介绍(,并且您可以从另一个目录调用解释器。

相关内容

最新更新