如何使用 oauth 2.0 对 Google 数据流管道进行身份验证

Question

我正在尝试使用 Google 数据流管道 python API 使用以下文档：Dataflow Python Docs 第一次尝试在我们的项目中使用示例代码时，它打开了网络请求权限。我获得了运行所有权限，然后在网络上收到了"authentication completed"消息。

所以我再次运行 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": {

"errors":[ { "domain": "global", "reason": "required", "message": "Anonymous caller does not have storage.objects.create access to testing_data_flow.", "locationType": "header", "location": "Authorization" } ], "code": 401, "message": "Anonymous caller does not have storage.objects.create access to testing_data_flow." }

我还没有找到任何可行的解决方案。

Answer 1

我知道问题出在哪里了。

我没有使用google cloud sdk and run these commands

如何使用 oauth 2.0 对 Google 数据流管道进行身份验证

How to authenticate with oauth 2.0 to Google Dataflow pipeline

oauth

oauth-2.0

google-cloud-platform

pipeline

dataflow