芹菜心跳不工作

Question

我在芹菜设置中设置了心跳：

BROKER_HEARTBEAT = 10

我还在 RabbitMQ 配置中设置了这个配置值：

'heartbeat' => '10',

但不知何故心跳仍然被禁用：

ubuntu@sync1:~$ sudo rabbitmqctl list_connections name timeout
Listing connections ...
some_address:37781 -> other_address:5672    0
some_address:37782 -> other_address:5672    0
...done.

任何想法我做错了什么？

更新：

所以现在我得到：

ubuntu@sync1:/etc/puppet$ sudo rabbitmqctl list_connections name timeout
Listing connections ...
some_address:41281 -> other_address:5672    10
some_address:41282 -> other_address:5672    10
some_address:41562 -> other_address:5672    0
some_address:41563 -> other_address:5672    0
some_address:41564 -> other_address:5672    0
some_address:41565 -> other_address:5672    0
some_address:41566 -> other_address:5672    0
some_address:41567 -> other_address:5672    0
some_address:41568 -> other_address:5672    0
...done.

我有3台服务器：

• RabbitMQ 代理
• RESTful API 服务器
• 远程工作者服务器

看起来远程妖魔化的 Celery 工人正确地发送了心跳。使用 Celery 远程处理任务的 RESTful API 服务器由于某种原因没有使用心跳。

Answer 1

celery worker 的心跳是应用层的心跳，不是 AMQP 协议的心跳。每个worker周期性地向BROKER中的“celeryev”事件交换发送心跳事件消息。心跳事件被转发回worker，这样worker就可以知道BROKER的健康状态。如果丢失心跳次数超过阈值，worker 可以对 BROKER 执行一些重新连接操作。

有关其余详细信息，您可以查看此页面 部分：BROKER_FAILOVER_STRATEGY 描述了您可以为从 BROKER 中删除而执行的操作。