我正在构建一个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: module 'apache_beam.coders.coders' 没有 'VarIntCoder' 属性。
test.py
以外的其他名称,一切都正常工作了。 - Twist