使用celery stats（）时因对等错误重置连接

Question

我想为我的芹菜Que（Rabbitmq）获取统计数据。我正在使用celery.app.control.检查（）. stats（）API。我在网络服务器上做这件事，我只能得到一次统计数据。如果我刷新页面，我得到[Errno 104]连接重置由对等错误。我怎么能处理这个。

/初始化。派克

celtasks = Celery(app.name,"rabbit mq url")

/帮手。派克

get_stats():
     stats = celtasks.control.Inspect().stats()
     return stats

每当有请求"get_stats"功能被命中。它只适用于在此之后的第一个请求，它说通过对等错误重置连接。

如果我去连接已被重置，并尝试再次创建连接，我得到错误

更新/helpers.py

 get_stats():
     celtasks = Celery(app.name,"rabbit mq url")
     stats = celtasks.control.Inspect().stats()
     return stats

Rabbitmq日志

=WARNING REPORT==== 10-Jul-2017::14:11:54 ===
closing AMQP connection <0.29185.6> (10.246.170.70:48618 -> 10.24.83.115:5672):
connection_closed_abruptly

=WARNING REPORT==== 10-Jul-2017::14:11:54 ===
closing AMQP connection <0.29197.6> (10.246.170.70:48620 -> 10.24.83.115:5672):
connection_closed_abruptly
"[e-mail]-20170625" 9054L, 361662C

Answer 1

在大多数情况下，对等机重置连接是因为服务器本身关闭了连接，但客户端不知道。当客户端希望通过断开的连接与服务器通信时，它会收到此错误。在您的情况下，可能挂起时间（两个stats（）之间的时间间隔）太长，服务器认为此连接无效，请关闭它。