Bagaimanakah httpx Boleh Meningkatkan Permintaan HTTP Hilir yang Selamat dan Cekap dalam FastAPI?

Membuat Permintaan HTTP Hilir dengan Selamat dalam FastAPI Menggunakan httpx

Apabila membuat permintaan HTTP dalam FastAPI menggunakan perpustakaan permintaan Python standard, keselamatan thread menjadi kebimbangan di tengah-tengah permintaan serentak. Untuk menangani isu ini dengan berkesan, pertimbangkan untuk menggunakan httpx, perpustakaan yang menawarkan keselamatan rangkaian dan prestasi yang dipertingkatkan.

Menggunakan httpx Async API

httpx disertakan dengan API tak segerak, membolehkan anda membuat dengan mudah Permintaan HTTP sambil mengendalikan berbilang tugas serentak dengan cekap. Berikut ialah contoh penggunaannya dalam titik akhir FastAPI:

from httpx import AsyncClient
from fastapi import FastAPI, Request

app = FastAPI()

@app.on_event("startup")
async def startup_event():
    app.state.client = AsyncClient()

@app.on_event('shutdown')
async def shutdown_event():
    await app.state.client.aclose()

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

Dalam contoh ini:

• startup_event() memulakan dan menyimpan httpx AsyncClient kongsi dalam keadaan apl.
• shutdown_event() menutup klien dengan anggun selepas permohonan penutupan.
• home() melaksanakan permintaan HTTP ke https://www.example.com menggunakan klien kongsi, menggunakan penstriman untuk mengendalikan respons besar dengan cekap.

Menggunakan httpx Synchronous API

Jika mentakrifkan titik akhir dengan async def tidak diingini, memilih API segerak httpx menjadi perlu. Pendekatan ini mengekalkan keselamatan rangkaian dan memudahkan pelaksanaan titik akhir:

from httpx import Client
from fastapi import FastAPI, Request

app = FastAPI()

@app.on_event("startup")
def startup_event():
    app.state.client = Client()

@app.on_event('shutdown')
async def shutdown_event():
    await app.state.client.aclose()

@app.get('/')
def home(request: Request):
    client = request.state.client
    req = client.build_request('GET', 'https://www.example.com')
    try:
        r = client.send(req)
        content_type = r.headers.get('content-type')
    except Exception as e:
        content_type = 'text/plain'
        e = str(e)

    if content_type == 'application/json':
        return r.json()
    elif content_type == 'text/plain':
        return PlainTextResponse(content=r.text)
    else:
        return Response(content=r.content)

Dalam contoh ini, API segerak mengendalikan permintaan HTTP dalam blok cuba/kecuali, membenarkan pengendalian yang anggun bagi sebarang pengecualian yang mungkin timbul semasa permintaan.

Ciri Tambahan dan Pertimbangan

• Faedah Async API: Async API memberikan prestasi unggul dan skala yang lebih cekap dengan permintaan serentak.
• Respons Penstriman: Gunakan penstriman respons apabila berurusan dengan sejumlah besar data dalam permintaan atau respons.
• Mengawal Kolam Sambungan: Anda boleh mengoptimumkan penggunaan kumpulan sambungan dengan menetapkan hujah had semasa mencipta klien httpx.
• Keselamatan Benang: httpx direka bentuk untuk selamat benang, memastikan pelaksanaan yang boleh dipercayai merentas pelbagai benang.

Dengan memanfaatkan httpx dan cirinya, anda dengan yakin boleh membuat permintaan HTTP hiliran dalam FastAPI, mengendalikan berbilang tugas serentak dengan lancar dan memastikan kestabilan aplikasi.

Atas ialah kandungan terperinci Bagaimanakah httpx Boleh Meningkatkan Permintaan HTTP Hilir yang Selamat dan Cekap dalam FastAPI?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!