芹菜无法连接到rabbitmq - 收到意外的方法答案

【问题标题】：celery can't connect to rabbitmq - unexpected method received芹菜无法连接到rabbitmq - 收到意外的方法
【发布时间】：2014-11-06 18:31:53
【问题描述】：

我正在尝试让我的 celery 守护程序在 rackspace 上的 Ubuntu 机器上运行，但我无法将 celery 与 rabbitmq 连接起来。在我的 Mac 上，使用默认的 rabbitmq 设置（BROKER_URL = 'amqp://'）一切正常，但在生产服务器上，我无法让 celery 与 rabbitmq 对话。

这就是我所做的：

$ sudo rabbitmqctl add_user celeryuser celerypassword
$ sudo rabbitmqctl add_vhost celeryhost
$ sudo rabbitmqctl set_permissions -p celeryhost celeryuser ".*" ".*" ".*"

遵循here的指示

在celeryconfig.py 中，我使用上面的配置定义了代理 url

BROKER_URL = 'amqp://celeryuser:celerypassword@localhost:5672/celeryhost'

并在celery_app.py 中加载上述配置：

app.config_from_object('proj.celeryconfig')

但是，当我尝试使用以下方式启动 celery worker 时：

celery worker --app=proj.celery_app

我收到以下错误：

-------------- celery@app1 v3.1.13 (Cipater)
---- **** ----- 
--- * ***  * -- Linux-2.6.32-64-server-x86_64-with-Ubuntu-10.04-lucid
-- * - **** --- 
- ** ---------- [config]
- ** ---------- .> app:         proj:0x29e9850
- ** ---------- .> transport:   amqp://celeryuser:**@localhost:5672/celeryhost
- ** ---------- .> results:     amqp
- *** --- * --- .> concurrency: 4 (prefork)
-- ******* ---- 
--- ***** ----- [queues]
-------------- .> celery           exchange=celery(direct) key=celery


[2014-09-12 09:28:00,266: ERROR/MainProcess] consumer: Cannot connect to amqp://celeryuser:**@localhost:5672/celeryhost: Couldn't log in: unexpected method received.
Trying again in 2.00 seconds...

我检查了rabbitmq服务器是否正在运行：

$ sudo rabbitmqctl status

结果是：

Status of node rabbit@app1 ...
[{running_applications,[{rabbit,"RabbitMQ","1.7.2"},
                        {mnesia,"MNESIA  CXC 138 12","4.4.12"},
                        {os_mon,"CPO  CXC 138 46","2.2.4"},
                        {sasl,"SASL  CXC 138 11","2.1.8"},
                        {stdlib,"ERTS  CXC 138 10","1.16.4"},
                        {kernel,"ERTS  CXC 138 10","2.13.4"}]},
 {nodes,[rabbit@app1]},
 {running_nodes,[rabbit@app1]}]
...done.

【问题讨论】：

标签： rabbitmq celery

【解决方案1】：

发生这种情况是因为 ubuntu 服务器安装了旧版本的 rabbitmq，然后我在我的开发机器上安装了。

当我查看 rabbitmq worker 的状态时我意识到.. 版本说明：

{rabbit,"RabbitMQ","1.7.2"},

但在我的本地我有

{rabbit,"RabbitMQ","3.3.4"},

我在ubuntu上更新了rabbitmq服务器的版本，并设置了和上面一样的权限，以this帖子为指导

现在我可以在生产机器上成功启动 celery worker。

【讨论】：