Mengapakah StreamingResponse FastAPI Tidak Menstrim dengan Fungsi Penjana?

FastAPI StreamingResponse Tidak Menstrim dengan Fungsi Penjana

StreamingResponse FastAPI bertujuan untuk menstrim data kembali kepada pelanggan apabila ia tersedia. Walau bagaimanapun, terdapat laporan StreamingResponse tidak berfungsi seperti yang diharapkan apabila menggunakan fungsi penjana. Artikel ini akan menyiasat kemungkinan punca isu ini dan menyediakan penyelesaian.

Operasi Menyekat dan Fungsi Penjana

Fungsi penjana dalam Python boleh mentakrifkan jujukan nilai yang membuahkan hasil satu persatu. Walau bagaimanapun, jika operasi menyekat (seperti time.sleep()) dilakukan dalam fungsi penjana, ia boleh menyekat gelung peristiwa, menghalang FastAPI daripada menstrim data kepada klien.

Def vs. Async Def

FastAPI mengendalikan StreamingResponse secara berbeza berdasarkan sama ada fungsi penjana menggunakan sintaks def atau async def. Jika fungsi penjana ditakrifkan menggunakan sintaks async def, FastAPI menganggap ia adalah penjana tak segerak dan melaksanakannya dalam kumpulan benang atau kumpulan tugas. Walau bagaimanapun, jika fungsi penjana menggunakan sintaks def, FastAPI mengiktirafnya sebagai penjana menyekat dan menggunakan iterate_in_threadpool() untuk menjalankannya dalam urutan yang berasingan.

Pendekatan Disyorkan

Untuk mengelakkan operasi menyekat dan memastikan penstriman yang betul, adalah disyorkan untuk menggunakan fungsi penjana tak segerak (async def). Jika perlu, sebarang operasi menyekat hendaklah dilakukan dalam kumpulan benang luaran dan menunggu untuk mengelakkan gangguan gelung acara.

Jenis Media Respons

Dalam sesetengah kes, penyemak imbas mungkin teks penimbal/tindak balas biasa untuk menyemak jenis MIME. Untuk mengelakkan ini, anda dinasihatkan untuk menentukan jenis media yang berbeza, seperti teks/strim-acara, aplikasi/json, atau tetapkan pengepala X-Content-Type-Options kepada nosniff.

Contoh

Berikut ialah contoh apl FastAPI yang berfungsi dengan fungsi penjana untuk penstriman data:

from fastapi import FastAPI, StreamingResponse, Request
from fastapi.responses import HTMLResponse
import asyncio

app = FastAPI()

@app.get("/stream")
async def streaming_data(request: Request):
    def generate_data():
        for i in range(10):
            yield b'some fake data\n\n'
            await asyncio.sleep(0.5)
    return StreamingResponse(generate_data(), media_type="text/event-stream")

Kesimpulan

Dengan mengelakkan operasi menyekat, menggunakan fungsi penjana tak segerak dan menentukan jenis media yang sesuai, anda boleh memastikan FastAPI StreamingResponse berfungsi seperti yang dimaksudkan , membolehkan anda menstrim data dengan cekap kepada pelanggan.

Atas ialah kandungan terperinci Mengapakah StreamingResponse FastAPI Tidak Menstrim dengan Fungsi Penjana?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!