python - 如何修复 `AttributeError: module ' apache_beam.coders.coders' 没有属性 'VarIntCoder'`

Question

我正在构建 Apache Beam 管道，但在尝试导入管道选项时遇到了 AttributeError。

我正在使用 python3.6 在干净的虚拟环境中的 Ubuntu 服务器上进行测试

步骤:

virtualenv -p python3.6 beam-env
. beam-env/bin/activate
pip install apache_beam==2.12.0
python3.6 test.py

在 test.py 中:

from apache_beam.options.pipeline_options import PipelineOptions

我希望导入能够成功，但我收到以下错误:

AttributeError:模块“apache_beam.coders.coders”没有属性“VarIntCoder”

Answer 1

我在使用 apache-beam 编写自己的数据管道时发现了一个非常奇怪的行为:只要在名为 test.py 的文件中拥有管道，就会出现此行为。

假设您当前的实现位于 main.py 中，您只需将整个代码复制到 test.py 文件中，之后就会产生错误在这两个文件上。

我现在解决这个问题的唯一方法是删除该 test.py 或将其重命名为其他名称，然后问题就消失了。