Method stream_generator

core/storage.py:349–365

()

            session = aiohttp.ClientSession()
            
            async def stream_generator():
                try:
                    async with session.get(link) as resp:
                        if resp.status != 200:
                            raise HTTPException(
                                status_code=resp.status,
                                detail=f"从S3获取文件失败: {resp.status}"
                            )
                        # 设置块大小（例如64KB）
                        chunk_size = 65536
                        while True:
                            chunk = await resp.content.read(chunk_size)
                            if not chunk:
                                break
                            yield chunk
                finally:
                    await session.close()
            
            from fastapi.responses import StreamingResponse
            encoded_filename = quote(filename, safe='')