从Atera API高效获取全量分页数据教程

{
  "items": [ /* ... 数据项 ... */ ],
  "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已通过Composer安装

use GuzzleHttp\Client;

$client = new Client();
$uri = 'https://app.atera.com/api/v3/alerts';
$header = ['headers' => ['X-Api-Key' => 'xxxxxxx']]; // 替换为您的API密钥
$res = $client->get($uri, $header);
$data = json_decode($res->getBody()->getContents(), true);

// 此时 $data['items'] 中只会包含当前页（默认第一页）的20条数据
// print_r($data);
?>

<?php
require 'vendor/autoload.php'; // 确保Guzzle已通过Composer安装

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

/**
 * 从Atera API获取所有告警数据
 *
 * @param string $apiKey 您的Atera API密钥
 * @return array 包含所有告警数据项的数组
 */
function fetchAllAteraAlerts(string $apiKey): array
{
    $client = new Client();
    $baseUri = 'https://app.atera.com/api/v3/alerts';
    $headers = ['X-Api-Key' => $apiKey];
    $allAlerts = []; // 用于存储所有获取到的告警数据
    $currentPage = 1; // 从第一页开始
    $itemsPerPage = 20; // 根据API响应，每页默认或最大条目数
    $totalPages = 1; // 初始化总页数，确保循环至少执行一次

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

    do {
        try {
            echo "正在获取第 {$currentPage} 页数据 (每页 {$itemsPerPage} 条)...\n";

            // 发送GET请求，通过query参数指定页码和每页条目数
            $response = $client->get($baseUri, [
                'query' => [
                    'page' => $currentPage,
                    'itemsInPage' => $itemsPerPage
                ],
                'headers' => $headers
            ]);

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

            // 检查API响应是否包含数据项
            if (isset($data['items']) && is_array($data['items'])) {
                $allAlerts = array_merge($allAlerts, $data['items']); // 将当前页数据合并到总数组中
                echo "已获取 " . count($data['items']) . " 条告警数据。当前总数: " . count($allAlerts) . "\n";
            }

            // 在第一次请求时或当总页数更新时，更新总页数
            if ($currentPage === 1 && isset($data['totalPages'])) {
                $totalPages = $data['totalPages'];
            }
            // 如果API在后续请求中更新了总页数（虽然不常见），我们也应更新
            else if (isset($data['totalPages']) && $data['totalPages'] > $totalPages) {
                $totalPages = $data['totalPages'];
            }

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

        } catch (RequestException $e) {
            // 处理Guzzle HTTP请求异常（如网络错误、API返回非2xx状态码）
            echo "API 请求失败: " . $e->getMessage() . "\n";
            if ($e->hasResponse()) {
                echo "响应内容: " . $e->getResponse()->getBody()->getContents() . "\n";
            }
            break; // 发生错误时退出循环
        } catch (Exception $e) {
            // 处理其他未知异常
            echo "发生未知错误: " . $e->getMessage() . "\n";
            break; // 发生错误时退出循环
        }

        // 可以在此处添加一个短暂的延迟，以避免触发API的速率限制
        // usleep(500000); // 暂停500毫秒 (0.5秒)

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

    echo "所有告警数据获取完毕。总计 " . count($allAlerts) . " 条。\n";
    return $allAlerts;
}

// --- 使用示例 ---
// 替换为您的实际 Atera API 密钥
$myApiKey = 'YOUR_ATERA_API_KEY_HERE';

// 调用函数获取所有告警数据
$alerts = fetchAllAteraAlerts($myApiKey);

// 打印部分结果以验证
echo "\n--- 前5条告警数据示例 ---\n";
print_r(array_slice($alerts, 0, 5));

// --- 将数据存储到 MongoDB (示例，您需要根据实际情况实现) ---
/*
// 假设您已经安装了 MongoDB PHP 驱动并配置好
// require 'vendor/autoload.php';
// use MongoDB\Client as MongoClient;

try {
    $mongoClient = new MongoClient("mongodb://localhost:27017"); // 您的MongoDB连接字符串
    $database = $mongoClient->yourDatabaseName; // 您的数据库名
    $collection = $database->yourCollectionName; // 您的集合名

    // 清空现有数据（可选）
    // $collection->drop();

    // 批量插入所有获取到的告警数据
    if (!empty($alerts)) {
        $insertResult = $collection->insertMany($alerts);
        echo "\n成功将 " . $insertResult->getInsertedCount() . " 条数据存储到 MongoDB。\n";
    } else {
        echo "\n没有数据可存储到 MongoDB。\n";
    }
} catch (Exception $e) {
    echo "\n存储数据到 MongoDB 失败: " . $e->getMessage() . "\n";
}
*/
?>