импорт apache_beam в виде луча из apache_beam.options.pipeline_options import PipelineOptions
p = beam.Pipeline(options=PipelineOptions())lines = p | beam.io.ReadFromText('file:///C:/Users/Lenovo/Desktop/dataflow.csv')
Луч Apache работает локально, но не может прочитать данные из csv.