当前位置：首页 > 文章列表 > 文章 > 前端 > 使用 Prisma 和 Nextjs 分析 API 调用趋势：按周、月或年分组

使用 Prisma 和 Nextjs 分析 API 调用趋势：按周、月或年分组

2025-01-27 14:21:52 0浏览收藏

从现在开始，我们要努力学习啦！今天我给大家带来《使用 Prisma 和 Nextjs 分析 API 调用趋势：按周、月或年分组》，感兴趣的朋友请继续看下去吧！下文中的内容我们主要会涉及到等等知识点，如果在阅读本文过程中有遇到不清楚的地方，欢迎留言呀！我们一起讨论，一起学习！

本文将阐述如何利用 Prisma 根据日期（日、月或年）对数据进行分组，并结合 Next.js 和 MongoDB，构建一个 API 调用趋势分析工具。通过这个示例，我们将学习如何查询数据，追踪 API 调用指标，例如一段时间内的成功率和调用频率。

简化 API 调用数据模型

为了有效分析 API 调用趋势，特别是按周、月或年分组，我们需要一个精简的数据模型。以下 Prisma 架构足以满足需求：

model apicall {
  id        string    @id @default(auto()) @map("_id") @db.objectid
  timestamp datetime  @default(now())
  status    apicallstatus // success 或 failure 枚举
}

enum apicallstatus {
  success
  failure
}

该模型记录每个 API 调用的时间戳和状态，为趋势分析提供必要信息。

查询 API 调用趋势

以下代码展示了 Next.js API 端点的实现，该端点通过按不同时间段分组数据，提供 API 调用趋势的洞察。此端点有助于监控 API 使用模式，并有效识别潜在的系统问题：

import { NextRequest, NextResponse } from 'next/server';
import { startOfYear, endOfYear, startOfMonth, endOfMonth } from 'date-fns';

export async function GET(req: NextRequest) {
    const range = req.nextUrl.searchParams.get("range"); // 'year' 或 'month'
    const groupBy = req.nextUrl.searchParams.get("groupBy"); // 'yearly', 'monthly', 'daily'

    if (!range || (range !== 'year' && range !== 'month')) {
        return NextResponse.json({ error: "range 必须为 'year' 或 'month'" }, { status: 400 });
    }

    if (!groupBy || (groupBy !== 'yearly' && groupBy !== 'monthly' && groupBy !== 'daily')) {
        return NextResponse.json({ error: "groupBy 必须为 'yearly', 'monthly' 或 'daily'" }, { status: 400 });
    }

    try {
        let start: Date, end: Date;
        if (range === 'year') {
            start = startOfYear(new Date());
            end = endOfYear(new Date());
        } else { // range === 'month'
            start = startOfMonth(new Date());
            end = endOfMonth(new Date());
        }

        let groupByFormat: string;
        switch (groupBy) {
            case 'yearly':
                groupByFormat = "%Y";
                break;
            case 'monthly':
                groupByFormat = "%Y-%m";
                break;
            case 'daily':
                groupByFormat = "%Y-%m-%d";
                break;
        }

        const apiCallTrends = await db.apicall.aggregateRaw({
            pipeline: [
                {
                    $match: {
                        timestamp: { $gte: { $date: start }, $lte: { $date: end } }
                    }
                },
                {
                    $group: {
                        _id: { $dateToString: { format: groupByFormat, date: '$timestamp' } },
                        success: { $sum: { $cond: [{ $eq: ['$status', 'success'] }, 1, 0] } },
                        failure: { $sum: { $cond: [{ $eq: ['$status', 'failure'] }, 1, 0] } },
                        total: { $sum: 1 }
                    }
                },
                {
                    $sort: {
                        _id: 1
                    }
                }
            ]
        });

        return NextResponse.json({ apiCallTrends });
    } catch (error) {
        console.error(error);
        return NextResponse.json({ error: "获取数据时发生错误。" }, { status: 500 });
    }
}

可能的响应

例如，请求 /api/your-endpoint?range=year&groupBy=monthly 可能返回以下 JSON 数据：

{
  "apiCallTrends": [
    {
      "_id": "2025-01", // 按月份分组 (2025年1月)
      "success": 120,
      "failure": 15,
      "total": 135
    },
    {
      "_id": "2025-02", // 按月份分组 (2025年2月)
      "success": 110,
      "failure": 10,
      "total": 120
    },
    {
      "_id": "2025-03", // 按月份分组 (2025年3月)
      "success": 130,
      "failure": 20,
      "total": 150
    }
    // ...更多按月分组的结果
  ]
}