1

“rabbitmqctl list_connections”显示为正在运行，但在连接选项卡的 UI 上，在客户端属性下，我看到“connection.blocked: true”。

我可以看到消息在 RabbitMq 中排队，并且连接处于空闲状态。

我正在用 Celery 运行 Airflow。我的工作根本没有执行。

这是作业没有执行的原因吗？

如何解决问题以便我的作业开始运行

4

1 回答 1

0

我只使用芹菜就遇到了同样的问题。

似乎当您在队列中有很多消息，并且这些消息相当大，并且您的节点内存变高时，rabbitMQ 内存水印被侵入，这会触发消费者连接的阻塞，因此没有工作人员可以访问该节点（和相关的队列）。

与此同时，出版商很乐意通过交易所发送东西，所以你会陷入双输的局面。

我们唯一的解决方案是避免达到内存水印并增加消费者的数量。保持消息/任务精简，以便签名不是 MB 而是 KB

于 2019-01-17T09:48:38.983 回答