我需要更新几个超过 2GB 的文件的最后一行,这些文件由无法用
readlines()
读取的文本行组成。目前,它通过逐行循环来正常工作。但是,我想知道是否有任何编译库可以更有效地实现这一点?谢谢!
myfile = open("large.XML")
for line in myfile:
do_something()
如果这确实是基于行的(其中真正的 XML 解析器不一定是最佳解决方案),
mmap
可以在这里提供帮助。
mmap
文件,然后在生成的对象上调用 .rfind('\n')
(当您确实想要其前面的非空行而不是后面的空“行”时,可能需要进行调整以处理以换行符结尾的文件)。然后你可以单独切掉最后一行。如果需要就地修改文件,可以调整文件大小以削减(或添加)与切片行和新行之间的差异相对应的字节数,然后写回新行。避免读取或写入超出您需要的文件内容。
示例代码(如有错误请评论):
import mmap
# In Python 3.1 and earlier, you'd wrap mmap in contextlib.closing; mmap
# didn't support the context manager protocol natively until 3.2; see example below
with open("large.XML", 'r+b') as myfile, mmap.mmap(myfile.fileno(), 0, access=mmap.ACCESS_WRITE) as mm:
# len(mm) - 1 handles files ending w/newline by getting the prior line
# + 1 to avoid catching prior newline (and handle one line file seamlessly)
startofline = mm.rfind(b'\n', 0, len(mm) - 1) + 1
# Get the line (with any newline stripped)
line = mm[startofline:].rstrip(b'\r\n')
# Do whatever calculates the new line, decoding/encoding to use str
# in do_something to simplify; this is an XML file, so I'm assuming UTF-8
new_line = do_something(line.decode('utf-8')).encode('utf-8')
# Resize to accommodate the new line (or to strip data beyond the new line)
mm.resize(startofline + len(new_line)) # + 1 if you need to add a trailing newline
mm[startofline:] = new_line # Replace contents; add a b"\n" if needed
显然在某些没有
mremap
的系统(例如 OSX)上,mm.resize
将无法工作,因此为了支持这些系统,您可能会拆分 with
(因此 mmap
在文件对象之前关闭),并使用基于文件对象的查找、写入和截断来修复文件。以下示例包括我之前提到的 Python 3.1 和之前为了完整性而使用 contextlib.closing
的具体调整:
import mmap
from contextlib import closing
with open("large.XML", 'r+b') as myfile:
with closing(mmap.mmap(myfile.fileno(), 0, access=mmap.ACCESS_WRITE)) as mm:
startofline = mm.rfind(b'\n', 0, len(mm) - 1) + 1
line = mm[startofline:].rstrip(b'\r\n')
new_line = do_something(line.decode('utf-8')).encode('utf-8')
myfile.seek(startofline) # Move to where old line began
myfile.write(new_line) # Overwrite existing line with new line
myfile.truncate() # If existing line longer than new line, get rid of the excess
mmap
相对于任何其他方法的优点是:
rfind
意味着你可以让Python在C层(在CPython中)快速完成查找换行符的工作;文件对象的显式 seek
和 read
可以匹配“仅读取一页左右”,但您必须手动实现换行符的搜索警告: 此方法行不通(至少,必须进行修改以避免映射超过 2 GB,并在可能未映射整个文件时处理调整大小)如果您使用的是 32 位系统并且文件太大,无法映射到内存中。在大多数 32 位系统上,即使在新生成的进程中,也只有 1-2 GB 的可用连续地址空间;在某些特殊情况下,您可能拥有多达 3-3.5 GB 的用户虚拟地址(尽管您会丢失一些用于堆、堆栈、可执行映射等的连续空间)。
mmap
不需要太多物理RAM,但需要连续的地址空间; 64 位操作系统的巨大好处之一是,除了最荒谬的情况外,您不再需要担心虚拟地址空间,因此 mmap
可以解决一般情况下无法处理的问题,而不会增加 32 位操作系统的复杂性位操作系统。目前大多数现代计算机都是 64 位的,但如果您的目标是 32 位系统,那么绝对需要记住这一点(在 Windows 上,即使操作系统是 64 位,它们也可能已经安装了 32 位版本的 Python)错误,所以同样的问题也适用)。这里还有一个可以在 32 位 Python 上运行的示例(假设最后一行不是 100+ MB 长)(为简洁起见,省略 closing
和导入),即使对于大文件也是如此:
with open("large.XML", 'r+b') as myfile:
filesize = myfile.seek(0, 2)
# Get an offset that only grabs the last 100 MB or so of the file aligned properly
offset = max(0, filesize - 100 * 1024 ** 2) & ~(mmap.ALLOCATIONGRANULARITY - 1)
with mmap.mmap(myfile.fileno(), 0, access=mmap.ACCESS_WRITE, offset=offset) as mm:
startofline = mm.rfind(b'\n', 0, len(mm) - 1) + 1
# If line might be > 100 MB long, probably want to check if startofline
# follows a newline here
line = mm[startofline:].rstrip(b'\r\n')
new_line = do_something(line.decode('utf-8')).encode('utf-8')
myfile.seek(startofline + offset) # Move to where old line began, adjusted for offset
myfile.write(new_line) # Overwrite existing line with new line
myfile.truncate() # If existing line longer than new line, get rid of the excess
更新:使用ShadowRanger的答案。它更短、更坚固。
为了后代:
读取文件的最后 N 个字节并向后搜索换行符。
#!/usr/bin/env python
with open("test.txt", "wb") as testfile:
testfile.write('\n'.join(["one", "two", "three"]) + '\n')
with open("test.txt", "r+b") as myfile:
# Read the last 1kiB of the file
# we could make this be dynamic, but chances are there's
# a number like 1kiB that'll work 100% of the time for you
myfile.seek(0,2)
filesize = myfile.tell()
blocksize = min(1024, filesize)
myfile.seek(-blocksize, 2)
# search backwards for a newline (excluding very last byte
# in case the file ends with a newline)
index = myfile.read().rindex('\n', 0, blocksize - 1)
# seek to the character just after the newline
myfile.seek(index + 1 - blocksize, 2)
# read in the last line of the file
lastline = myfile.read()
# modify last_line
lastline = "Brand New Line!\n"
# seek back to the start of the last line
myfile.seek(index + 1 - blocksize, 2)
# write out new version of the last line
myfile.write(lastline)
myfile.truncate()