ウィンストンの構造化イベント分析

import winston from "winston";
import telemetry from "telemetry-sh";

const logger = winston.createLogger({
  format: winston.format.json(),
  transports: [new winston.transports.Console()],
});

const startedAt = performance.now();
try {
  const result = await processImport();
  const outcome = {
    operation: "customer_import",
    job_id: jobId,
    status: "success",
    duration_ms: Math.round(performance.now() - startedAt),
    item_count: result.itemCount,
    release: process.env.APP_RELEASE,
  };

  logger.info("customer import completed", outcome);
  await telemetry.log("job_completed", outcome);
  return result;
} catch (error) {
  const outcome = {
    operation: "customer_import",
    job_id: jobId,
    status: "failed",
    duration_ms: Math.round(performance.now() - startedAt),
    error_type: classifyError(error),
    release: process.env.APP_RELEASE,
  };

  logger.error("customer import failed", { ...outcome, error });
  await telemetry.log("job_completed", outcome);
  throw error;
}