16

我正在尝试在我的项目中使用 django-celery

在 settings.py 我有

CELERY_RESULT_BACKEND = "amqp"

服务器开始正常

python manage.py celeryd --setting=settings

但是，如果我想访问延迟任务的结果，则会收到以下错误：

Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "C:\Python27\lib\site-packages\celery\result.py", line 108, in ready
    return self.status in self.backend.READY_STATES
  File "C:\Python27\lib\site-packages\celery\result.py", line 196, in status
    return self.state
  File "C:\Python27\lib\site-packages\celery\result.py", line 191, in state
    return self.backend.get_status(self.task_id)
  File "C:\Python27\lib\site-packages\celery\backends\base.py", line 404, in _is
_disabled
    raise NotImplementedError("No result backend configured.  "
NotImplementedError: No result backend configured.  Please see the documentation
 for more information.

这很奇怪，因为当我只运行 celeryd（使用相同的 celery 设置）时，它工作得很好。有没有人遇到过这个问题？

提前致谢！

4

6 回答 6

6

尽管执行了 celery 任务（控制台日志），但我在从 celery 任务中获取结果时遇到了同样的问题。我发现，我CELERY_RESULT_BACKEND = "redis"在 django settings.py 中有相同的设置，但我也在 tasks.py 中实例化了 celery

celery = Celery('tasks', broker='redis://localhost')- 我想这会覆盖 settings.py 属性，因此它没有为用于存储结果的 celery 实例配置后端服务器。

我删除了这个，让 django 从 settings.py 中获取 celery 属性，示例代码对我有用。

于 2013-01-08T06:15:43.690 回答
3

如果您只是从http://www.celeryproject.org/tutorials/first-steps-with-celery/运行示例，则需要通过 manage.py 运行控制台：

% python manage.py 外壳

于 2012-06-01T17:35:40.977 回答
2

对于那些像我一样拼命寻找解决方案的人。

将此行放在settings.py脚本的末尾：

djcelery.setup_loader()

看起来django-celery在没有严格顺序的情况下不会考虑它自己的设置。

于 2015-11-25T23:51:54.933 回答
1

就我而言，问题在于我将 CELERY_RESULT_BACKEND 参数传递给 celery 构造函数：

Celery('proj',
         broker = 'amqp://guest:guest@localhost:5672//',
         CELERY_RESULT_BACKEND='amqp://',
         include=['proj.tasks'])

解决方案是改用 backend 参数：

Celery('proj',
         broker = 'amqp://guest:guest@localhost:5672//',
         backend='amqp://',
         include=['proj.tasks'])
于 2016-06-04T15:15:52.120 回答
0

一些控制台必须如何设置 django 环境才能获取设置。例如，在 PyCharm 中，您可以运行 django 控制台，其中一切都按预期工作。

于 2011-12-09T06:18:15.683 回答
0

请参阅AMQP 后端设置以更好地理解

注意 AMQP 后端需要 RabbitMQ 1.1.0 或更高版本才能自动使结果过期。如果你运行的是旧版本的 RabbitMQ，你应该像这样禁用结果过期： CELERY_TASK_RESULT_EXPIRES = None

尝试将以下行添加到您的 settings.py：

CELERY_TASK_RESULT_EXPIRES = 18000 # 5 hours

于 2015-11-30T19:18:56.547 回答