如文档中所述,
为了使for
循环成为遍历文件行的最有效方法(一种非常常见的操作),该next()
方法使用了隐藏的预读缓冲区。
您可以查看调用底层迭代器方法(via )的csv
模块的实现(784行)。csv.reader``next()``PyIter_Next
因此,如果您真的想无缓冲地读取CSV文件,则需要将文件对象(此处为sys.stdin
)转换为next()
实际调用其方法的迭代器readline()
。使用iter
函数的两个参数形式可以轻松完成此操作。因此,将代码更改为test_reader.py
如下所示:
for row in csv.reader(iter(sys.stdin.readline, '')):
print("Read: ({}) {!r}".format(time.time(), row))
例如,
$ python test_writer.py | python test_reader.py
Read: (1388776652.964925) ['R0', '$']
Read: (1388776653.466134) ['R1', '$$']
Read: (1388776653.967327) ['R2', '$$$']
Read: (1388776654.468532) ['R3', '$$$$']
[etc]