首页 > 解决方案 > 来自芹菜任务延迟的Keyerror

问题描述

celery 开始使用 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,然后使用以下命令运行 celery:

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

在 python3 shell 中,我得到以下结果:

>>> 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 是在设置文件中定义的。

标签: djangocelery

解决方案


普通 Python shell 与普通 Python shell 之间的唯一区别在于manage.py shell它将您的设置模块 ( project_name.settings) 导出到 DJANGO_SETTINGS_MODULE 环境变量中。

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

您应该能够使用

./manage.py shell

从您的项目目录中,使用与您的虚拟环境相同的解释器。这也可以工作,因为 DJANGO_SETTINGS_MODULE 需要一个存在于解释器搜索路径中的路径(更多信息在这里),并且您可以从另一个目录调用解释器。


推荐阅读