当前位置:首页 > 文章列表 > 文章 > python教程 > Python异步写入慢?用aiofiles提升效率

Python异步写入慢?用aiofiles提升效率

2026-04-23 11:35:20 0浏览 收藏
Python的aiofiles库并非为加速磁盘写入而生,它本质是用线程池封装同步文件操作,核心价值在于避免阻塞asyncio事件循环,从而实现文件I/O与其他异步任务(如HTTP请求、数据解析)的高效协同;它只在多任务并发、I/O等待成为瓶颈(如高延迟网络存储、大量混合异步操作)时带来实际收益,盲目用于高频小写或单一大文件拆分反而更慢——真正提升写入性能的关键,在于批量写入、选用高效格式(如Parquet)、系统级调优,而非执着于“异步”表象。

Python异步写入文件慢怎么办_使用aiofiles替代传统open操作

aiofiles 确实能让你的文件写入“看起来”异步,但它本身不加速磁盘 I/O,反而可能更慢——除非你明确知道为什么、在什么场景下用它。

aiofiles.open 本质是线程池封装,不是真异步 I/O

  • Python 标准库的 open() 是同步阻塞调用,会卡住事件循环
  • aiofiles 并没有绕过操作系统限制,而是用 loop.run_in_executor()open()write() 等操作扔进默认线程池(concurrent.futures.ThreadPoolExecutor
  • 所以它解决的是「不阻塞事件循环」的问题,不是「写得更快」的问题

常见误用现象:

  • aiofiles.open(..., 'w') 逐行写入 1000 个小文件,总耗时比同步还长
  • 没调大线程池,默认只有 min(32, os.cpu_count() + 4) 个线程,大量并发写入时排队严重

正确做法:

  • import aiofiles 前先配置自定义线程池:
    import asyncio
    from concurrent.futures import ThreadPoolExecutor
    import aiofiles
    

创建更大线程池(例如 16 线程)

executor = ThreadPoolExecutor(max_workers=16) loop = asyncio.get_running_loop() loop.set_default_executor(executor)

async def write_one(filename, data): async with aiofiles.open(filename, 'w') as f: await f.write(data)

  • 单次写入量尽量大,避免高频小写:攒够 8KB+ 再 await f.write(buffer),而不是每行都 await

异步写入真正提速的前提:I/O 不是瓶颈,等待才是

aiofiles 只在以下场景带来实际收益:

  • 你同时做很多事:比如一边发 HTTP 请求、一边解析 JSON、一边写日志 —— 这时用 aiofiles 避免写文件拖垮整个协程流
  • 文件目标是网络文件系统(如 NFS、S3FS)或高延迟存储(某些云盘),同步写会卡几百毫秒,而线程池能并行消化这些等待
  • 你已经在用 asyncio.gather() 并发调度几十个写任务,且磁盘带宽没打满(SSD 随机写通常 >50K IOPS)

反例(别这么干):

  • 把一个 2GB CSV 拆成 200 万行,每行起一个 aiofiles.open 协程 → 线程池过载 + 文件句柄爆炸 + 磁盘寻道雪崩
  • 在单核 VM 或低配云服务器上开 100 个 aiofiles 写任务 → CPU 调度开销压倒 I/O 收益

替代方案往往比 aiofiles 更有效

如果你的目标是「写得更快」,优先考虑这些:

  • 批量写入:用 file.write() 一次性写入大字符串/字节块,而非分多次 await f.write()
  • 换格式:写 .parquet.feather 比写 CSV 快 3–10 倍,Pandas 的 to_parquet() 默认就带缓冲和压缩
  • 绕过 Python:用 subprocessddcatpv,尤其适合管道场景
  • 真异步 I/O(Linux):用 io_uring 绑定的库(如 anyio 未来可能支持),但目前 Python 生态还不成熟

aiofiles 的价值不在速度,而在调度自由度——它让你能把文件操作和其他异步任务放在同一个事件循环里协调。但一旦你开始盯着「写入耗时」优化,就得立刻跳出协程层,去看磁盘队列深度、缓冲区大小、文件系统挂载参数这些真实瓶颈。

以上就是本文的全部内容了,是否有顺利帮助你解决问题?若是能给你带来学习上的帮助,请大家多多支持golang学习网!更多关于文章的相关知识,也可关注golang学习网公众号。

PHP动态传参到类构造函数的技巧PHP动态传参到类构造函数的技巧
上一篇
PHP动态传参到类构造函数的技巧
Python多线程与量化交易高频系统设计
下一篇
Python多线程与量化交易高频系统设计
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    516次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    500次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    485次学习
查看更多
AI推荐
  • H2O EvalGPT:开源LLM大模型评估与排行榜工具
    H2O EvalGPT
    H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
    105次使用
  • LMArena是什么?伯克利AI模型评估平台使用指南与功能解析
    LMArena
    LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
    21次使用
  • OpenCompass大模型评测体系详解:功能、使用指南与应用场景
    OpenCompass
    OpenCompass是上海AI实验室推出的开源大模型评测平台,提供CompassKit、CompassHub和CompassRank三大核心组件,支持LLM及多模态模型的一站式标准化评估与排行榜查询。
    31次使用
  • AGI-Eval大模型评测平台:权威榜单、数据集与人机协同评测方案
    AGI-Eval
    AGI-Eval是由上海交大等高校联合发布的大模型评测社区,提供公正透明的LLM能力榜单、多领域评测集及Data Studio数据服务,助力AI模型性能评估与NLP科研开发。
    22次使用
  • SuperCLUE中文大模型评测基准:功能、能力维度与应用指南
    SuperCLUE
    SuperCLUE是权威的中文大语言模型综合评测基准,涵盖语言理解、知识应用、AI Agent智能体及安全性等12项核心能力。通过多轮对话与客观测试,定期发布榜单与技术报告,为模型研发、优化及行业选型提供科学依据。
    259次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码