Django celery : Consumer Connection Error (111) when running python manage. py celeryd

标签 django celery

我正在尝试配置一个 Django 项目以使用 Celery(我在 Debian Squeeze 上使用 Django 1.3)

我安装了 django-celery (2.3.3) 然后跟着 these instructions .

我的 Django celery 设置如下:

BROKER_HOST = "localhost"
BROKER_PORT = 5672
BROKER_USER = "guest"
BROKER_PASSWORD = "guest"
BROKER_VHOST = "/"

当我尝试使用...启动 celery 工作服务器时
$ python manage.py celeryd -l info

我得到以下输出,其中带有“ 消费者:连接错误:[Errno 111] ”:
/home/thomas/virtualenv/ULYSSE/lib/python2.6/site-packages/djcelery/loaders.py:84:     UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in production environments!
warnings.warn("Using settings.DEBUG leads to a memory leak, never "
[2011-09-20 12:14:00,645: WARNING/MainProcess]  

-------------- celery@debian v2.3.3
---- **** -----
--- * ***  * -- [Configuration]
-- * - **** ---   . broker:      amqp://guest@localhost:5672//
- ** ----------   . loader:      djcelery.loaders.DjangoLoader
- ** ----------   . logfile:     [stderr]@INFO
- ** ----------   . concurrency: 1
- ** ----------   . events:      OFF
- *** --- * ---   . beat:        OFF
-- ******* ----
--- ***** ----- [Queues]
--------------   . celery:      exchange:celery (direct) binding:celery


[Tasks]
  . competitions.tasks.add

[2011-09-20 12:14:00,788: INFO/PoolWorker-1] child process calling self.run()
[2011-09-20 12:14:00,795: WARNING/MainProcess] celery@debian has started.
[2011-09-20 12:14:00,809: ERROR/MainProcess] **Consumer: Connection Error: [Errno 111]          Connection refused. Trying again in 2 seconds**...

显然,我的设置被正确读取(参见输出中的配置部分)并且工作进程已正确启动(“celery@debian 已启动”)

我不明白为什么这个“消费者:连接错误:[Errno 111]”错误附加......

这与 BROKER_USER 和 BROKER_PASSWORD 设置有关吗?

我尝试了不同的用户/密码设置(我的帐户、root 帐户...),但我总是遇到相同的错误。 'BROKER_USER' 和 'BROKER_PASSWORD 是否指的是操作系统用户、数据库用户、“经纪人”用户?

我怎样才能摆脱这个连接错误?

最佳答案

看起来rabbitmq 没有安装或运行。你能检查一下吗?

apt-get install rabbitmq-server 

在 Ubuntu 上

关于Django celery : Consumer Connection Error (111) when running python manage. py celeryd,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/7483728/

相关文章:

python - 如何在 Django 中动态组合 OR 查询过滤器?

python - 我的virtualenv是不是没有考虑到? [apache、mod_wsgi 和 django]

python - Django - 如何将异步任务队列与 celery 和 redis 一起使用

python - Django Celery 任务记录

python - 如何测量 Celery 任务持续时间

django - 如何让 django-allauth 发送 html 电子邮件

python - Django - 重定向到带有 www 的版本

python - 在 Django 查询中使用 .extra(select={...}) 引入的值上使用 .aggregate()?

django - Celeryd 似乎找不到我的 Django 项目的设置

rabbitmq - Airflow Scheduler 和 Web 服务器在对 RabbitMQ 上运行的任务进行排队时挂起