이제 SSE를 설정합니다. SSE는 서버에서 클라이언트로 실시간 데이터를 전달하기 위한 통신 방식입니다. 이때 /messages/는 메시지를 받을 기본 URL 경로입니다.
코드
sse = SseServerTransport("/messages/")
다음은 SSE 요청 처리 함수입니다. 클라이언트가 /sse로 연결하면 이 함수가 호출됩니다. 즉, SSE 기반으로 MCP 요청/응답이 오가는 통로 역할을 한다고 이해하면 됩니다.
코드
async def handle_sse(request: Request) -> None: async with sse.connect_sse(...) as (read_stream, write_stream): await mcp._mcp_server.run(read_stream, write_stream, ...)