Я работаю над созданием конвейера Apache Beam, но при попытке импортировать параметры конвейера я сталкиваюсь с AttributeError.
Я тестирую на сервере Ubuntu в чистой виртуальной среде с использованием python3.6
Шаги:
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»