BigQuery PHP客户端查询结果404错误：区域性作业的处理

<?php

require __DIR__ . '/vendor/autoload.php';

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

// 1. 初始化Google客户端
$client = new Client();
$client->setApplicationName('Google-BigQuery-PHP-App');

// 如果在App Engine等Google Cloud环境中运行，可以使用默认凭据
// 否则，需要通过服务账号密钥文件进行认证
$client->useApplicationDefaultCredentials();

// 设置必要的API作用域
$client->addScope('https://www.googleapis.com/auth/bigquery');
$client->addScope('https://www.googleapis.com/auth/devstorage.read_write'); // 如果涉及存储操作，可能需要此权限

// 2. 创建BigQuery服务对象
$bq = new Bigquery($client);

// 3. 构建查询作业配置
$query = "SELECT * FROM `your-project.your_dataset.your_table` LIMIT 100"; // 替换为你的SQL查询

$queryConfig = new JobConfigurationQuery();
$queryConfig->setQuery($query);
// 可以选择性设置默认项目ID，如果查询中未完全限定表名
// $queryConfig->setDefaultDataset(new Google_Service_Bigquery_DatasetReference(['projectId' => 'your-project', 'datasetId' => 'your_dataset']));

$config = new JobConfiguration();
$config->setQuery($queryConfig);

$job = new Job();
$job->setConfiguration($config);

// 4. 提交查询作业
$projectId = 'your-project-id'; // 替换为你的Google Cloud项目ID
try {
    $submittedJob = $bq->jobs->insert($projectId, $job);
    $jobReference = $submittedJob->getJobReference();
    $jobId = $jobReference->getJobId();
    echo "BigQuery作业提交成功，作业ID: " . $jobId . PHP_EOL;
} catch (Exception $e) {
    echo "作业提交失败: " . $e->getMessage() . PHP_EOL;
    exit;
}

// 后续步骤：获取查询结果 (这正是问题所在)
// ...

{
  "error": {
    "code": 404,
    "message": "Not found: Job my-project:job-id",
    "errors": [...]
  }
}

// 假设 $jobId 和 $projectId 已经正确获取
try {
    $queryResults = $bq->jobs->getQueryResults($projectId, $jobId); // 此时可能抛出404错误
    // ... 处理结果 ...
} catch (Exception $e) {
    echo "获取查询结果失败: " . $e->getMessage() . PHP_EOL;
}

<?php

// ... (省略前面的客户端初始化、认证和作业提交代码) ...

// 假设 $jobId 和 $projectId 已经正确获取
$jobId = $jobReference->getJobId(); // 从 jobs->insert 返回的 jobReference 中获取
$projectId = 'your-project-id'; // 你的项目ID

// 确定BigQuery作业实际执行的区域
// 这个区域信息通常在提交作业时确定，或者可以在BigQuery控制台中查看作业详情获取。
$jobLocation = 'europe-west1'; // 替换为你的BigQuery作业实际执行的区域

// 构建包含 location 参数的数组
$arrLocation = array("location" => $jobLocation);

try {
    // 正确的解决方案：传递 location 参数
    $queryResults = $bq->jobs->getQueryResults($projectId, $jobId, $arrLocation);

    echo "成功获取查询结果！" . PHP_EOL;

    // 遍历并处理查询结果
    if ($queryResults->getRows()) {
        foreach ($queryResults->getRows() as $row) {
            foreach ($row->getF() as $field) {
                echo $field->getV() . "\t";
            }
            echo PHP_EOL;
        }
    } else {
        echo "查询没有返回任何行。" . PHP_EOL;
    }

} catch (Exception $e) {
    echo "获取查询结果失败: " . $e->getMessage() . PHP_EOL;
    // 捕获并打印详细的错误信息，有助于调试
    if (method_exists($e, 'getErrors')) {
        print_r($e->getErrors());
    }
}