python - Celery - [Errno 111] 使用 delay() 触发 celery 任务时连接被拒绝

Question

我有两个应用程序服务器(都有 django 应用程序)。两者都有 celery worker 在运行。 RabbitMQ 服务器设置在第三个不同的服务器上。

当使用 delay() 通过 shell 从两个应用程序的服务器中的任何一个执行任何测试任务时，它们都可以正常执行。

如果从浏览器(通过 ajax)从 server1 触发相同的任务，它再次正常工作。

但是对于服务器 2(具有与服务器 1 相同的配置和代码)，当从浏览器触发相同的任务时，它会给出 [错误 111] 连接被拒绝的错误。

server1 或 server2 上安装的一些软件包是:

celery 3.1.18
amqp 1.4.9
django 1.8.5

谁能帮我解决这个问题？谢谢!

错误轨迹如下:

File "../lib/python2.7/site-packages/celery/app/task.py" in delay  453.         return self.apply_async(args, kwargs)File "../lib/python2.7/site-packages/celery/app/task.py" in apply_async  559.             **dict(self._get_exec_options(), **options)File "../lib/python2.7/site-packages/celery/app/base.py" in send_task  353.                 reply_to=reply_to or self.oid, **optionsFile "../lib/python2.7/site-packages/celery/app/amqp.py" in publish_task  305.             **kwargsFile "../lib/python2.7/site-packages/kombu/messaging.py" in publish  172.                        routing_key, mandatory, immediate, exchange, declare)File "../lib/python2.7/site-packages/kombu/connection.py" in _ensured  457.                                            interval_max)File "../lib/python2.7/site-packages/kombu/connection.py" in ensure_connection  369.                         interval_start, interval_step, interval_max, callback)File "../lib/python2.7/site-packages/kombu/utils/__init__.py" in retry_over_time  246.             return fun(*args, **kwargs)File "../local/lib/python2.7/site-packages/kombu/connection.py" in connect  237.         return self.connectionFile "../lib/python2.7/site-packages/kombu/connection.py" in connection  742.                 self._connection = self._establish_connection()File "../lib/python2.7/site-packages/kombu/connection.py" in _establish_connection  697.         conn = self.transport.establish_connection()File "../lib/python2.7/site-packages/kombu/transport/pyamqp.py" in establish_connection  116.         conn = self.Connection(**opts)File "../lib/python2.7/site-packages/amqp/connection.py" in __init__  165.         self.transport = self.Transport(host, connect_timeout, ssl)File "../lib/python2.7/site-packages/amqp/connection.py" in Transport  186.         return create_transport(host, connect_timeout, ssl)File "../lib/python2.7/site-packages/amqp/transport.py" in create_transport  299.         return TCPTransport(host, connect_timeout)File "../lib/python2.7/site-packages/amqp/transport.py" in __init__  95.             raise socket.error(last_err)

Answer 1

我想说的是在调用 server2 上的 delay 之前开始添加一些额外的日志记录调用，只是为了确保您的 celery 配置在作为网络服务器运行时是正确的(而不是 manage.py shell 实例)。听起来 gunicorn/uwsgi/apache/magic 的一些启动脚本没有加载正确配置 celery 所需的一些变量。或者它只是在该上下文中以某种方式被覆盖。

真正可怕的方法是在 server2 上以 manage.py runserver 运行你的网络服务器，并在你调用 .delay() 之前将 PDB 放在那里并四处寻找。当你这样做的时候，这并不是你想要向一般互联网开放的东西，但是当所有其他方法都失败时......