2

根据芹菜文档

librabbitmq

如果您使用 RabbitMQ (AMQP) 作为代理,那么您可以安装 librabbitmq 模块以使用用 C 编写的优化客户端:

$ pip install librabbitmq

'amqp' 传输将自动使用 librabbitmq 模块(如果已安装),或者您也可以使用 pyamqp:// 或 librabbitmq:// 前缀直接指定所需的传输。

我安装librabbitmq并更改了BROKER_URL设置,使其以librabbitmq://.

我如何验证 Celery 现在正在使用 librabbitmq(即我做的一切正确)?

4

1 回答 1

0
  1. 卸载 librabbitmq。
  2. 确保BROKER_URLlibrabbitmq://.
  3. 尝试用 celery 做一些事情(例如,python manage.py celery worker如果使用djcelery)。
  4. 该命令将失败并显示ImportError: No module named librabbitmq.
  5. 重新安装 librabbitmq。
  6. 重复步骤 3。
  7. 该命令现在应该可以正常工作了。

这不是 100% 的结论,但确实可以很好地表明 celery 正在使用 librabbitmq。

于 2014-11-20T16:48:57.183 回答