log.py 文件源码

def create_dispatch_stream_log(app):
    @asyncio.coroutine
    def dispatch_stream_log(request):
        vault_id = request.match_info.get('vault_id', None)
        limit = int(request.GET.get('limit', 100))

        ws = web.WebSocketResponse()
        yield from ws_stream_log(request, ws, app, vault_id=vault_id, limit=limit)
        return ws

    return dispatch_stream_log