python - Flower 没有显示 celery 的所有 worker

Question

我在两台服务器上运行 celery，其中一台 redis 作为代理。

Celery 启动命令如下所示:

celery multi start 2 -A app_name

花启动命令:

celery flower -A app_name --address=10.41.31.210 --port=5555

在 flower 的输出中有一些警告:

WARNING:flower.api.control:'stats' inspect method failed
WARNING:flower.api.control:'active_queues' inspect method failed
WARNING:flower.api.control:'registered' inspect method failed
WARNING:flower.api.control:'scheduled' inspect method failed
WARNING:flower.api.control:'active' inspect method failed
WARNING:flower.api.control:'reserved' inspect method failed
WARNING:flower.api.control:'revoked' inspect method failed
WARNING:flower.api.control:'conf' inspect method failed

对我来说最奇怪的是——并不是所有的 worker 都显示在 Flower 的仪表板上。似乎每次花重新启动后只显示一些 worker 。由于我的启动脚本 - 应该至少有 8 个 worker ，但我看到 4 个或有时 6 个。

寻找任何解决方案或建议。谢谢。

P.s 当只有一台服务器用于 celery workers 时，我对相同的服务没有任何问题。

Answer 1

这里的问题是，在 celery 准备好之前开花

这可以通过 celery inspect ping 轻松检查

这是我的项目 start_flower.sh

的示例

#!/bin/sh

until timeout -t 10 celery -A project inspect ping; do
    >&2 echo "Celery workers not available"
done

echo 'Starting flower'
celery -A project flower