celery - 监控有或没有花的芹菜队列待处理任务

Question

我正在尝试监视芹菜队列，以便如果队列中没有任务增加，我可以选择产生更多的工人。

我怎么能用或不用Flower（芹菜监控工具）做到这一点

例如：我可以像这样得到所有工人的名单

curl -X GET http://localhost:5555/api/workers

{
    "celery@ip-172-0-0-1": {
        "status": true,
        "queues": [
            "tasks"
        ],
        "running_tasks": 0,
        "completed_tasks": 0,
        "concurrency": 1
    },
    "celery@ip-172-0-0-2": {
        "status": true,
        "queues": [
            "tasks"
        ],
        "running_tasks": 0,
        "completed_tasks": 5,
        "concurrency": 1
    },
    "celery@ip-172-0-0-3": {
        "status": true,
        "queues": [
            "tasks"
        ],
        "running_tasks": 0,
        "completed_tasks": 5,
        "concurrency": 1
    }
}

同样，我需要按队列名称挂起的任务列表，以便我可以在该队列上启动一个工作人员。

感谢您没有对这个问题投反对票。

Answer 1

保留任务在这里没有意义。它只包括收到的部分，但不包括正在运行的部分。

如果使用 RabbitMQ 作为代理，我们可以使用rabbitmq-management来监控队列。celery 文档也提供了一些方法来做同样的事情。