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中文網其他相關文章！
