BigQuery PHP API 404错误解决方法

本文旨在解决在使用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错误。

解决方案

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 变量应该包含查询结果

代码解释：

1. $projectId: 替换为你的Google Cloud项目的ID。
2. $jobId: 替换为你要获取结果的BigQuery作业的ID。 这个job ID可以在BigQuery控制台或通过$job->getJobReference()['jobId']获取。
3. $location: 替换为作业运行的实际地理位置。 可以在BigQuery控制台中查看作业的详细信息以确定其位置。 常见的例子包括 europe-west1，us-central1等。
4. $arrLocation = array("location" => $location);: 创建一个包含 location 键的关联数组，并将位置值设置为变量 $location。
5. $queryResults = $bq->jobs->getQueryResults($projectId, $jobId, $arrLocation);: 调用getQueryResults 方法，并将项目ID、作业ID和包含位置信息的数组作为参数传递。

完整示例

require_once 'vendor/autoload.php'; // 确保已安装Google API客户端库

use Google\Client;
use Google\Service\Bigquery;
use Google\Service\Bigquery\Job;
use Google\Service\Bigquery\JobConfiguration;
use Google\Service\Bigquery\JobConfigurationQuery;

$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的适当权限。