python: невозможно импортировать имя beam_runner_api_pb2

Question

Я относительно новичок в Python и Beam, и я следил за Apache Beam - Python Quickstart ( здесь ) до последней буквы. Моя виртуальная среда Python 2.7 была создана с помощью conda.

Я клонировал пример из https://github.com/apache/beam

Когда я пытаюсь запустить

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

Я получаю следующую ошибку

/Users/name/anaconda3/envs/py27/bin/python: cannot import name beam_runner_api_pb2

(что, как я понимаю, после поиска означает, что существует циклический импорт)

Понятия не имею, с чего начать. Это ошибка или что-то не так с моей настройкой.

(я сейчас попробовал повторить пример в трех разных виртуальных средах - все с одинаковым результатом)

Answer 1

Кажется, это была моя ошибка. Я неправильно установил компоненты Google Cloud Platfrom (gcp). Как только я это сделал, все заработало

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