高效获取Atera RESTful API全量数据：分页机制与Guzzle实现

{
  "items": [
    {
      "AlertID": xxxx,
      "Code": xxxx,
      // ... 其他告警详情
    }
  ],
  "totalItemCount": 6783,  // 数据总条目数
  "page": 1,               // 当前页码
  "itemsInPage": 20,       // 当前页的条目数
  "totalPages": 290,       // 总页数
  "prevLink": "",
  "nextLink": "http://app.atera.com/api/v3/alerts?page=2&itemsInPage=20" // 下一页的链接
}

<?php

require 'vendor/autoload.php'; // 确保Guzzle库已加载

use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;

/**
 * 从Atera API获取所有告警数据
 *
 * @param string $apiKey 您的Atera API密钥
 * @param int $itemsPerPage 每页请求的条目数，Atera API默认为20，可尝试更高值（如50、100）
 * @return array 包含所有告警数据的数组
 */
function fetchAllAteraAlerts(string $apiKey, int $itemsPerPage = 20): array
{
    $client = new Client();
    $baseUrl = 'https://app.atera.com/api/v3/alerts';
    $allAlerts = [];
    $currentPage = 1;
    $totalPages = 1; // 初始设置为1，以便第一次循环执行

    echo "开始从Atera API获取数据...\n";

    do {
        try {
            echo "正在获取第 {$currentPage} 页 (每页 {$itemsPerPage} 条)...\n";
            $response = $client->get($baseUrl, [
                'query' => [
                    'page' => $currentPage,
                    'itemsInPage' => $itemsPerPage,
                ],
                'headers' => [
                    'X-Api-Key' => $apiKey,
                    'Content-Type' => 'application/json',
                    'Accept' => 'application/json',
                ],
                'timeout' => 30, // 请求超时时间（秒）
                'connect_timeout' => 5, // 连接超时时间（秒）
            ]);

            $data = json_decode($response->getBody()->getContents(), true);

            // 检查API响应是否有效
            if (empty($data) || !isset($data['items'])) {
                echo "API响应为空或缺少'items'键，停止获取。\n";
                break;
            }

            // 累加当前页的数据
            $allAlerts = array_merge($allAlerts, $data['items']);

            // 第一次请求时获取总页数和总条目数
            if ($currentPage === 1) {
                $totalPages = $data['totalPages'] ?? 1;
                echo "API报告总条目数: {$data['totalItemCount']}, 总页数: {$totalPages}\n";
            }

            $currentPage++;

            // 建议：为避免API限速，可以在每次请求后暂停一小段时间
            // sleep(1); // 每次请求后暂停1秒

        } catch (RequestException $e) {
            echo "请求API失败: " . $e->getMessage() . "\n";
            if ($e->hasResponse()) {
                echo "API响应体: " . $e->getResponse()->getBody()->getContents() . "\n";
            }
            // 遇到错误可以选择重试或直接退出
            break; // 遇到错误则停止
        } catch (Exception $e) {
            echo "发生未知错误: " . $e->getMessage() . "\n";
            break;
        }

    } while ($currentPage <= $totalPages); // 当当前页小于或等于总页数时继续循环

    echo "数据获取完成。共获取到 " . count($allAlerts) . " 条数据。\n";
    return $allAlerts;
}

// --- 示例用法 ---
$ateraApiKey = 'YOUR_ATERA_API_KEY'; // 替换为您的实际API密钥
$retrievedAlerts = fetchAllAteraAlerts($ateraApiKey, 50); // 尝试每页获取50条

// 打印部分数据进行验证
echo "--- 前5条获取到的告警数据 ---\n";
print_r(array_slice($retrievedAlerts, 0, 5));

// --- 将数据存入MongoDB或其他数据库的示例 ---
// 假设您已经安装了MongoDB PHP驱动
// require 'vendor/autoload.php';
// use MongoDB\Client as MongoClient;
//
// try {
//     $mongoClient = new MongoClient("mongodb://localhost:27017"); // 根据您的MongoDB配置修改
//     $collection = $mongoClient->selectCollection('your_database_name', 'atera_alerts_collection');
//
//     if (!empty($retrievedAlerts)) {
//         // 批量插入所有获取到的数据
//         $result = $collection->insertMany($retrievedAlerts);
//         echo "数据已成功导入MongoDB。插入文档数: " . $result->getInsertedCount() . "\n";
//     } else {
//         echo "没有数据可导入MongoDB。\n";
//     }
// } catch (Exception $e) {
//     echo "MongoDB连接或插入失败: " . $e->getMessage() . "\n";
// }

?>