在 Deno 中入门 OpenTelemetry

import { metrics, trace } from "npm:@opentelemetry/api@1";

// 为我们的应用创建 tracer 和 meter
const tracer = trace.getTracer("my-server", "1.0.0");
const meter = metrics.getMeter("my-server", "1.0.0");

// 创建一些指标
const requestCounter = meter.createCounter("http_requests_total", {
  description: "HTTP 请求总数",
});

const requestDuration = meter.createHistogram("http_request_duration_ms", {
  description: "HTTP 请求持续时间（毫秒）",
  unit: "ms",
});

// 启动服务器
Deno.serve({ port: 8000 }, (req) => {
  // 记录请求开始时间，以测量请求持续时间
  const startTime = performance.now();

  // 为该请求创建一个 span
  return tracer.startActiveSpan("handle_request", async (span) => {
    try {
      // 从 URL 中提取路径
      const url = new URL(req.url);
      const path = url.pathname;

      // 为 span 添加属性
      span.setAttribute("http.route", path);
      span.setAttribute("http.method", req.method);
      span.updateName(`${req.method} ${path}`);

      // 为 span 添加事件
      span.addEvent("request_started", {
        timestamp: startTime,
        request_path: path,
      });

      // 模拟一些处理时间
      const waitTime = Math.random() * 100;
      await new Promise((resolve) => setTimeout(resolve, waitTime));

      // 为 span 添加另一个事件
      span.addEvent("processing_completed");

      // 创建响应
      const response = new Response(`Hello from ${path}!`, {
        headers: { "Content-Type": "text/plain" },
      });

      // 记录指标
      requestCounter.add(1, {
        method: req.method,
        path,
        status: 200,
      });

      const duration = performance.now() - startTime;
      requestDuration.record(duration, {
        method: req.method,
        path,
      });

      span.setAttribute("request.duration_ms", duration);

      return response;
    } catch (error) {
      // 在 span 中记录错误
      if (error instanceof Error) {
        span.recordException(error);
        span.setStatus({
          code: trace.SpanStatusCode.ERROR,
          message: error.message,
        });
      }

      return new Response("内部服务器错误", { status: 500 });
    } finally {
      // 始终结束 span
      span.end();
    }
  });
});

// 向不同路径发送 10 个请求
for (let i = 0; i < 10; i++) {
  const path = ["", "about", "users", "products", "contact"][i % 5];
  const url = `http://localhost:8000/${path}`;

  console.log(`正在向 ${url} 发送请求`);

  try {
    const response = await fetch(url);
    const text = await response.text();
    console.log(`来自 ${url} 的响应：${text}`);
  } catch (error) {
    console.error(`获取 ${url} 时出错：`, error);
  }
}