检测celery是否可用/正在运行

Question

我正在使用Celery管理异步任务。但是，有时候，芹菜加工过程会停止，这不会导致任何任务被执行。我希望能够检查芹菜的状态，并确保一切正常，如果我发现任何问题，请向用户显示错误消息。从Celery
Worker文档中看来，我可能可以使用ping或inspect进行此操作，但是ping感觉很笨拙，并且不清楚要使用的检查方式是否确切（如果inspect（）。registered（）为空？）。

任何对此的指导将不胜感激。基本上我正在寻找的是这样的方法：

def celery_is_alive():
    from celery.task.control import inspect
    return bool(inspect().registered()) # is this right??

编辑：它甚至看起来都不像celery 2.3.3上提供了registered（）（即使2.1文档列出了它）。也许ping是正确的答案。

编辑：Ping似乎也没有做我想做的事情，因此仍然不确定此处的答案。

Answer 1

这是我一直在使用的代码。
celery.task.control.Inspect.stats()返回一个字典，其中包含有关当前可用工作程序的许多详细信息；如果没有工作程序在运行，则返回None；如果IOError无法连接到消息代理，则引发dict
。我正在使用RabbitMQ-其他消息传递系统的行为可能会略有不同。这在Celery 2.3.x和2.4.x中有效；我不确定它能走多远。

def get_celery_worker_status():
    ERROR_KEY = "ERROR"
    try:
        from celery.task.control import inspect
        insp = inspect()
        d = insp.stats()
        if not d:
            d = { ERROR_KEY: 'No running Celery workers were found.' }
    except IOError as e:
        from errno import errorcode
        msg = "Error connecting to the backend: " + str(e)
        if len(e.args) > 0 and errorcode.get(e.args[0]) == 'ECONNREFUSED':
            msg += ' Check that the RabbitMQ server is running.'
        d = { ERROR_KEY: msg }
    except ImportError as e:
        d = { ERROR_KEY: str(e)}
    return d