01
// 以分钟为粒度生成时间 key，如 "2026-03-13T10:05"
02
function getMinuteKey(): string {
03
  return new Date().toISOString().slice(0, 16)
04
}
05

06
class MetricsCollector {
07
  private counters: Map<string, number> = new Map()
08
  private histograms: Map<string, number[]> = new Map()
09

10
  // 累加计数器：比如每来一个请求 increment('requests')
11
  increment(name: string, value: number = 1) {
12
    this.counters.set(name, (this.counters.get(name) ?? 0) + value)
13
  }
14

15
  // 记录一个观测值：比如每次请求 observe('latency.total', 1350)
16
  observe(name: string, value: number) {
17
    const arr = this.histograms.get(name) ?? []
18
    arr.push(value)
19
    this.histograms.set(name, arr)
20
  }
21

22
  // 将本次请求收集的指标写入 KV
23
  async flush(env: { KV: KVNamespace }) {
24
    const minute = getMinuteKey()
25

26
    for (const [name, value] of this.counters) {
27
      const key = `metrics:counter:${name}:${minute}`
28
      const existing = Number(await env.KV.get(key) ?? '0')
29
      await env.KV.put(key, String(existing + value), { expirationTtl: 86400 })
30
    }
31

32
    for (const [name, values] of this.histograms) {
33
      const key = `metrics:histogram:${name}:${minute}`
34
      const existing = JSON.parse(await env.KV.get(key) ?? '[]') as number[]
35
      await env.KV.put(key, JSON.stringify([...existing, ...values]), {
36
        expirationTtl: 86400
37
      })
38
    }
39
  }
40
}

01
const metrics = new MetricsCollector()
02

03
// 延迟指标：记录每个节点的耗时（单位 ms）
04
metrics.observe('latency.safety_check', safetyCheckDuration)
05
metrics.observe('latency.memory_retrieval', memoryRetrievalDuration)
06
metrics.observe('latency.llm_generation', llmDuration)
07
metrics.observe('latency.total', totalDuration)
08

09
// 检索质量指标
10
metrics.increment('retrieval.total_requests')
11
if (memories.length > 0) metrics.increment('retrieval.hit_requests')
12
metrics.observe('retrieval.count', memories.length)
13
metrics.observe('retrieval.top_score', memories[0]?.score ?? 0)
14

15
// 成本指标
16
metrics.increment('tokens.input', inputTokenCount)
17
metrics.increment('tokens.output', outputTokenCount)
18

19
// 情绪分布指标：每种情绪各自计数
20
metrics.increment(`emotion.${currentEmotion}`)
21

22
// 在 Hono 框架中，c 是请求上下文对象
23
// c.executionCtx 对应 Workers 原生的 ExecutionContext（上一篇用的 ctx）
24
// c.env 对应 Workers 原生的 env（绑定的 D1、KV 等资源）
25
c.executionCtx.waitUntil(metrics.flush(c.env))

1
const traces = await env.DB.prepare(
2
  `SELECT trace_id, total_duration, has_error, has_degraded, created_at
3
   FROM traces
4
   WHERE user_id = ? AND created_at BETWEEN ? AND ?
5
   ORDER BY created_at DESC`
6
).bind(userId, startTime, endTime).all()

1
const spans = await env.DB.prepare(
2
  `SELECT name, duration, status, input, output, metadata
3
   FROM spans WHERE trace_id = ? ORDER BY start_time`
4
).bind(traceId).all()