从分页 RESTful API 高效获取所有数据：以 Atera API 为例

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

composer require guzzlehttp/guzzle

<?php

require 'vendor/autoload.php'; // 引入 Composer 自动加载文件

use GuzzleHttp\Client;
use GuzzleHttp\Exception\GuzzleException;

/**
 * 从 Atera API 获取所有警报数据
 *
 * @param string $apiKey 您的 Atera API Key
 * @param int $itemsPerPage 每页请求的条目数，通常由 API 决定或有最大值
 * @return array 所有警报数据，如果失败则返回空数组
 */
function fetchAllAteraAlerts(string $apiKey, int $itemsPerPage = 20): array
{
    $client = new Client();
    $baseUrl = 'https://app.atera.com/api/v3/alerts';
    $headers = ['X-Api-Key' => $apiKey];
    $allAlerts = []; // 用于存储所有页面的数据
    $currentPage = 1;
    $totalPages = 1; // 初始设为1，以便第一次请求能获取到总页数

    echo "开始从 Atera API 获取所有警报数据...\n";

    try {
        // 循环获取所有页面数据
        while ($currentPage <= $totalPages) {
            echo "正在获取第 {$currentPage} 页 (共 {$totalPages} 页)...\n";

            // 构建请求参数
            $options = [
                'query' => [
                    'page' => $currentPage,
                    'itemsInPage' => $itemsPerPage
                ],
                'headers' => $headers
            ];

            // 发送 GET 请求
            $response = $client->get($baseUrl, $options);
            $data = json_decode($response->getBody()->getContents(), true);

            // 检查 API 响应是否有效
            if (!isset($data['items']) || !is_array($data['items'])) {
                echo "API 响应格式不正确或无数据。\n";
                break; // 退出循环
            }

            // 合并当前页的数据到总数组中
            $allAlerts = array_merge($allAlerts, $data['items']);

            // 在第一次请求时更新总页数
            if ($currentPage === 1) {
                $totalPages = $data['totalPages'] ?? 1;
                echo "API 报告总共有 {$data['totalItemCount']} 条数据，分布在 {$totalPages} 页。\n";
            }

            // 移动到下一页
            $currentPage++;
        }

        echo "成功获取到 " . count($allAlerts) . " 条警报数据。\n";
        return $allAlerts;

    } catch (GuzzleException $e) {
        echo "Guzzle HTTP 请求失败: " . $e->getMessage() . "\n";
        // 实际应用中，可以记录日志、重试或抛出自定义异常
        return [];
    } catch (Exception $e) {
        echo "数据处理失败: " . $e->getMessage() . "\n";
        return [];
    }
}

// --- 示例调用 ---
$ateraApiKey = 'YOUR_ATERA_API_KEY'; // 替换为您的实际 Atera API Key
// 注意：Atera API 的 itemsInPage 似乎固定为 20，即使你请求其他值，它也可能只返回 20。
// 如果 API 允许自定义 itemsInPage 且有最大值，可以在这里设置。
$alerts = fetchAllAteraAlerts($ateraApiKey, 20);

// 此时 $alerts 数组中包含了所有从 Atera API 获取到的警报数据
// 您可以在这里将数据存储到 MongoDB 数据库，例如：
/*
$mongoClient = new MongoDB\Client("mongodb://localhost:27017");
$collection = $mongoClient->mydatabase->alerts;
foreach ($alerts as $alert) {
    $collection->insertOne($alert);
}
echo "所有警报数据已成功存储到 MongoDB。\n";
*/

// 打印部分数据以验证
// print_r(array_slice($alerts, 0, 5)); // 打印前5条数据