NodeJS/Typescript AWS Lambda日志服务：函数终止前日志刷出问题

我来帮你搞定Lambda日志刷出的问题！针对你提到的四种Lambda终止场景，我们可以逐个击破，确保所有日志都能在函数结束前被正确刷出，不会因为Lambda突然终止而丢失关键日志。

Lambda日志丢失的核心原因是异步日志写入/刷出操作还未完成，进程就被终止了。我们的目标就是针对不同终止场景，确保日志刷出的异步操作在Lambda结束前执行完毕。下面结合Node.js/TypeScript给出具体实现，假设你使用的是支持异步刷出的主流日志库（比如pino，其他库思路类似）。

1. 默认终止：所有回调执行完成 #

这种场景下，只要在所有业务逻辑完成后，等待日志库的刷出操作完成即可。如果你的Lambda用的是async/await风格，直接在函数末尾await日志刷出：

import pino from 'pino';

const logger = pino({
  level: process.env.LOG_LEVEL || 'info',
});

export const handler = async (event: any, context: any) => {
  // 执行你的业务逻辑
  logger.info('开始处理事件:', event);
  
  // 等待日志刷出后再让函数自然结束
  await new Promise((resolve) => logger.flush(resolve));
  
  return { statusCode: 200, body: '处理完成' };
};

2. 错误终止：未捕获异常/未处理拒绝 #

这种情况下进程会被强制终止，所以我们需要在全局层面监听错误事件，在终止前先完成日志刷出：

import pino from 'pino';

const logger = pino({
  level: process.env.LOG_LEVEL || 'info',
});

// 全局监听未捕获异常
process.once('uncaughtException', async (err) => {
  logger.error('触发未捕获异常:', err);
  // 等待日志刷出后再退出进程
  await new Promise((resolve) => logger.flush(resolve));
  process.exit(1);
});

// 全局监听未处理的Promise拒绝
process.once('unhandledRejection', async (reason) => {
  logger.error('触发未处理Promise拒绝:', reason);
  await new Promise((resolve) => logger.flush(resolve));
  process.exit(1);
});

export const handler = async (event: any, context: any) => {
  // 模拟抛出未捕获异常
  throw new Error('测试未捕获异常场景');
};

注意用once而非on监听，避免重复绑定导致内存泄漏。

3. 超时终止：运行时长超过设定时间 #

Lambda在超时前会给Node.js进程发送SIGTERM信号（预留几百毫秒的清理时间），我们可以监听这个信号触发日志刷出：

import pino from 'pino';

const logger = pino({
  level: process.env.LOG_LEVEL || 'info',
});

// 监听SIGTERM信号（Lambda超时前触发）
process.once('SIGTERM', async () => {
  logger.warn('收到SIGTERM信号，Lambda即将超时，开始刷日志');
  await new Promise((resolve) => logger.flush(resolve));
  // 无需主动exit，Lambda会自行终止进程
});

export const handler = async (event: any, context: any) => {
  // 模拟超时场景：运行时间超过剩余时长
  await new Promise((resolve) => setTimeout(resolve, context.getRemainingTimeInMillis() + 1000));
};

你也可以主动通过context.getRemainingTimeInMillis()监控剩余时间，比如当剩余时间不足1秒时提前触发日志刷出。

4. 受控终止：调用context.done()/context.succeed() #

如果你仍在使用旧版回调风格的Lambda（更推荐async/await），可以封装这些方法，确保日志刷出后再执行原方法：

import pino from 'pino';

const logger = pino({
  level: process.env.LOG_LEVEL || 'info',
});

// 封装context.done方法
const wrappedDone = async (context: any, err?: Error, result?: any) => {
  await new Promise((resolve) => logger.flush(resolve));
  context.done(err, result);
};

export const handler = (event: any, context: any, callback: any) => {
  logger.info('执行业务逻辑');
  // 使用封装后的方法替代原context.done
  wrappedDone(context, null, { statusCode: 200, body: '处理完成' });
};

把所有逻辑整合起来，形成一个健壮的日志刷出方案：

import pino from 'pino';

const logger = pino({
  level: process.env.LOG_LEVEL || 'info',
});

// 全局错误处理
process.once('uncaughtException', async (err) => {
  logger.error('未捕获异常:', err);
  await new Promise((resolve) => logger.flush(resolve));
  process.exit(1);
});

process.once('unhandledRejection', async (reason) => {
  logger.error('未处理Promise拒绝:', reason);
  await new Promise((resolve) => logger.flush(resolve));
  process.exit(1);
});

// 超时信号处理
process.once('SIGTERM', async () => {
  logger.warn('Lambda即将超时，开始刷日志');
  await new Promise((resolve) => logger.flush(resolve));
});

export const handler = async (event: any, context: any) => {
  try {
    logger.info('开始处理事件:', event);
    
    // 模拟业务操作
    await new Promise((resolve) => setTimeout(resolve, 100));
    
    // 主动检查剩余时间，提前刷日志（可选）
    if (context.getRemainingTimeInMillis() < 1000) {
      logger.warn('剩余时间不足，提前刷日志');
      await new Promise((resolve) => logger.flush(resolve));
    }
    
    return { statusCode: 200, body: JSON.stringify({ message: '处理成功' }) };
  } catch (err) {
    logger.error('业务逻辑出错:', err);
    // 出错时也确保日志刷出
    await new Promise((resolve) => logger.flush(resolve));
    return { statusCode: 500, body: JSON.stringify({ message: '处理失败' }) };
  }
};

• 优先使用async/await风格的Lambda handler，避免回调地狱，也更易控制异步流程。
• 选择支持异步刷出的日志库，比如pino、winston（需配置对应transport的flush方法），避免使用同步日志库（性能差）。
• Lambda的清理时间有限（尤其是超时场景），日志刷出操作要尽量轻量化，不要在刷日志时执行耗时操作。

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