Bagaimanakah Saya Boleh Mengelak `H11._util.LocalProtocolError` Apabila Membuat Permintaan HTTP Hilir dalam Aplikasi FastAPI/Uvicorn Serentak?

Mengendalikan Permintaan HTTP Hilir dalam Uvicorn/FastAPI

Apabila membina titik akhir API menggunakan FastAPI/Uvicorn, adalah perkara biasa untuk membuat permintaan HTTP hiliran. Walau bagaimanapun, apabila mengendalikan berbilang permintaan serentak, pembangun mungkin menghadapi ralat:

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

Ralat ini berlaku kerana sesi permintaan lalai FastAPI tidak selamat untuk benang sepenuhnya. Untuk mengatasi cabaran ini, kita perlu menggunakan pendekatan alternatif.

Menggunakan Httpx untuk Permintaan HTTP Tak Segerak

Satu penyelesaian ialah menggunakan perpustakaan httpx, yang menyediakan penyegerakan API. Daripada requests.Session(), kita boleh menggunakan httpx.AsyncClient(). Pelanggan ini membenarkan permintaan serentak kepada hos yang sama, kerana sambungan TCP asas digunakan semula.

Dalam FastAPI, kami boleh menentukan pengendali jangka hayat kami untuk memulakan AsyncClient semasa dimulakan dan menutupnya apabila ditutup. Contohnya:

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

Di titik akhir kami, kami boleh mengakses klien menggunakan request.state.client. Kami boleh membuat permintaan hiliran seperti berikut:

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

Respons Penstriman lwn. Bukan Penstrim

Kami boleh menghantar respons hiliran kepada pelanggan dengan cara yang berbeza. Jika kami ingin menstrimkan respons, kami boleh mencipta StreamingResponse yang menggunakan penjana untuk menggelung secara tak segerak melalui data respons. Jika tidak, kita boleh menggunakan r.json(), PlainTextResponse atau Respons tersuai.

Faedah menggunakan Httpx

Menggunakan httpx menawarkan beberapa faedah:

• Async Async untuk pengendalian serentak yang cekap permintaan.
• Kumpulan sambungan berterusan untuk prestasi yang dipertingkatkan.
• Kawalan ke atas saiz kumpulan sambungan.
• Penyatuan mudah dengan pengendali jangka hayat dan titik akhir FastAPI.

Dengan memanfaatkan httpx, pembangun boleh membuat permintaan HTTP hiliran dengan berkesan dalam mereka Aplikasi FastAPI/Uvicorn tanpa menghadapi masalah keselamatan benang. Ini memastikan gelagat API yang boleh dipercayai dan berskala.

Atas ialah kandungan terperinci Bagaimanakah Saya Boleh Mengelak `H11._util.LocalProtocolError` Apabila Membuat Permintaan HTTP Hilir dalam Aplikasi FastAPI/Uvicorn Serentak?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!