Uvicorn/FastAPI에서 HTTP 요청 만들기

FastAPI 및 Uvicorn을 사용하여 구축된 HTTP 엔드포인트를 처리할 때 외부 API에서 데이터를 요청하는 것이 일반적입니다. 그러나 여러 동시 요청을 처리하는 경우 "role=SERVER 및 state=SEND_RESPONSE인 경우 이벤트 유형 ConnectionClosed를 처리할 수 없습니다."와 같은 오류가 발생할 수 있습니다. 이는 기본 HTTP 클라이언트 라이브러리 '요청'이 이러한 동시 환경에서 활용될 때 스레드로부터 완전히 안전하지 않기 때문에 발생합니다.

이 문제를 해결하려면 httpx라는 대체 HTTP 클라이언트 라이브러리 구현을 고려하십시오. FastAPI 내에서 스레드 안전 문제를 방지하는 데 도움이 되는 비동기 API를 제공합니다. 아래 예는 FastAPI에서 httpx를 사용하는 방법을 보여줍니다.

from fastapi import FastAPI, Request, BackgroundTask
from fastapi.responses import StreamingResponse, Response
from contextlib import asynccontextmanager
import httpx

@asynccontextmanager
async def lifespan(app: FastAPI):
    async with httpx.AsyncClient() as client:
        yield {'client': client}

app = FastAPI(lifespan=lifespan)

@app.get('/')
async def home(request: Request):
    client = request.state.client
    req = client.build_request('GET', 'https://www.example.com')
    r = await client.send(req, stream=True)
    return StreamingResponse(r.aiter_raw(), background=BackgroundTask(r.aclose())) 

httpx의 비동기 API를 활용하면 스레드 안전성을 유지하면서 FastAPI 내에서 HTTP 요청을 보다 효율적으로 처리할 수 있습니다. 클라이언트 개체의 'limits' 키워드 인수를 사용하여 연결 풀 크기를 추가로 사용자 정의할 수 있습니다.