
本文旨在解决在使用 php 的 BigQuery API 时,遇到的“Not found: Job project-id:job-id”的 404 错误。该错误通常是由于缺少指定作业的 地理位置 信息引起的。通过在 getQueryResults 方法中传递包含 location 参数的数组,可以成功获取查询结果。
在使用 PHP 的 google BigQuery API 时,可能会遇到一个常见的错误,即在尝试通过 getQueryResults 方法获取查询结果时,收到http 404 错误,错误信息类似于 “Not found: Job my-project:job-id”。这通常发生在 BigQuery 作业在特定 地理位置(location)执行的情况下。
问题分析
默认情况下,BigQuery 作业可以在全球位置运行。但是,有时为了满足数据驻留要求或优化性能,作业可能被配置为在特定的地理位置(例如 europe-west1)运行。当作业在特定位置运行时,在使用 getQueryResults 方法获取结果时,必须明确指定该位置。如果未指定位置,BigQuery API 将尝试在全球位置查找该作业,从而导致 404 错误。
立即学习“PHP 免费学习笔记(深入)”;
解决方案
google_Service_Bigquery_Jobs::getQueryResults 方法接受第三个可选参数,该参数允许您传递其他配置选项。我们可以利用此参数来指定作业的地理位置。
以下是解决此问题的示例代码:
$projectId = 'your-project-id'; $jobId = 'your-job-id'; $location = 'europe-west1'; // 替换为你的作业运行的实际位置 $arrLocation = Array("location" => $location); $queryResults = $bq->jobs->getQueryResults($projectId, $jobId, $arrLocation); // 现在,$queryResults 变量应该包含查询结果
代码解释:
- $projectId: 替换为你的 Google Cloud 项目的 ID。
- $jobId: 替换为你要获取结果的 BigQuery 作业的 ID。这个 job ID 可以在 BigQuery 控制台或通过 $job-youjiankuohaophpcngetJobReference()[‘jobId’]获取。
- $location: 替换为作业运行的实际地理位置。可以在 BigQuery 控制台中查看作业的详细信息以确定其位置。常见的例子包括 europe-west1,us-central1 等。
- $arrLocation = array(“location” => $location);: 创建一个包含 location 键的 关联数组,并将位置值设置为变量 $location。
- $queryResults = $bq->jobs->getQueryResults($projectId, $jobId, $arrLocation);: 调用 getQueryResults 方法,并将项目 ID、作业 ID 和包含位置信息的数组作为参数传递。
完整示例
require_once 'vendor/autoload.php'; // 确保已安装 Google API 客户端库 use GoogleClient; use GoogleServiceBigquery; use GoogleServiceBigqueryJob; use GoogleServiceBigqueryJobConfiguration; use GoogleServiceBigqueryJobConfigurationQuery; $projectId = 'your-project-id'; $location = 'europe-west1'; // 替换为你的作业运行的实际位置 $query = "SELECT 1"; // 你的 BigQuery 查询 $client = new Client(); $client->setapplicationName('Google-BigQuery'); $client->useApplicationDefaultCredentials(); $client->addScope(Bigquery::BIGQUERY); $bq = new Bigquery($client); $job = new Job(); $config = new JobConfiguration(); $queryConfig = new JobConfigurationQuery(); $config->setQuery($queryConfig); $job->setConfiguration($config); $queryConfig->setQuery($query); $job = $bq->jobs->insert($projectId, $job); $jobId = $job->getJobReference()->getJobId(); // 等待作业完成(可以添加轮询机制)sleep(5); $arrLocation = array("location" => $location); try {$queryResults = $bq->jobs->getQueryResults($projectId, $jobId, $arrLocation); if ($queryResults->getTotalRows() > 0) {foreach ($queryResults->getRows() as $row) {foreach ($row->getF() as $field) {echo $field->getV() . "n"; } } } else {echo "No results found.n";} } catch (Exception $e) {echo 'Caught exception:', $e->getMessage(), "n"; }
注意事项
- 确保已安装 Google API 客户端库。可以使用 composer 进行安装:composer require google/apiclient
- 确保你的 Google Cloud 项目已启用 BigQuery API。
- 确保你的应用程序具有访问 BigQuery 的适当权限。在使用 useApplicationDefaultCredentials()时,App Engine 环境会自动处理身份验证。在其他环境中,可能需要使用服务帐户密钥。
- 如果作业仍在运行,getQueryResults 方法可能会返回错误。建议在调用 getQueryResults 之前,检查作业的状态。
- 如果作业运行在默认的全球位置,则不需要指定 location 参数。
总结
通过在 getQueryResults 方法中显式指定作业的地理位置,可以有效解决在使用 PHP BigQuery API 时遇到的 404 错误。这确保了 API 能够正确找到并检索指定位置的作业结果。请务必根据你的 BigQuery 作业的实际配置调整代码,并确保应用程序具有访问 BigQuery 的适当权限。