我开始使用芹菜,遵循"芹菜的第一步".我完全使用了该链接上指示的tasks.py.但是当我运行任务时,
celery -A tasks worker --loglevel=info
我收到此错误:
[2014-09-16 20:52:57,427: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: Socket closed. Trying again in 2.00 seconds...
rabbitmq服务器肯定在运行,而下面是关于错误的日志片段:
=ERROR REPORT==== 16-Sep-2014::20:53:09 === exception on TCP connection <0.235.0> from 127.0.0.1:58162 {channel0_error,starting, {amqp_error,access_refused, "AMQPLAIN login refused: user 'guest' - invalid credentials", 'connection.start_ok'}} =INFO REPORT==== 16-Sep-2014::20:53:09 === closing TCP connection <0.235.0> from 127.0.0.1:58162 =INFO REPORT==== 16-Sep-2014::20:53:15 === accepted TCP connection on [::]:5672 from 127.0.0.1:58163 =INFO REPORT==== 16-Sep-2014::20:53:15 === starting TCP connection <0.239.0> from 127.0.0.1:58163 =ERROR REPORT==== 16-Sep-2014::20:53:18 === exception on TCP connection <0.239.0> from 127.0.0.1:58163 {channel0_error,starting, {amqp_error,access_refused, "AMQPLAIN login refused: user 'guest' - invalid credentials", 'connection.start_ok'}} =INFO REPORT==== 16-Sep-2014::20:53:18 === closing TCP connection <0.239.0> from 127.0.0.1:58163
有了这个,我做了以下工作以确保'guest'用户拥有/ vhost的权限:
sudo rabbitmqctl set_permissions -p / guest ".*" ".*" ".*"
然后我重新加载/重新启动rabbitmq服务以确保更改生效,然后再次运行任务.但是,错误仍然是相同的.
我甚至尝试创建一个不同的vhost(jm-vhost)和用户(jm-user1)并再次设置权限以允许所有:
sudo rabbitmqctl add_vhost jm-vhost sudo rabbitmqctl add_user jm-user1 "" --> "" to make it passwordless (is this correct?) sudo rabbitmqctl set_permissions -p /jm-vhost jm-user1 ".*" ".*" ".*"
然后将tasks.py修改为:
app = Celery('tasks', broker='amqp://jm-user1@localhost//jm-vhost')
但是当我开始完成任务时,我仍然得到同样的错误.我该如何解决这个问题?提前致谢!