
本文旨在解决在使用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的适当权限。