Method stream_generator

core/storage.py:1165–1180

()

                pass
            
            async def stream_generator():
                try:
                    async with session.get(url) as resp:
                        if resp.status != 200:
                            raise HTTPException(
                                status_code=resp.status,
                                detail=f"文件获取失败{resp.status}: {await resp.text()}",
                            )
                        chunk_size = 65536
                        while True:
                            chunk = await resp.content.read(chunk_size)
                            if not chunk:
                                break
                            yield chunk
                finally:
                    await session.close()
            
            encoded_filename = quote(filename, safe='')
            headers = {