python - 我可以在 FastAPI StreamingResponse 中使用线程吗

Question

我正在使用 FastAPI，其中 api 负责创建 docker 实例。我想将创建 docker 实例的输出流回客户端。

我正在查看将数据发送到客户端的 StreamingResponse 示例，但是，我想从线程中产生数据，以便它流出到响应中。有没有人有什么建议？我只是从 fastapi 网站上查看 StreamingResponse。

async def fake_video_streamer():
    for i in range(2):
        await asyncio.sleep(10)
        yield str.encode(f"some fake video bytes {i}")

@router.post("/")
async def create_build():
    return StreamingResponse(fake_video_streamer())

标签： pythonmultithreadingfastapi