带有芹菜的 Django 无法从后端获取结果

Question

我的django项目是从Celery repo：https://github.com/celery/celery/tree/3.1/examples/django 克隆而来的。在我添加的常量BROKER_URL之后的设置中

CELERY_RESULT_BACKEND = 'amqp://'

我正在尝试从项目中调用名为"添加"的任务。内部工人终端结果正常，但无法恢复。我称命令是这样的：

from demoapp.tasks import add
add.delay(2,2)
add.AsyncResult(a.task_id).get()

但不知道为什么我得到错误：

<ipython-input-3-5f18de09f6a1> in <module>()
----> 1 add.AsyncResult(a.task_id).get()
/home/t/py/django/celeryexample/venv/lib/python2.7/site-packages/celery/result.pyc in get(self, timeout, propagate, interval, no_ack, follow_parents, EXCEPTION_STATES, PROPAGATE_STATES)
    167             interval=interval,
    168             on_interval=on_interval,
--> 169             no_ack=no_ack,
    170         )
    171         if meta:
/home/t/py/django/celeryexample/venv/lib/python2.7/site-packages/celery/backends/base.pyc in _is_disabled(self, *args, **kwargs)
    595     def _is_disabled(self, *args, **kwargs):
    596         raise NotImplementedError(
--> 597             'No result backend configured.  '
    598             'Please see the documentation for more information.')
    599     wait_for = get_status = get_result = get_traceback = _is_disabled
NotImplementedError: No result backend configured.  Please see the documentation for more information

Answer 1

我从 ipython 而不是 shell 运行任务 manage.py 所以这就是问题所在

Answer 2

pip install 'django_celery_results'

在 settings.py INSTALLED_APPS中添加django_celery_results（它将创建一个表来存储结果）

将芹菜结果设置为以下 settings.py

CELERY_RESULT_BACKEND = 'django-db'
python manage.py makemigrations
python manage.py migrate

重新启动工作线程..做

Answer 3

您收到此错误是因为您将后端设置为使用与 AMPQ 兼容的后备存储，而您没有该存储。通常的AMPQ存储是RabbitMQ，但还有其他的，如ActiveMQ，Apollo等。

我建议不要使用 AMPQ 进行持久性，除非您有专用服务器。

您可以改用数据库或 redis 来存储结果。出于测试目的，您可以使用SQLite，

CELERY_RESULT_BACKEND = 'db+sqlite:///results.db'

来自芹菜文档