从没有结束的管道中读取[重复]

Question

如果我有一个带有不停止的连续数据流的管道，我在从stdin 读取 python 时遇到问题。

例如，我有 data_stream.py

import time

i = 0
while True:
    print(i)
    i += 1
    time.sleep(2)

现在我尝试使用文件 read_data.py

读取数据

import sys
for line in sys.stdin:
    print(line)

当我尝试使用python3 data_stream.py | python3 read_data.py 运行它时，我没有得到任何结果，因为data_stream.py 没有完成。 我如何在data_stream.py 仍在运行时读取它？

Answer 1

您必须“刷新” data_stream.py 中的标准输出和 read_data.py 中的“readline”。 完整代码如下：

#!/usr/bin/env python
# -*- coding: utf-8 -*-
#
#  data_stream.py

import sys
import time

i = 0
while True:
    print(i)
    i += 1
    sys.stdout.flush()
    time.sleep(2)

还有 read_data.py 的代码

#!/usr/bin/env python
# -*- coding: utf-8 -*-
#
#  read_data.py

import sys

# Now I try to read the data with the file read_data.py

while True:
    line = sys.stdin.readline()
    print (line),

最好的问候，