我刚从apache文档的初始指南开始,看起来这个特定的管道导入已经不可用了。
从apache_beam.options.pipeline_options导入PipelineOptions
参考资料:https://beam.apache.org/documentation/programming-guide/#pipeline
错误:
ImportError跟踪(最近一次调用) in () ->1来自apache_beam.options.pipeline_options import PipelineOptions
**
ImportError:没有名为options.pipeline_options的模块
**
有任何活跃的用户吗?谁知道实际的导入路径是什么?
发布于 2017-05-22 03:38:02
看起来它被重命名/重构到这个模块名:
从apache_beam.pipeline导入PipelineOptions
基本上是它的apache_beam.pipeline而不是apache_beam.options.pipeline_options
而且成功了!
注意: 2.7.13是我的python版本
发布于 2017-05-22 07:52:31
导航到Python文件夹或structure文件夹,并验证apache_beam包中的文件夹结构。
如果文件夹结构是apache_beam\pipeline
,那么导入语句应该是from apache_beam.pipeline import *
。
或者更好地使用@gnanagurus中提到的目标导入语句。
https://stackoverflow.com/questions/44104121
复制相似问题