BetterStack 监控

// src/telemetry/index.ts
import { NodeSDK } from "@opentelemetry/sdk-node";

const sdk = new NodeSDK({
  resource,
  sampler: new TraceIdRatioBasedSampler(0.1), // 10% 采样率
  spanProcessors: [new BatchSpanProcessor(traceExporter)],
  metricReader: new PeriodicExportingMetricReader({
    exporter: metricExporter,
    exportIntervalMillis: 30000,
  }),
  instrumentations: [
    new HttpInstrumentation(),
    new FetchInstrumentation(),
    new UndiciInstrumentation(),
    new IORedisInstrumentation(),
  ],
});

IMGPROXY_OPEN_TELEMETRY_ENABLE = "true"
IMGPROXY_OPEN_TELEMETRY_ENABLE_METRICS = "true"
OTEL_EXPORTER_OTLP_PROTOCOL = "http/protobuf"
OTEL_SERVICE_NAME = "kira-imgproxy"

import { logs } from "@opentelemetry/api-logs";

const logger = logs.getLogger("kira-be");

logger.emit({
  severityText: "INFO",
  body: "User generated image",
  attributes: {
    userId: "xxx",
    toolName: "generateImageWithAI",
    durationMs: 1234,
  },
});

// src/telemetry/logger.ts
export function logAIToolExecuted(
  toolName: string,
  resourceId: string,
  threadId: string,
  durationMs: number
) {
  logger.emit({
    severityText: "INFO",
    body: `AI tool executed: ${toolName}`,
    attributes: {
      "tool_name": toolName,
      "user_id": resourceId,
      "thread_id": threadId,
      "duration_ms": durationMs,
    },
  });
}

// src/telemetry/external.ts
export const ExternalService = {
  FAL: "fal",
  REPLICATE: "replicate",
  OPENAI: "openai",
  ANTHROPIC: "anthropic",
  GOOGLE: "google",
  XAI: "xai",
  BYTEPLUS: "byteplus",
  IDEOGRAM: "ideogram",
  RECRAFT: "recraft",
  COHERE: "cohere",
  SERPER: "serper",
} as const;

// 使用示例
const response = await tracedFetch(url, options, {
  service: ExternalService.BYTEPLUS,
  operation: "seedream_edit",
});

// src/telemetry/metrics.ts
export function recordAITool(
  toolName: string,
  success: boolean,
  durationMs: number
) {
  aiToolCounter.add(1, {
    tool_name: toolName,
    success: success.toString(),
  });
  aiToolDuration.record(durationMs, {
    tool_name: toolName,
    success: success.toString(),
  });
}

SELECT
  toStartOfInterval(dt, INTERVAL 1 minute) as time,
  avgMerge(metric_name) as value
FROM {{source}}
WHERE dt BETWEEN {{start_time}} AND {{end_time}}
GROUP BY time
ORDER BY time

SELECT
  toStartOfInterval(dt, INTERVAL 1 minute) as time,
  avgMerge(workers_utilization) * 100 as utilization
FROM {{source}}
WHERE dt BETWEEN {{start_time}} AND {{end_time}}
GROUP BY time
ORDER BY time

SELECT
  toStartOfInterval(dt, INTERVAL 1 minute) as time,
  maxMerge(process_mb) as process_mb,
  maxMerge(vips_mb) as vips_mb
FROM {{source}}
WHERE dt BETWEEN {{start_time}} AND {{end_time}}
GROUP BY time
ORDER BY time

SELECT
  toStartOfInterval(dt, INTERVAL 1 minute) as time,
  maxMerge(images_in_progress) as images,
  maxMerge(requests_in_progress) as requests
FROM {{source}}
WHERE dt BETWEEN {{start_time}} AND {{end_time}}
GROUP BY time
ORDER BY time

// src/hono/middleware/auth.ts
const payload = c.get("jwtPayload");
if (payload?.sub) {
  Sentry.setUser({
    id: payload.sub,
    email: payload.email,
  });
}

// login-provider.tsx
useEffect(() => {
  if (isAuth && profile) {
    Sentry.setUser({
      id: profile.id,
      email: profile.email,
      username: profile.nickname,
    });
  } else {
    Sentry.setUser(null);
  }
}, [isAuth, profile]);

// src/telemetry/sentry.ts - 初始化示例
import * as Sentry from "@sentry/bun";

Sentry.init({
  dsn: process.env.SENTRY_DSN,
  // ...配置
});

# BetterStack
BETTERSTACK_HOST=in-otel.logs.betterstack.com
BETTERSTACK_TOKEN=xxx

# Sentry
SENTRY_DSN=https://xxx@o.betterstack.com/xxx

# PostHog (Analytics)
POSTHOG_API_KEY=xxx
POSTHOG_PROJECT_ID=xxx