Django 中的 Celery（RabbitMQ 与 Django 数据库）答案

【问题标题】：Celery in Django (RabbitMQ vs. Django Database)Django 中的 Celery（RabbitMQ 与 Django 数据库）
【发布时间】：2011-11-09 12:47:06
【问题描述】：

我正在尝试使用 Celery 设置 Django，以便我可以在后台发送大量电子邮件。

我对 Celery 的不同组件如何发挥作用有点困惑。我需要使用 RabbitMQ 吗？我可以只用“django-kombu”来运行 Celery 吗？ (http://ask.github.com/celery/tutorials/otherqueues.html#django-database)

我从 django-celery 文档 (http://django-celery.readthedocs.org/en/latest/getting-started/first-steps-with-django.html) 中的“使用 Django 的第一步”开始，但是当我进入“运行 celery 工作服务器”时，会发生这种情况：

$ python manage.py celeryd -l info
[2011-09-02 18:35:00,150: WARNING/MainProcess]  

 -------------- celery@Sauls-MacBook.local v2.3.1
---- **** -----
--- * ***  * -- [Configuration]
-- * - **** ---   . broker:      amqplib://guest@localhost:5672/
- ** ----------   . loader:      djcelery.loaders.DjangoLoader
- ** ----------   . logfile:     [stderr]@INFO
- ** ----------   . concurrency: 2
- ** ----------   . events:      OFF
- *** --- * ---   . beat:        OFF
-- ******* ----
--- ***** ----- [Queues]
 --------------   . celery:      exchange:celery (direct) binding:celery


[Tasks]
  . tasks.add

[2011-09-02 18:35:00,213: INFO/PoolWorker-2] child process calling self.run()
[2011-09-02 18:35:00,214: INFO/PoolWorker-1] child process calling self.run()
[2011-09-02 18:35:00,229: WARNING/MainProcess] celery@Sauls-MacBook.local has started.
[2011-09-02 18:35:00,276: ERROR/MainProcess] Consumer: Connection Error: [Errno 61} Connection refused. Trying again in 2 seconds...
[2011-09-02 18:35:02,283: ERROR/MainProcess] Consumer: Connection Error: [Errno 61] Connection refused. Trying again in 4 seconds...

那我得退出进程了……

【问题讨论】：

标签： django rabbitmq celery django-celery celeryd

【解决方案1】：

从您的配置中可以看出，您没有正确设置传输，实际上 celery 正在尝试使用 amqplib 连接到像 Rabbit MQ 这样的代理

broker:      amqplib://guest@localhost:5672/

您应该在 settings.py 中以这种方式设置代理后端：

BROKER_BACKEND = "djkombu.transport.DatabaseTransport"

【讨论】：

感谢您的建议！我会试试这个，让你知道它是怎么回事。