温斯顿结构化事件分析

import winston from "winston";

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

async function recordOutcome(data) {
  try {
    const receipt = await fetch("https://api.telemetry.sh/log", {
      method: "POST",
      headers: {
        Authorization: process.env.TELEMETRY_API_KEY,
        "Content-Type": "application/json",
      },
      body: JSON.stringify({ table: "job_completed", data }),
      signal: AbortSignal.timeout(2_000),
    });
    if (!receipt.ok) console.warn("Telemetry ingestion failed", receipt.status);
  } catch {
    console.warn("Telemetry ingestion unavailable");
  }
}

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 recordOutcome(outcome);
  return result;
} catch (error) {
  const outcome = {
    operation: "customer_import",
    job_id: jobId,
    status: "failed",
    duration_ms: Math.round(performance.now() - startedAt),
    error_type: "import_error",
    release: process.env.APP_RELEASE,
  };

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