如何使用 oauth 2.0 对 Google 数据流管道进行身份验证
How to authenticate with oauth 2.0 to Google Dataflow pipeline
我正在尝试使用 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."
}
我还没有找到任何可行的解决方案。
我知道问题出在哪里了。
我没有使用google cloud sdk and run these commands
我正在尝试使用 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." }
我还没有找到任何可行的解决方案。
我知道问题出在哪里了。
我没有使用google cloud sdk and run these commands