调用Google Cloud Dataflow REST API始终返回403-SERVICE_DISABLED

可能的原因及对应解决方案 #

1. Cloud Dataflow API未启用 #

即使项目中已有Dataflow流水线，若API服务本身未开启，调用必然返回该错误。

• 操作：
  • 登录Google Cloud控制台进入目标项目
  • 进入「API和服务」→「库」
  • 搜索「Cloud Dataflow API」，确认状态为已启用；若未启用，点击「启用」

2. 凭据权限不足 #

你使用的凭据（"My credentials"）可能缺少访问Dataflow资源的权限：

• 确保凭据关联的账号（服务账号或用户）拥有至少一个符合需求的IAM角色：
  • roles/dataflow.viewer：仅用于查看作业
  • roles/dataflow.developer：用于管理作业
  • roles/dataflow.admin：全权限管控
• 操作：
  • 进入项目「IAM与管理员」→「IAM」页面
  • 找到对应账号，点击「编辑」添加上述合适角色

3. 凭据初始化错误 #

检查客户端构建代码，确保凭据正确加载：

• 避免硬编码凭据字符串，使用官方推荐的初始化方式：

private fun dataflow(): Dataflow {
    val credentials = GoogleCredentials.getApplicationDefault()
    return Dataflow.Builder(
        NetHttpTransport(),
        JacksonFactory.getDefaultInstance(),
        HttpRequestInitializer { request ->
            credentials.initialize(request)
            request.connectTimeout = 30000
            request.readTimeout = 30000
        }
    ).setApplicationName("your-app-name").build()
}

4. 区域参数缺失 #

若Dataflow作业运行在特定区域，调用list方法时指定区域可避免跨区域权限问题：

dataflow().projects().jobs().list("myProjectId")
    .setLocation("us-central1") // 替换为你的作业实际所在区域
    .execute()

内容的提问来源于stack exchange，提问作者Atanas S.