Python aiofiles 的正确打开关闭方式

2次阅读

必须用 async with aiofiles.open(),不可 await 后手动 close;需显式指定 encoding=’utf-8′ 读文本;mode=’w’ 不自动建父目录;aiofiles 文件对象不能脱离 async with 使用。

Python aiofiles 的正确打开关闭方式

aiofiles.open() 必须配合 async with

不加 async with 直接 await aiofiles.open(...),文件句柄不会自动释放,协程退出后底层 fd 仍可能被占用,尤其在高并发循环打开时容易触发 OSError: [errno 24] Too many open files

正确写法只有一种主流模式:

async with aiofiles.open('data.txt', 'r') as f:     content = await f.read()
  • aiofiles.open() 返回的是一个异步上下文管理器,不是文件对象本身
  • 不能用 with(同步语法),也不能手动调 .close() —— 它没有这个方法
  • 如果需要复用文件对象(比如多次读写),必须确保整个生命周期都在同一个 async with 块内

aiofiles.open() 的 mode 参数和同步版不完全等价

看起来和内置 open() 一样支持 'r''w''a',但实际行为有隐含差异:它默认不带 encoding,且二进制模式下不能混用字符串操作。

  • 读文本务必显式传 encoding='utf-8',否则 await f.read() 返回 bytes,容易和预期类型错位
  • mode='w' 不会自动创建父目录,FileNotFoundError 仍会抛出,需提前用 os.makedirs(..., exist_ok=True)
  • mode='a' 在某些系统上对小文件可能不实时刷盘,如需强一致性,得额外 await f.flush()

别在 async with 外面 hold 住 aiofiles 文件对象

下面这种写法看似省事,实则危险:

立即学习Python免费学习笔记(深入)”;

f = await aiofiles.open('log.txt', 'a') await f.write('msgn') # ... 其他 await 操作 await f.close()  # ❌ 报错:'AsyncTextIOWrapper' object has no attribute 'close'

原因:aiofiles 包装的文件对象没有 .close() 方法,也不支持手动关闭。它的释放完全依赖 async with__aexit__

  • 试图保存 f 到类属性或全局变量?立刻放弃 —— 协程挂起期间文件资源不可控
  • 想“延迟关闭”?不行。异步 IO 的生命周期必须和上下文绑定
  • 唯一合法的“中途退出”方式是 breakreturn 出当前 async with 块,上下文管理器仍会正常清理

替代方案:什么时候不该用 aiofiles

它不是万能加速器。IO 密集型任务中,如果文件很小(open() 反而更稳更快 —— aiofiles 底层仍是线程池模拟异步,有调度开销。

  • Web 请求里读一个配置 JSON?同步更简单,还少一层异常链(aiofiles 抛的异常常嵌套在 concurrent.futures 里)
  • 要同时处理上百个大文件?考虑分批 + asyncio.Semaphore 控制并发数,否则线程池打满反而卡死
  • 日志写入场景慎用 —— aiofiles 不保证原子追加,多协程写同一文件可能错乱,优先选 logging 配合 QueueHandler

真正需要它的典型场景只有一个:你已经在跑一个纯异步服务(比如 FastAPI / Quart),且必须避免阻塞事件循环去读写本地文件。其他时候,先问自己一句:这里真的不能用 await loop.run_in_executor(None, sync_func) 吗?

text=ZqhQzanResources