从 celery 工作线程到 prometheus 的自定义指标

Question

我有一些 celery 工作人员在 kubernetes 下的容器中运行。它们不会由 celery 自动缩放，并且每个都在单个进程中运行（即没有多处理）。我想从他们那里得到一堆不同的指标到普罗米修斯中。我研究过 celery-prometheus-exporter （未维护）和 celery-exporter，但它们专注于 celery 级别的指标，而不是 celery 工作人员内部的应用程序指标。

看起来有两个选择，要么找到一些hacky方法将应用程序级别的指标获取到celery-prometheus-exporter，然后使它们可供prometheus使用，要么使用

pushgateway

。

哪个更好，或者也许我错过了另一个选择？

Answer 1

只需使用默认客户端并让它在线程中运行http服务器。

Answer 2

我也面临着类似的问题。我想根据队列中消息的等待时间来扩展我的工作人员。有没有办法做到这一点。 我创建了一个带有flower的UI，可以看到平均负载，但不知道它是工作级别还是系统级别。

如果有人能提供帮助那就太好了。