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: {
      "ai.tool.name": toolName,
      "user.id": resourceId,
      "thread.id": threadId,
      "duration.ms": durationMs,
    },
  });
}

// src/telemetry/external.ts
export enum ExternalService {
  FAL = "fal",
  REPLICATE = "replicate",
  OPENAI = "openai",
  ANTHROPIC = "anthropic",
  GOOGLE = "google",
  XAI = "xai",
  BYTEPLUS = "byteplus",
  ILLUSTRIOUS = "illustrious",
}

// 使用示例
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,
  });
}

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]);

try {
  // ...
} catch (error) {
  Sentry.captureException(error, {
    tags: {
      toolName: "generateImageWithAI",
    },
    extra: {
      input: sanitizedInput,
    },
  });
  throw error;
}

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

# Sentry
SENTRY_DSN=https://[email protected]/xxx

# PostHog (Analytics)
POSTHOG_API_KEY=xxx
POSTHOG_PROJECT_ID=xxx