如何通过Google Cloud Scheduler调用Google BigQuery存储过程？

问题核心 #

你在Cloud Scheduler中单独调用BigQuery存储过程时返回INVALID_ARGUMENT错误，但执行普通DDL语句正常，排除了权限和拼写问题，核心原因是请求体缺少BigQuery API要求的关键标识字段，或存储过程调用格式不规范。

修正后的请求体 #

直接使用以下JSON作为Cloud Scheduler的请求体，替换为你的实际项目/数据集/存储过程名称：

{
  "kind": "bigquery#queryRequest",
  "query": "CALL `project-id.dataset.procedure`();",
  "useLegacySql": false,
  "defaultDataset": {
    "datasetId": "dataset",
    "projectId": "project-id"
  }
}

关键调整说明 #

1. 添加kind字段：BigQuery的HTTP API要求明确请求类型，"kind": "bigquery#queryRequest"是标识该请求为标准SQL查询的必要字段，缺失会导致API无法正确解析请求。
2. 规范存储过程引用：必须用反引号（`）包裹存储过程的完全限定名，这是BigQuery标准SQL的强制规范，即使名称无特殊字符也需遵守。
3. 指定默认数据集：通过defaultDataset明确存储过程所属的数据集，避免API解析存储过程内部对象时出现歧义。

额外优化建议 #

如果存储过程执行涉及多个数据源同步，耗时较长，可添加超时设置延长请求有效期：

{
  "kind": "bigquery#queryRequest",
  "query": "CALL `project-id.dataset.procedure`();",
  "useLegacySql": false,
  "defaultDataset": {
    "datasetId": "dataset",
    "projectId": "project-id"
  },
  "timeoutMs": 3600000
}

（timeoutMs单位为毫秒，示例设置为1小时，可根据实际执行时间调整）

验证步骤 #

1. 替换请求体中的项目、数据集、存储过程名称为实际值。
2. 保持Cloud Scheduler的配置：Target Type为HTTP，HTTP Method为POST，Content-Type为application/json，OAuth令牌使用原有有效配置。
3. 触发任务，检查BigQuery的Job历史记录确认执行状态。

内容的提问来源于stack exchange，提问作者Jimi J