如何通过管道将子进程stdout/stderr用WinstonJS记录？

你这个思路方向是对的——用管道（pipe）来衔接子进程的输出和Winston日志，但问题在于Winston的Logger实例本身并没有直接提供一个可以被pipe的Writable接口（毕竟Winston是日志输出工具，它是数据的消费者，而不是生产者）。我们需要做一层简单的转换，把子进程的流数据转成Winston能处理的日志条目。

下面给你两种实用的实现方式：

方法一：自定义Writable Stream对接Winston #

我们可以用Node.js内置的stream.Writable创建一个自定义流，每次接收到子进程的输出数据时，就调用Winston的日志方法把内容记录下来。

const { Writable } = require('stream');
const winston = require('winston');
const { spawn } = require('child_process');

// 1. 先初始化你的Winston Logger
const logger = winston.createLogger({
  level: 'info',
  format: winston.format.combine(
    winston.format.timestamp(),
    winston.format.printf(({ timestamp, level, message }) => {
      return `${timestamp} [${level.toUpperCase()}] ${message}`;
    })
  ),
  transports: [
    new winston.transports.Console(),
    new winston.transports.File({ filename: 'child-process.log' })
  ]
});

// 2. 创建通用的Winston流生成函数
function createWinstonLogStream(logLevel = 'info') {
  return new Writable({
    // 禁用对象模式，因为子进程输出的是Buffer/字符串
    objectMode: false,
    write(chunk, encoding, callback) {
      // 把Buffer转成字符串，去掉首尾的换行/空白
      const logMessage = chunk.toString(encoding).trim();
      
      // 避免记录空内容
      if (logMessage) {
        logger[logLevel](logMessage);
      }
      
      // 通知流已处理完当前数据
      callback();
    }
  });
}

// 3. 启动子进程并对接管道
const childProcess = spawn('your-command-here', ['arg1', 'arg2']);

// stdout 对应 info 级别日志
childProcess.stdout.pipe(createWinstonLogStream('info'));
// stderr 对应 error 级别日志
childProcess.stderr.pipe(createWinstonLogStream('error'));

方法二：直接监听data事件（替代pipe的简化方案） #

如果你觉得自定义流有点繁琐，也可以直接监听子进程stdout和stderr的data事件，本质上和pipe是一样的逻辑，只是写法更直接：

const winston = require('winston');
const { spawn } = require('child_process');

// 初始化Winston Logger（同上）
const logger = winston.createLogger({ /* ...配置... */ });

const childProcess = spawn('your-command-here');

// 处理stdout输出
childProcess.stdout.on('data', (chunk) => {
  const message = chunk.toString().trim();
  if (message) logger.info(message);
});

// 处理stderr输出
childProcess.stderr.on('data', (chunk) => {
  const message = chunk.toString().trim();
  if (message) logger.error(message);
});

关键注意事项 #

• 编码处理：子进程输出的是Buffer，记得转成字符串时指定正确的编码（默认utf8一般没问题）。
• 空行过滤：子进程可能会输出空行，记得用trim()过滤掉，避免生成无意义的空日志。
• 日志级别区分：建议把stdout对应info级别，stderr对应error级别，这样后续排查问题时更容易区分。
• 自定义前缀：如果需要标识日志来自子进程，可以在日志消息前加前缀，比如logger.info([child] ${message})。

内容的提问来源于stack exchange，提问作者Sebastian