django 项目中的 Celery 异步任务。它是如何运作的？

Question

我需要在我的 Django 项目中运行长时间的任务。决定使用 celery 和 redis 作为代理。安装的redis运行：

服务器现在已准备好接受端口 6379 上的连接

比我安装 django-celery、配置：

import djcelery
djcelery.setup_loader()
BROKER_HOST = "localhost"
BROKER_PORT = 6379 #redis
BROKER_USER = "guest"
BROKER_PASSWORD = "guest"
BROKER_VHOST = "/"

并运行它：

python manage.py celeryd -l DEBUG
[...]
[2011-06-18 10:31:37,913: DEBUG/MainProcess] Starting thread Timer...
[2011-06-18 10:31:37,914: DEBUG/MainProcess] Starting thread Consumer... 
[2011-06-18 10:31:37,914: WARNING/MainProcess] celery@greg... has started.
[2011-06-18 10:31:37,914: DEBUG/MainProcess] Consumer: Re-establishing connection to the broker...

我的示例任务如下所示：

from celery.decorators import task
@task()
def add(x, y):
    return x + y

现在我尝试在 shell 中运行它：

In [3]: from message.tasks import add
In [4]: r=add.delay(2, 5)    

它等待很长时间并呈现 Traceback http://dpaste.com/555939/。它可以是什么？也许我错过了什么？

Answer 1

缺少 BROKER_BACKEND 设置。以下是使用 Redis 的示例配置：

import djcelery
djcelery.setup_loader()

CELERY_RESULT_BACKEND = 'database'

BROKER_BACKEND = 'redis'
BROKER_HOST = 'localhost'
BROKER_PORT = 6379
BROKER_VHOST = '1'

Answer 2

不知道这是什么，但我知道 RabbitMQ 是 Celery 和 Django 的推荐代理。我让它运行起来，它就像一个魅力。为什么不尝试一下呢？