是否可以按顺序读取文本文件?

是的,您可以使用 FileSystems API . 这是什么 ReadFromText 所有其他基于文件的内置转换都是在后台进行的。

def ParseFile(name):
  with FileSystems.open(name) as f:
    ... Parse the file and yield elements ...

p | beam.Create(['/path/to/file'])
  | beam.FlatMapElements(ParseFile)