FastAPI StreamingResponse 不使用生成器函數進行串流處理
FastAPI 的StreamingResponse 旨在在資料可用時將資料串流回客戶端。但是,有報告指出在使用生成器函數時 StreamingResponse 無法如預期運作。本文將調查此問題的潛在原因並提供解決方案。
阻塞操作和生成器函數
Python 中的生成器函數可以定義一系列值,這些值是一次產生一個。但是,如果在生成器函數內執行阻塞操作(例如 time.sleep()),它可能會阻塞事件循環,從而阻止 FastAPI 將資料串流傳輸到客戶端。
Def 與Async Def
FastAPI 根據生成器函數是否使用 def 或 async def 語法以不同方式處理 StreamingResponse。如果生成器函數是使用 async def 語法定義的,FastAPI 會假定它是一個非同步生成器,並在執行緒池或任務池中執行它。但是,如果生成器函數使用 def 語法,FastAPI 會將其識別為阻塞生成器,並使用 iterate_in_threadpool() 在單獨的執行緒中執行它。
建議方法
為了避免阻塞操作並確保正確的流式傳輸,建議使用非同步產生器函數(async def)。如有必要,任何阻塞操作都應在外部執行緒池中執行並等待,以避免中斷事件循環。
回應媒體類型
在某些情況下,瀏覽器可能會緩衝文字/純文字回應以檢查 MIME 類型。為了防止這種情況,建議指定不同的媒體類型,例如 text/event-stream、application/json,或將 X-Content-Type-Options 標頭設定為 nosniff。
範例
這是一個具有用於串流資料的產生器函數的工作 FastAPI應用程式的範例:
結論
透過避免阻塞操作,使用非同步產生器函數並指定適當的媒體類型,您可以確保FastAPI StreamingResponse 按預期工作,從而使您能夠有效率地將資料串流傳輸到客戶端。
以上是為什麼 FastAPI 的 StreamingResponse 不使用生成器函數進行串流?的詳細內容。更多資訊請關注PHP中文網其他相關文章!