Grafana에서 파일 전송 상태 대시보드 만들기

┌──────────────────────────────────────────────────────┐
│                   File Transfer                     │
│                                                      │
│  Flow A ──┐                                         │
│  Flow B ──┼──▶ Run / Transfer Metrics               │
│  Flow C ──┘                 │                        │
└─────────────────────────────┼────────────────────────┘
                              │
                              ▼
                     Monitoring Data
                              │
                              ▼
┌──────────────────────────────────────────────────────┐
│                       Grafana                        │
│                                                      │
│  Total Transfer │ Progress │ Completed │ Failed     │
│                                                      │
│  Retry Count    │ Transfer Trend │ Flow Status      │
└──────────────────────────────────────────────────────┘

Grafana Dashboard
        │
        ├── Transfer Volume
        │
        ├── Completed
        │
        ├── Failed
        │
        └── Retrying
                │
                ▼
          Flow Identification
                │
                ▼
             Run Details
                │
                ▼
        Source / Target Check

Transfer Flow
      │
      ▼
     Run
      │
      ├── Total Files
      ├── Total Size
      ├── Progress
      ├── Status
      └── Retry
              │
              ▼
        Metrics / Events
              │
              ▼
           Grafana

┌───────────────────────────────────────────────────┐
│               FILE TRANSFER OVERVIEW              │
├─────────────┬─────────────┬──────────┬────────────┤
│ In Progress │ Completed   │ Failed   │ Retrying   │
│     12      │    248      │    3     │     2      │
├───────────────────────────────────────────────────┤
│                                                   │
│              Transfer Volume Trend                │
│                                                   │
│        ╱╲        ╱╲                               │
│   ╱───╱  ╲──╱╲──╱  ╲────                          │
│                                                   │
├───────────────────────────┬───────────────────────┤
│ Flow Status               │ Retry / Failure Trend │
│                           │                       │
│ Flow A  Completed         │ ↑ Failure             │
│ Flow B  Running           │ → Retry               │
│ Flow C  Failed            │ ↓ Recovery            │
└───────────────────────────┴───────────────────────┘

                    Transfer Volume
                           │
        ┌──────────────────┼──────────────────┐
        ▼                  ▼                  ▼
     Time Range         Flow Name          Target
        │                  │                  │
        ▼                  ▼                  ▼
    Hour / Day       Backup Flow         Amazon S3
                     Report Flow         File Server
                     Media Flow          Cloud Storage

                    Run Status
                        │
       ┌────────────────┼────────────────┐
       ▼                ▼                ▼
   Completed          Failed          Retrying
       │                │                │
       ▼                ▼                ▼
   Success Count    Failure Count    Retry Count
       │                │                │
       └────────────────┼────────────────┘
                        ▼
                  Grafana Dashboard
                        │
                        ▼
                Status Trend Analysis

┌──────────────────────────────────────────────┐
│                 Flow Status                  │
├────────────────┬────────────┬───────────────┤
│ Flow           │ Transfer   │ Current State │
├────────────────┼────────────┼───────────────┤
│ Backup         │ 1.2 TB     │ Completed     │
│ Daily Report   │ 48 GB      │ Completed     │
│ Media Upload   │ 860 GB     │ Retrying      │
│ Archive        │ 2.4 TB     │ Failed        │
└────────────────┴────────────┴───────────────┘

Dashboard Check
      │
      ▼
Metric Change
      │
      ├── Transfer Volume Increase
      │
      ├── Failed Count Increase
      │
      └── Retry Repeated
                │
                ▼
           Identify Flow
                │
                ▼
            Check Run
                │
         ┌──────┼──────┐
         ▼      ▼      ▼
      Source  Files   Target
         │      │      │
         └──────┼──────┘
                ▼
          Environment Check

┌─────────────────┐
│ Grafana         │
│ Dashboard       │
└────────┬────────┘
         │
         │ Overall Status
         ▼
┌─────────────────┐
│ Flow            │
│ Identification  │
└────────┬────────┘
         │
         ▼
┌─────────────────┐
│ Run Details     │
└────────┬────────┘
         │
    ┌────┴─────┐
    ▼          ▼
Normal       Issue
    │          │
    │          ▼
    │    Environment Check
    │          │
    │          ▼
    │        Retry
    │          │
    └──────────┘
         │
         ▼
   Updated Metrics
         │
         ▼
 Grafana Dashboard

def transfer_metrics(start_date, end_date, limit=200):
    counts = {}   # status -> count
    cursor = None
    while True:
        params = {"startDate": start_date, "endDate": end_date, "limit": limit}
        if cursor:
            params["cursor"] = cursor
        page = api("GET", "/api/transfer-history", params=params) or {}

        for row in (page.get("data") or []):
            status = row.get("status")
            counts[status] = counts.get(status, 0) + 1

        cursor = (page.get("pagination") or {}).get("nextCursor")
        if not cursor:
            break

    # metric shape read by the Grafana JSON datasource
    return {
        "completed": counts.get(2, 0),
        "error": counts.get(4, 0),
        "partial": counts.get(9, 0),
        "total": sum(counts.values()),
    }


metrics = transfer_metrics("2026-09-01T00:00:00Z", "2026-09-07T23:59:59Z")
print(metrics)   # e.g. {"completed": 120, "error": 3, "partial": 1, "total": 124}

static Map<String, Integer> transferMetrics(InnorixClient client, String startDate,
        String endDate, int limit) {
    Map<Integer, Integer> counts = new HashMap<>();
    String cursor = null;
    do {
        Map<String, Object> params = Json.newObj("startDate", startDate, "endDate", endDate, "limit", limit);
        if (cursor != null) params.put("cursor", cursor);
        Map<String, Object> page = client.apiObj("GET", "/api/transfer-history", null, params);

        for (Object row : Json.arrOf(page, "data")) {
            Integer status = Json.intOrNull(Json.asObj(row), "status");
            counts.merge(status, 1, Integer::sum);
        }
        Map<String, Object> pg = Json.asObj(page.get("pagination"));
        cursor = pg == null ? null : Json.str(pg, "nextCursor");
    } while (cursor != null);

    int total = counts.values().stream().mapToInt(Integer::intValue).sum();
    return Map.of(
            "completed", counts.getOrDefault(2, 0),
            "error", counts.getOrDefault(4, 0),
            "partial", counts.getOrDefault(9, 0),
            "total", total);
}

async function transferMetrics(startDate, endDate, limit = 200) {
  const counts = {};
  let cursor = null;
  do {
    const params = { startDate, endDate, limit };
    if (cursor) params.cursor = cursor;
    const page = (await api("GET", "/api/transfer-history", null, params)) || {};

    for (const row of page.data || []) counts[row.status] = (counts[row.status] || 0) + 1;
    cursor = (page.pagination || {}).nextCursor;
  } while (cursor);

  const total = Object.values(counts).reduce((a, b) => a + b, 0);
  return {
    completed: counts[2] || 0,
    error: counts[4] || 0,
    partial: counts[9] || 0,
    total,
  };
}

const metrics = await transferMetrics("2026-09-01T00:00:00Z", "2026-09-07T23:59:59Z");
console.log(metrics);

static async Task<Dictionary<string, int>> TransferMetricsAsync(InnorixClient client,
    string startDate, string endDate, int limit = 200)
{
    var counts = new Dictionary<int, int>();
    string cursor = null;
    do
    {
        var pars = new Dictionary<string, object> { ["startDate"] = startDate, ["endDate"] = endDate, ["limit"] = limit };
        if (cursor != null) pars["cursor"] = cursor;
        JsonObject page = await client.ApiObjAsync("GET", "/api/transfer-history", null, pars);

        foreach (JsonNode row in J.ArrOf(page, "data"))
        {
            int? status = J.IntOrNull(row, "status");
            int key = status ?? -1;
            counts[key] = counts.GetValueOrDefault(key) + 1;
        }
        JsonObject pg = J.AsObj(page["pagination"]);
        cursor = pg == null ? null : J.Str(pg, "nextCursor");
    } while (cursor != null);

    int total = counts.Values.Sum();
    return new Dictionary<string, int>
    {
        ["completed"] = counts.GetValueOrDefault(2),
        ["error"] = counts.GetValueOrDefault(4),
        ["partial"] = counts.GetValueOrDefault(9),
        ["total"] = total,
    };
}

전송 이력·활성 목록 API 조회 (기간·상태·커서)
   ↓  상태별 집계 (완료·실패·부분)
지표 JSON 노출
   ↓  Grafana JSON 데이터소스가 조회
Grafana 대시보드 패널