asyncio.gather()更适合批量下载,它并发启动所有任务并统一等待完成,支持return_exceptions=true捕获单个失败而不中断整体;而create_task()需手动管理task列表,否则易因主协程结束导致未完成下载被静默取消。

asyncio.create_task() 和 asyncio.gather() 哪个更适合批量下载?
直接用 asyncio.gather() 更稳妥。它会并发启动所有任务并统一等待完成,而手动调用 asyncio.create_task() 后若不显式 await 或管理 task 列表,容易漏掉异常或提前退出。
常见错误是把 create_task() 当成“后台线程”用,结果主协程结束、事件循环关闭,未完成的下载被静默取消 —— 这在下载大图时特别明显。
-
asyncio.gather(*tasks, return_exceptions=True)能捕获单个失败而不中断其他请求 - 避免在循环里反复
await asyncio.create_task(...),这其实是串行执行 - 如果需控制并发数(比如限制同时最多 10 个连接),得配合
asyncio.Semaphore,不能只靠gather
用 aiohttp 下载图片时如何正确处理响应流和文件写入?
高清图片体积大,直接用 response.text() 或 response.read() 会把整张图加载进内存,可能触发 MemoryError。必须用流式读取 + 异步写入。
关键点在于:不要用内置 open(),它会阻塞事件循环;必须用 aiofiles 或 asyncio.to_thread()(Python 3.9+)做非阻塞写入。
- 推荐用
aiofiles.open(path, "wb")配合async for chunk in response.content.iter_chunked(8192) - 别忽略
response.raise_for_status(),否则 404、403 等状态码不会抛异常 - 设置
timeout(如aiohttp.ClientTimeout(total=30)),防止某张图卡死整个批次
为什么下载高清图经常遇到 “ClientOSError: [Errno 24] Too many open files”?
这是系统级限制被突破的典型表现:每个 TCP 连接、每个打开的文件句柄都算一个 file descriptor。aiohttp 默认复用连接,但并发数过高 + 图片多 + 写入慢,仍会快速耗尽。
根本解法不是调高 ulimit,而是从代码层控流:
- 用
asyncio.Semaphore(5)限制同时活跃的下载任务数(5 是保守值,可按机器网络和磁盘调整) - 给
aiohttp.TCPConnector设置limit=10和limit_per_host=5,避免单域名压垮连接池 - 确保每次下载后显式
await f.close()(aiofiles对象)或使用async with上下文
保存路径含中文或特殊字符时要注意什么?
URL 解析出的文件名若含 %xx 编码、斜杠、空格或 Unicode 字符,直接拼接路径会导致 FileNotFoundError 或写入失败。
别依赖 urllib.parse.unquote() 后直接用 —— 它不清理非法路径字符。必须做白名单过滤或标准化。
- 用
pathlib.Path(filename).name提取基础名,再用正则替换非安全字符(如re.sub(r"[^a-zA-Z0-9_\u4e00-\u9fa5.-]", "_", name)) - 保存前检查目录是否存在:
await aiofiles.os.makedirs(parent_dir, exist_ok=True) - 避免用
os.path.join(),改用pathlib.Path(dir) / safe_name,更可靠且跨平台
Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!











