检测断开连接#

如果您在路由或 WebSocket 处理程序(或从其中调用的代码)中正在等待,并且客户端断开连接,则等待将引发 CancelledError。这可用于检测客户端何时断开连接,以允许进行清理,例如来自 broadcast_tutorial 的 sse 处理程序使用它在断开连接时移除客户端,

@app.route('/sse')
async def sse():
    queue = asyncio.Queue()
    app.clients.add(queue)
    async def send_events():
        while True:
            try:
                data = await queue.get()
                event = ServerSentEvent(data)
                yield event.encode()
            except asyncio.CancelledError:
                app.clients.remove(queue)

或者仅包含相关部分,

@app.route('/sse')
async def sse():
    try:
        await ...
    except asyncio.CancelledError:
        # Has disconnected

同样适用于 WebSockets、流式请求等…