高效获取分页API数据：以Atera API为例的Guzzle实践指南

{
  "items": [
    {
      "AlertID": xxxx,
      // ... 其他警报数据 ...
    }
  ],
  "totalItemCount": 6783, // 总共有6783条记录
  "page": 1,             // 当前是第1页
  "itemsInPage": 20,     // 每页返回20条记录
  "totalPages": 290,     // 总共有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\RequestException;

/**
 * 从Atera API获取所有警报数据。
 *
 * @param string $apiKey 你的Atera API Key。
 * @return array 包含所有警报数据的数组。
 */
function fetchAllAteraAlerts(string $apiKey): array
{
    $client = new Client();
    $baseUrl = 'https://app.atera.com/api/v3/alerts';
    $headers = ['X-Api-Key' => $apiKey];
    $allAlerts = []; // 用于存储所有警报数据的数组
    $currentPage = 1; // 从第一页开始
    $itemsPerPage = 20; // Atera API默认或推荐的每页条目数

    // totalPages会在第一次请求成功后更新
    $totalPages = 1; 

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

    while ($currentPage <= $totalPages) {
        try {
            echo "正在获取第 " . $currentPage . " 页数据...\n";
            $response = $client->get($baseUrl, [
                'headers' => $headers,
                'query' => [
                    'page' => $currentPage,
                    'itemsInPage' => $itemsPerPage
                ]
            ]);

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

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

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

            // 在第一次请求成功后更新总页数
            if ($currentPage === 1 && isset($data['totalPages'])) {
                $totalPages = $data['totalPages'];
                echo "总共有 " . $totalPages . " 页数据。\n";
            }

            $currentPage++; // 准备获取下一页

            // 可选：添加一个小的延迟，以避免触发API限速
            // sleep(0.1); // 暂停100毫秒

        } catch (RequestException $e) {
            // 处理Guzzle请求异常（如网络错误、HTTP 4xx/5xx错误）
            echo "请求第 " . $currentPage . " 页数据时发生错误: " . $e->getMessage() . "\n";
            if ($e->hasResponse()) {
                echo "响应内容: " . $e->getResponse()->getBody()->getContents() . "\n";
            }
            break; // 发生错误时退出循环
        } catch (Exception $e) {
            // 处理其他通用异常
            echo "发生未知错误: " . $e->getMessage() . "\n";
            break; // 发生错误时退出循环
        }
    }

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

// --- 示例用法 ---
$yourAteraApiKey = 'YOUR_ATERA_API_KEY'; // 替换为你的实际Atera API Key

// 调用函数获取所有数据
$allAteraData = fetchAllAteraAlerts($yourAteraApiKey);

// 现在 $allAteraData 包含了从Atera API获取的所有警报记录
// 你可以将其存储到数据库、进行分析或进一步处理
// print_r($allAteraData); // 打印所有数据（如果数据量大，请谨慎使用）

// 假设你希望将数据存储到MongoDB，这里只是一个概念性的示例
// $mongoClient = new MongoDB\Client("mongodb://localhost:27017");
// $collection = $mongoClient->yourDatabase->yourCollection;
// foreach ($allAteraData as $item) {
//     $collection->insertOne($item);
// }
// echo "所有数据已尝试插入到MongoDB。\n";

?>