python:无法导入名称beam_runner_api_pb2

Question

我对Python和Beam比较陌生，而且我一直遵循apachebeam-Python快速入门（here）的最后一个字母。我的cond7.Python是用虚拟Python环境创建的。在

我从https://github.com/apache/beam克隆了这个示例

当我想跑的时候

python -m apache_beam.examples.wordcount --input sample_text.txt --output counts

我得到以下错误

^{pr2}$

（在搜索后我理解为存在循环导入）

我不知道从哪里开始。这是错误还是我的设置有问题。在

（我现在尝试在三个不同的虚拟环境中重做这个例子，结果都一样）

Answer 1

看来是我的错。我没有正确安装googlecloudplatfrom（gcp）组件。一旦我做了这一切都奏效了

# As part of the initial setup, install Google Cloud Platform specific extra components.
pip install apache-beam[gcp]