没有名为 options.pipeline_options 的模块

Question

我刚开始使用 Apache Beam 文档中的初始指南，看起来这个特定的管道导入不再可用。

从 apache_beam.options.pipeline_options 导入 PipelineOptions

参考：https://beam.apache.org/documentation/programming-guide/#pipeline

错误：

---

ImportError Traceback（最后一次调用） 在 （） ----> 1 来自 apache_beam.options.pipeline_options 导入 PipelineOptions

**

ImportError: No module named options.pipeline_options

**

任何活跃的 Apache Beam python 用户？谁知道实际导入路径是什么？

Answer 1

看起来它得到了 renamed/refactored 这个模块名称：

from apache_beam.pipeline import PipelineOptions

基本上是 apache_beam.pipeline 而不是 apache_beam.options.pipeline_options

并且成功运行！

注意：2.7.13 是我的 python 版本

Answer 2

导航到 Python Lib 文件夹或 site-packages 文件夹并验证 apache_beam 包中的文件夹结构。

如果文件夹结构是 apache_beam\pipeline 那么你的导入语句应该是 from apache_beam.pipeline import *

或者更好地使用@gnanagurus 回答中提到的目标导入语句。