java - 如何在 Eclipse 中设置 GCP 凭据以运行数据流管道

Question

我有一个在 Eclipse 中使用 Java 开发的管道。

安装 Cloud SDK for Eclipse 后，我可以使用数据流配置在本地运行管道(直接运行程序):

我还想使用 Maven 配置在本地运行它。

如果我尝试使用 maven 执行它，我遇到的问题是当管道尝试创建 pubsub 订阅时的凭据。

Exception: org.apache.beam.sdk.Pipeline$PipelineExecutionException: java.lang.RuntimeException: Failed to create subscription to topic projects/xxx/topics/test on project projects/xxx: 403 Forbidden

{
  "code" : 403,
  "errors" : [ {
    "domain" : "global",
    "message" : "The request is missing a valid API key.",
    "reason" : "forbidden"
  } ],
  "message" : "The request is missing a valid API key.",
  "status" : "PERMISSION_DENIED"
}
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time:  7.154 s
[INFO] Finished at: 2019-12-12T11:19:36+01:00
[INFO] ------------------------------------------------------------------------

我已安装并配置了云 shell。还要设置环境变量 GOOGLE_APPLICATION_CREDENTIALS

<小时/>

如果我在cmd(也是gcp shell)中执行mvn命令，我也会遇到同样的错误

Answer 1

您可以在 shell 中运行以下命令，然后尝试运行该作业

gcloud auth application-default login

或者，您还可以在此处查看如何为 GCP 设置 Eclipse - https://cloud.google.com/dataflow/docs/quickstarts/quickstart-java-eclipse