Pino日志是否内置支持将日志输出至MongoDB表？

Pino 本身没有内置直接输出到 MongoDB 的功能，但可以通过官方生态插件或自定义传输器轻松实现，以下是两种常用方案：

1. 使用官方社区插件 pino-mongodb #

这是 Pino 生态中专门适配 MongoDB 的传输插件，配置简单，能直接将日志写入指定集合。

安装 #

npm install pino-mongodb

基本使用 #

命令行管道传输

启动应用时通过管道将 Pino 输出传给插件：

node your-app.js | pino-mongodb mongodb://localhost:27017/your-db-name

代码内集成配置

在应用代码中直接配置传输器：

const pino = require('pino');

const logger = pino({
  level: 'info'
}, pino.transport({
  target: 'pino-mongodb',
  options: {
    uri: 'mongodb://localhost:27017/your-db-name',
    collection: 'app-logs', // 指定存储日志的集合名称
    writeConcern: { w: 1 } // 可选，配置 MongoDB 写入确认策略
  }
}));

logger.info('这条日志会被写入 MongoDB');

2. 自定义 Pino 传输器 #

如果需要更灵活的控制（比如日志字段转换、过滤特定级别日志），可以自行实现简单的传输逻辑：

const pino = require('pino');
const { MongoClient } = require('mongodb');

// 初始化 MongoDB 客户端
const client = new MongoClient('mongodb://localhost:27017/your-db-name');
client.connect().catch(err => console.error('MongoDB 连接失败:', err));

const customMongoTransport = {
  async write(log) {
    try {
      const db = client.db();
      // 可在此对日志对象做自定义处理，比如添加额外字段、过滤内容
      await db.collection('custom-logs').insertOne(JSON.parse(log));
    } catch (err) {
      console.error('写入 MongoDB 失败:', err);
    }
  }
};

const logger = pino(customMongoTransport);
logger.error('通过自定义传输器写入的错误日志');

注意事项 #

• 确保 MongoDB 服务正常运行，且应用拥有目标数据库的读写权限
• 高并发场景下建议配置 MongoDB 连接池，避免连接耗尽
• 可给日志集合设置过期索引，自动清理旧日志以节省存储空间

内容的提问来源于stack exchange，提问作者J.Doe