Apache Beam 2.39.0 和 DataFlow 运行器上的 BigQuery Storage API 的 PERMISSION_DENIED答案

【问题标题】：PERMISSION_DENIED for BigQuery Storage API on Apache Beam 2.39.0 and DataFlow runnerApache Beam 2.39.0 和 DataFlow 运行器上的 BigQuery Storage API 的 PERMISSION_DENIED
【发布时间】：2022-08-12 21:47:03
【问题描述】：

我的一项 DataFlow 作业出现以下错误：

2022-06-15T16：12：27.365182607Z 来自工作人员的错误消息：java.lang.RuntimeException：org.apache.beam.sdk.util.UserCodeException：java.lang.RuntimeException：java.lang.RuntimeException：java.lang.RuntimeException ：com.google.api.gax.rpc.PermissionDeniedException：io.grpc.StatusRuntimeException：PERMISSION_DENIED：BigQuery Storage API 之前未在项目 770406736630 中使用或已禁用。通过访问https://console.developers.google.com/apis/api/bigquerystorage.googleapis.com/overview?project=770406736630 启用它，然后重试。如果您最近启用了此 API，请等待几分钟让该操作传播到我们的系统并重试。

相同的代码适用于 Apache Beam 2.38.0。我测试了多次，这不是暂时的问题。错误（770406736630）中提到的项目号不是我的。

知道为什么我会收到此错误吗？

标签： google-cloud-platform google-bigquery google-cloud-dataflow apache-beam

【解决方案1】：

我遇到过同样的问题。我正在使用 Spring Cloud GCP 并且没有设置 spring.cloud.gcp.project-id 属性，我猜这会使 SDK 或 API 使用一些默认值。

我不知道您是如何设置环境的，因为您没有指定，但请查看如何显式设置项目 ID。您可以从 GCP Console 中选择项目的对话框中获取它。

【讨论】：

【解决方案2】：

我刚刚遇到了这个问题，只需要通过运行gcloud auth application-default login 重新使用 gcp cli 进行身份验证。

【讨论】：