当前位置：首页 > 文章列表 > 文章 > 前端 > NestJS + Opentelemetry (Loki)

NestJS + Opentelemetry (Loki)

来源：dev.to 2024-08-19 08:07:02 0浏览收藏

小伙伴们对文章编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《NestJS + Opentelemetry (Loki)》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

先决条件

opentelemetry collector 必须准备好。（去准备吧）
grafana 设置查看 opentelemetry 跟踪（转到准备）
（可选）opentelemetry知识（遇到困难可以学习^0^）（去学习）
（可选）nestjs + opentelemetry 帖子（查看）

nestjs 到 loki

本来，当你设置零代码opentelemetry时，日志应该自动发送到otel收集器并累积在loki中。

但是，日志记录自动仪器存在问题，因此如果设置不当，日志不会累积。

（感谢这个bug，我研究了otel?）

如何正确设置自动

问题中的组合方法。（嗯，这不是魔法）

auto-instrumentation in sdk (not working)
instrumentation-winston in sdk (not working)
instrumentation-winston in sdk + winston-transport in logger transports (working)
auto-instrumentation in sdk + winston-transport in logger transports (working)
auto-instrumentation in sdk + winston-transport installed only (working)

最后原因是instrumentation-winston没有包含winston-transport依赖，所以必须单独安装

请务必执行 npm install @opentelemetry/winston-transport。

如果你运气好并且设置正确的话，就不需要按照下面的方法了

温斯顿

我决定让 winston 作为记录器。我本来用的是pino，但看到这篇文章后改成了winston。 (+网上有更多关于winston的信息)

即使你使用的是pino，下面的方法仍然适用。

代码

手动设置 loggerprovider

创建一个新文件 logger.ts 来设置记录器。

import { otlplogexporter } from "@opentelemetry/exporter-logs-otlp-http";
import { resource } from "@opentelemetry/resources";
import {
  batchlogrecordprocessor,
  loggerprovider,
} from "@opentelemetry/sdk-logs";
import {
  semresattrs_service_name,
  semresattrs_service_version,
} from "@opentelemetry/semantic-conventions";
import { opentelemetrytransportv3 } from "@opentelemetry/winston-transport";

const logexporter = new otlplogexporter();
const loggerprovider = new loggerprovider({
  resource: new resource({
    [semresattrs_service_name]: "your-service-name",
    [semresattrs_service_version]: "1.0",
  }),
});

loggerprovider.addlogrecordprocessor(
  new batchlogrecordprocessor(logexporter)
  // new simplelogrecordprocessor(new consolelogrecordexporter())
);
api.logs.setgloballoggerprovider(loggerprovider);

创建loggerprovider，连接exporter、resource、processor，然后在globalloggerprovider中设置。

创建温斯顿记录器

之后，创建一个用于nestjs的winston logger。还写入 logger.ts。

import { opentelemetrytransportv3 } from "@opentelemetry/winston-transport";

export default function createlogger() {
  const transports = [
    new winston.transports.console({
      format: winston.format.combine(
        winston.format.timestamp({ format: "yyyy-mm-ddthh:mm:ss.sssz" }),
        winston.format.json(),
        winston.format.ms(),
        nestwinstonmoduleutilities.format.nestlike("api", {
          colors: true,
          prettyprint: true,
          processid: true,
          appname: true,
        })
      ),
    }),
    new opentelemetrytransportv3(),
  ];
  const logger = winstonmodule.createlogger({
    defaultmeta: { environment: process.env.node_env },
    transports,
  });

  return logger;
}

这里，opentelemetrytransportv3被注册为winston的transport，允许将winston的日志导出到oltp。

导入记录器

与 tracer 一样，logger 也是在 main.ts 顶部导入。

// eslint-disable-next-line import/order
import otelsdk from "./tracer"; // otelsdk should be imported before any other imports
// eslint-disable-next-line import/order
import createlogger from "./logger";

连接记录器

创建nestapp时，会创建并移交一个记录器。这取代了 nestjs/common 中的记录器。

  const app = await nestfactory.create<nestexpressapplication>(
    appmodule,
    new expressadapter(expressapp),
    {
      logger: createlogger(),