我正在构建 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
Run Code Online (Sandbox Code Playgroud)
内部test.py:
from apache_beam.options.pipeline_options import PipelineOptions
Run Code Online (Sandbox Code Playgroud)
我希望导入成功,但出现以下错误:
AttributeError: 模块 'apache_beam.coders.coders' 没有属性 'VarIntCoder'