首页 > 解决方案 > apache Beam 在本地运行但无法从 Python 中的 csv 读取数据

问题描述

从 apache_beam.options.pipeline_options 导入 apache_beam 作为梁

p = beam.Pipeline(options=PipelineOptions())lines = p | beam.io.ReadFromText('file:///C:/Users/Lenovo/Desktop/dataflow.csv')

Apache Beam 在本地运行,但无法从 csv 读取数据。

标签: pythonpython-2.7apache-beam

解决方案


推荐阅读