Как пройти аутентификацию с помощью oauth 2.0 в конвейере данных Google - PullRequest
Новая
       49

Как пройти аутентификацию с помощью oauth 2.0 в конвейере данных Google

0 голосов
/ 06 июня 2018

Я пытаюсь использовать API Python для конвейера потока данных Google, используя следующую документацию: Документы Python для потока данных При первой попытке использовать пример кода с нашим проектом, и он открыл веб-страницу с запросом разрешений.Я предоставил все разрешения и затем получил сообщение «проверка подлинности завершена» в Интернете.

Поэтому я снова запустил команду python: 

python -m apache_beam.examples.wordcount --input gs://dataflow-samples/shakespeare/kinglear.txt \
                                     --output gs://<your-gcs-bucket>/counts \
                                     --runner DataflowRunner \
                                     --project your-gcp-project \
                                     --temp_location gs://<your-gcs-bucket>/tmp/

(Это пример кода, я ввел нашсобственные данные проекта), и я всегда получаю 401 ошибку 

"error": {

«ошибки»: [{«домен»: «глобальный», «причина»: «требуется», «сообщение»: «анонимный абонент делаетне иметь storage.objects.create доступ к testing_data_flow. "," locationType ":" header "," location ":" Authorization "}]," code ": 401," message ":" У анонимного абонента нет объектов storage.objectsСоздать доступ к testing_data_flow. "}

Я не нашел ни одного рабочего решения.

1 Ответ

0 голосов
/ 06 июня 2018

Я выяснил, в чем проблема.

Я не использовал Google Cloud SDK и запустил эти команды

...