handlers.py 文件源码

def status(request: web.Request):
    stat = {
        'queues': {
            n: {
                'length': len(replication.get_queue_for_node(n))
            } for n in replication.get_nodes()
            }
    }
    return web.Response(text=json.dumps(stat), headers={
        'Content-Type': 'application/json'
    })