Python open()函数之buffering缓冲区策略

2023-10-14 19:10

本文主要是介绍Python open()函数之buffering缓冲区策略,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

文章目录

    • 一、buffering 缓冲策略
    • 二、示例
      • 1. 可交互文本文件
        • 1.1 buffering=-1,行缓冲(默认)
        • 1.2 buffering=0,文本模式不支持关闭缓冲区
        • 1.3 buffering=1,行缓冲,同 buffering=-1
        • 1.4 buffering>1,io.DEFAULT_BUFFER_SIZE
      • 2. 普通文本文件
        • 2.1 buffering=-1, io.DEFAULT_BUFFER_SIZE
        • 2.2 buffering=0,文本模式不支持关闭缓冲区
        • 2.3 buffering=1,行缓冲
        • 2.4 buffering>1,io.DEFAULT_BUFFER_SIZE
      • 3. 二进制文件
        • 3.1 buffering=-1,io.DEFAULT_BUFFER_SIZE
        • 3.2 buffering=0,关闭缓冲区
        • 3.3 buffering=1,io.DEFAULT_BUFFER_SIZE
        • 3.4 buffering>1,指定的大小的缓冲区

一、buffering 缓冲策略

Python中,open() 内建函数,是用来打开文件, 根据设定的参数来创造一个文件对象.
完整的格式:

open(file, mode='r', buffering=None, encoding=None, errors=None, newline=None, closefd=True)

其中 buffering参数,用来指定访问文件所采用的缓冲方式。open()函数操作的文件主要有三类:可交互文本文件、普通文本文件、二进制文件,根据文件类型的不同,缓冲策略又有差别,具体如下:

buffering可交互文本文件普通文本文件二进制文件
-1表示行缓冲,即遇到换行符就flushio.DEFAULT_BUFFER_SIZEio.DEFAULT_BUFFER_SIZE
0文本模式不支持文本模式不支持表示关闭buffer,即不缓冲
1表示行缓冲,即遇到换行符就flush表示行缓冲,即遇到换行符就flushio.DEFAULT_BUFFER_SIZE
网上有说buffering=1时,表示1字节缓冲区???
从测试结果看是io.DEFAULT_BUFFER_SIZE
>1io.DEFAULT_BUFFER_SIZEio.DEFAULT_BUFFER_SIZE使用buffering设置的值作为缓冲区大小,这个值可以>io.DEFAULT_BUFFER_SIZE
  1. 怎么理解可交互式文本文件?就是连接到终端设备的文件,即 fileObject.isatty()返回值为True的文件。例如:控制台的标准输出流你就可以简单的理解为一个可交互文本文件;
  2. open() 函数声明中,buffering=None,表示默认缺省,等效于 buffering=-1
  3. 在大多数系统中,io.DEFAULT_BUFFER_SIZE 默认是 40968192 字节长度。可以通过下面的代码来获取这个值
import io
print(io.DEFAULT_BUFFER_SIZE)

引用builtins.pyopen()函数注释原文:
When no buffering argument is given, the default buffering policy works as follows:

  • Binary files are buffered in fixed-size chunks; the size of the buffer
    is chosen using a heuristic trying to determine the underlying device’s
    “block size” and falling back on io.DEFAULT_BUFFER_SIZE.
    On many systems, the buffer will typically be 4096 or 8192 bytes long.
  • “Interactive” text files (files for which isatty() returns True)
    use line buffering. Other text files use the policy described above
    for binary files.

二、示例

下面举几个示例,帮助你理解可交互文本文件、普通文本文件的buffering如何控制缓存策略的。

1. 可交互文本文件

# -*- coding:utf-8 -*-
# test.py
import datetime,time
import sys
with open(sys.stdout.fileno(),"w",buffering=-1) as f:print(datetime.datetime.now())for i in range(10):time.sleep(1)f.write("{}".format(i)*10+"\n")print(datetime.datetime.now())print(str(f.isatty()))

在命令行终端执行python test.py,输出结果:

1.1 buffering=-1,行缓冲(默认)

buffering=-1或1
行缓冲,缓冲区内容每满一行(即遇到换行符),就刷新缓冲区,将内容转储到终端设备。

1.2 buffering=0,文本模式不支持关闭缓冲区

buffering=0

1.3 buffering=1,行缓冲,同 buffering=-1

演示效果同1.1

1.4 buffering>1,io.DEFAULT_BUFFER_SIZE

系统默认缓冲区大小 io.DEFAULT_BUFFER_SIZE
buffering>1

  1. 为什么最后两个print()语句打印的结果在上面???
    这是因为 print()函数本身在往控制台输出内容时,有自己的缓冲策略,它有两个参数fileflush,其中默认file=sys.stdoutflush=False,也就是说它是直接连接的sys.stdout,并不经过open()函数创建的f类文件对象,因此它默认缓冲策略是sys.stdout的默认策略:行缓冲
    1)可以修改上述代码中的最后两个print()语句,做验证:
    print(datetime.datetime.now(),end="")
    print(str(f.isatty()),file=f)
    输出结果如下:
    输出结果
    print(datetime.datetime.now(),end="") 语句的数据结果在最后了,这是因为end=""去掉了换行符,没有换行符,它就一直在缓冲区待着,直到程序运行结束也没有等到换行符,于是程序结束时就自动刷新了缓冲区;
    print(str(f.isatty()),file=f) 语句,指定了使用open()函数创建的f类文件对象,所以它的输出同上边的for循环里的f.write(xxx)的输出,一同在with语句结束后刷新到了sys.stdout(因为内容没有达到io.DEFAULT_BUFFER_SIZE大小,所以没有立即刷新,而是with语句结束后,关闭了f文件对象,自动刷新到了sys.stdout
    2)如果你将print()flush设置为True,如下:
    print(datetime.datetime.now(),end="",flush=True)
    然后再运行,你会发现,即使该条输出内容中没有换行符,但还是在该语句结束后,立刻刷新了缓冲区。也就是说,flush=True会使缓冲策略失效,变为强制刷新。

  2. 无论什么缓冲策略,当程序被中断或文件对象关闭时,都会自动刷新缓冲区,这也是一种保护机制。
    这一点你可以在运行上述代码时(buffering>1),通过CTRL+C手动中断程序来验证:
    手动中断程序
    你会发现,f.write()输出到缓冲区的部分内容,在程序中断时,自动刷新了缓冲区,输出到了sys.stdout.

2. 普通文本文件

# -*- coding:utf-8 -*-
import time
with open("test.txt","w",buffering=-1) as f:for i in range(10):time.sleep(1)out_str = "{}".format(i)*10+"\n"print(out_str,end="")f.write(out_str)print(str(f.isatty()))f.write(str(f.isatty())+"\n")

打开两个命令行窗口,一个执行python test.py,另一个执行tail -F test.txt(先执行这个)

2.1 buffering=-1, io.DEFAULT_BUFFER_SIZE

buffering=-1
系统默认的缓冲区,io.DEFAULT_BUFFER_SIZE,我机器上是8192字节大小,当缓冲区内容满了后才刷新缓冲区,示例中输出的代码显然未使缓冲区填满,但是with代码块结束后,会自动关闭文件对象,文件关闭后会自动调用flush进行刷新缓冲区。所以最后,一次性将缓冲区内容写入到了设备上的文件内。

2.2 buffering=0,文本模式不支持关闭缓冲区

buffering=0

2.3 buffering=1,行缓冲

buffering=1
行缓冲,缓冲区内容每满一行(即遇到换行符),就刷新缓冲区,将内容转储到文件中。

2.4 buffering>1,io.DEFAULT_BUFFER_SIZE

演示效果同2.1

3. 二进制文件

# -*- coding:utf-8 -*-
import time
with open("test.png","bw",buffering=-1) as f:for i in range(10):time.sleep(1)out_str = "{}".format(i)*10print(bytes(out_str.encode("gbk")),end="",flush=True)f.write(bytes(out_str.encode('gbk')))print(bytes(str(f.isatty()).encode('gbk')),end="",flush=True)f.write(bytes(str(f.isatty()).encode('gbk')))
3.1 buffering=-1,io.DEFAULT_BUFFER_SIZE

使用系统默认缓冲区io.DEFAULT_BUFFER_SIZE,我这里默认8192字节
buffering=-1
可以看出,当python test.py执行完后,才一次性将缓冲区刷新,写入到test.png文件的。

3.2 buffering=0,关闭缓冲区

buffering=0
关闭缓冲区,内容会实时写入到文件中。

3.3 buffering=1,io.DEFAULT_BUFFER_SIZE

buffering=1
buffering=1,则使用默认io.DEFAULT_BUFFER_SIZE缓冲区大小,在网上有些资料说,buffering=1时,代表缓冲区大小为1字节,但是从这里的测试结果来看,buffering=1时,使用的是io.DEFAULT_BUFFER_SIZE默认缓冲区。

3.4 buffering>1,指定的大小的缓冲区

我这里将设置buffering=30进行测试
buffering=30
可以看出,缓冲区每满30字节,即刷新缓冲区。



python中文件IO操作
disable-output-buffering

这篇关于Python open()函数之buffering缓冲区策略的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/212537

相关文章

Python的Darts库实现时间序列预测

《Python的Darts库实现时间序列预测》Darts一个集统计、机器学习与深度学习模型于一体的Python时间序列预测库,本文主要介绍了Python的Darts库实现时间序列预测,感兴趣的可以了解... 目录目录一、什么是 Darts?二、安装与基本配置安装 Darts导入基础模块三、时间序列数据结构与

Python正则表达式匹配和替换的操作指南

《Python正则表达式匹配和替换的操作指南》正则表达式是处理文本的强大工具,Python通过re模块提供了完整的正则表达式功能,本文将通过代码示例详细介绍Python中的正则匹配和替换操作,需要的朋... 目录基础语法导入re模块基本元字符常用匹配方法1. re.match() - 从字符串开头匹配2.

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现(FastAPI)2.1 运行环境2.2 目录结构建议2.3 serv

通过Docker容器部署Python环境的全流程

《通过Docker容器部署Python环境的全流程》在现代化开发流程中,Docker因其轻量化、环境隔离和跨平台一致性的特性,已成为部署Python应用的标准工具,本文将详细演示如何通过Docker容... 目录引言一、docker与python的协同优势二、核心步骤详解三、进阶配置技巧四、生产环境最佳实践

Python一次性将指定版本所有包上传PyPI镜像解决方案

《Python一次性将指定版本所有包上传PyPI镜像解决方案》本文主要介绍了一个安全、完整、可离线部署的解决方案,用于一次性准备指定Python版本的所有包,然后导出到内网环境,感兴趣的小伙伴可以跟随... 目录为什么需要这个方案完整解决方案1. 项目目录结构2. 创建智能下载脚本3. 创建包清单生成脚本4

Python实现Excel批量样式修改器(附完整代码)

《Python实现Excel批量样式修改器(附完整代码)》这篇文章主要为大家详细介绍了如何使用Python实现一个Excel批量样式修改器,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一... 目录前言功能特性核心功能界面特性系统要求安装说明使用指南基本操作流程高级功能技术实现核心技术栈关键函

python获取指定名字的程序的文件路径的两种方法

《python获取指定名字的程序的文件路径的两种方法》本文主要介绍了python获取指定名字的程序的文件路径的两种方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要... 最近在做项目,需要用到给定一个程序名字就可以自动获取到这个程序在Windows系统下的绝对路径,以下

使用Python批量将.ncm格式的音频文件转换为.mp3格式的实战详解

《使用Python批量将.ncm格式的音频文件转换为.mp3格式的实战详解》本文详细介绍了如何使用Python通过ncmdump工具批量将.ncm音频转换为.mp3的步骤,包括安装、配置ffmpeg环... 目录1. 前言2. 安装 ncmdump3. 实现 .ncm 转 .mp34. 执行过程5. 执行结

Python实现批量CSV转Excel的高性能处理方案

《Python实现批量CSV转Excel的高性能处理方案》在日常办公中,我们经常需要将CSV格式的数据转换为Excel文件,本文将介绍一个基于Python的高性能解决方案,感兴趣的小伙伴可以跟随小编一... 目录一、场景需求二、技术方案三、核心代码四、批量处理方案五、性能优化六、使用示例完整代码七、小结一、

Python中 try / except / else / finally 异常处理方法详解

《Python中try/except/else/finally异常处理方法详解》:本文主要介绍Python中try/except/else/finally异常处理方法的相关资料,涵... 目录1. 基本结构2. 各部分的作用tryexceptelsefinally3. 执行流程总结4. 常见用法(1)多个e