Amazon Bedrock 모델 Telemetry

import {
  BedrockRuntimeClient,
  ConverseCommand,
} from "@aws-sdk/client-bedrock-runtime";
import telemetry from "telemetry-sh";

const bedrock = new BedrockRuntimeClient({ region: process.env.AWS_REGION });
const startedAt = performance.now();
const modelId = process.env.BEDROCK_MODEL_ID;

try {
  const response = await bedrock.send(new ConverseCommand({
    modelId,
    messages,
  }));

  await telemetry.log("llm_request_completed", {
    provider: "aws_bedrock",
    model: modelId,
    region: process.env.AWS_REGION,
    feature: "research_assistant",
    status: "success",
    latency_ms: Math.round(performance.now() - startedAt),
    input_tokens: response.usage?.inputTokens,
    output_tokens: response.usage?.outputTokens,
    total_tokens: response.usage?.totalTokens,
    finish_reason: response.stopReason,
  });

  return response;
} catch (error) {
  await telemetry.log("llm_request_completed", {
    provider: "aws_bedrock",
    model: modelId,
    region: process.env.AWS_REGION,
    feature: "research_assistant",
    status: "failed",
    latency_ms: Math.round(performance.now() - startedAt),
    error_type: classifyProviderError(error),
  });
  throw error;
}