동시 FastAPI/Uvicorn 애플리케이션에서 다운스트림 HTTP 요청을 할 때 `H11._util.LocalProtocolError`를 방지하려면 어떻게 해야 합니까?

Uvicorn/FastAPI에서 다운스트림 HTTP 요청 처리

FastAPI/Uvicorn을 사용하여 API 엔드포인트를 구축할 때 다운스트림 HTTP 요청을 만드는 것이 일반적입니다. 그러나 여러 동시 요청을 처리할 때 개발자는 오류가 발생할 수 있습니다.

H11._util.LocalProtocolError: can't handle event type ConnectionClosed when role=SERVER and state=SEND_RESPONSE

이 오류는 FastAPI의 기본 요청 세션이 스레드로부터 완전히 안전하지 않기 때문에 발생합니다. 이 문제를 극복하려면 대체 접근 방식을 채택해야 합니다.

비동기 HTTP 요청에 Httpx 사용

한 가지 해결책은 비동기 HTTP 요청을 제공하는 httpx 라이브러리를 사용하는 것입니다. API. request.Session() 대신 httpx.AsyncClient()를 사용할 수 있습니다. 이 클라이언트는 기본 TCP 연결이 재사용되므로 동일한 호스트에 대한 동시 요청을 허용합니다.

FastAPI에서는 시작 시 AsyncClient를 초기화하고 종료 시 닫도록 수명 핸들러를 정의할 수 있습니다. 예를 들면 다음과 같습니다.

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

엔드포인트에서는 request.state.client를 사용하여 클라이언트에 액세스할 수 있습니다. 다음과 같이 다운스트림 요청을 할 수 있습니다.

@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))

스트리밍 및 비스트리밍 응답

다운스트림 응답을 다양한 방법으로 클라이언트에 보낼 수 있습니다. 응답을 스트리밍하려면 생성기를 사용하여 응답 데이터를 비동기적으로 반복하는 StreamingResponse를 만들 수 있습니다. 그렇지 않으면 r.json(), PlainTextResponse 또는 사용자 정의 응답을 사용할 수 있습니다.

Httpx 사용의 이점

httpx를 사용하면 다음과 같은 여러 가지 이점이 있습니다.

• 동시 요청을 효율적으로 처리하기 위한 비동기 API.
• 지속적 성능 향상을 위한 연결 풀
• 연결 풀 크기 제어
• FastAPI의 수명 처리기 및 엔드포인트와 쉽게 통합됩니다.

httpx를 활용하여 개발자는 효과적으로 스레드 안전 문제가 발생하지 않고 FastAPI/Uvicorn 애플리케이션 내의 다운스트림 HTTP 요청. 이는 안정적이고 확장 가능한 API 동작을 보장합니다.

위 내용은 동시 FastAPI/Uvicorn 애플리케이션에서 다운스트림 HTTP 요청을 할 때 `H11._util.LocalProtocolError`를 방지하려면 어떻게 해야 합니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!