如何在AWS NodeJS Lambda中获取V8堆快照及排查调用卡住问题

调用v8.getHeapSnapshot()卡住的核心原因有三个：

• 接口本身是同步全堆遍历操作，V8需要暂停JS执行、遍历堆上所有对象构建对象图，需要至少等于当前已使用堆大小1.5~2倍的空闲连续内存，如果Lambda分配的内存配额不足，V8会进入内存等待状态，既不抛错也不返回，直到Lambda超时。
• 测试代码仅获取了快照的可读流，没有添加消费逻辑，流处于背压阻塞状态，会直接卡住事件循环，在资源配额紧张的Lambda沙箱中不会像本地环境一样自动排空流。
• Amazon Linux 2（AL2）基底的低版本Lambda Node.js运行时（Node.js 14及更早、Node.js 16早期版本）对V8做了编译裁剪，移除了堆快照序列化的部分符号，调用时会卡在内部锁等待，无任何报错输出。

不是全版本默认支持：

• 所有版本的Lambda Node.js运行时都原生支持测试代码中用到的三个统计类接口：v8.getHeapSpaceStatistics()、v8.getHeapCodeStatistics()、v8.getHeapStatistics()，这类接口属于轻量只读操作，不需要遍历全堆、不需要额外内存/IO资源，所以可以正常运行。
• Amazon Linux 2023（AL2023）基底的Node.js 18/20运行时原生支持完整堆快照生成，只要内存配额足够、流被正常消费即可正常输出快照。
• AL2基底的Node.js 16及更早版本不支持直接调用v8.getHeapSnapshot()，调用必然卡住。

以下方案都可以拿到可直接导入Chrome DevTools分析的标准.heapsnapshot文件，不是基础统计指标：

• 方案1：高版本运行时原生调用
  将Lambda运行时升级为Node.js 18/20（AL2023版本），内存配置设置为业务堆峰值的2.5倍以上，补充流消费逻辑，参考代码：

const v8 = require('v8');
const fs = require('fs');

exports.handler = async (event) => {
  // 原有业务逻辑执行完成后再触发生成，避免快照包含无关对象
  console.log("开始生成堆快照");
  const snapshotPath = '/tmp/current.heapsnapshot';
  const writeStream = fs.createWriteStream(snapshotPath);
  const snapshotStream = v8.getHeapSnapshot();
  snapshotStream.pipe(writeStream);

  await new Promise((resolve, reject) => {
    writeStream.on('finish', resolve);
    writeStream.on('error', reject);
    snapshotStream.on('error', reject);
  });
  console.log("堆快照已生成，大小：", fs.statSync(snapshotPath).size, "字节");
  // 可在此处将快照上传到S3等存储服务，本地下载后用Chrome内存分析工具打开
  return { statusCode: 200 };
};

注意：生成快照期间JS执行会完全阻塞，耗时从几百毫秒到数秒不等，建议用单独的测试事件触发，不要在生产正常请求链路中执行。

• 方案2：无侵入运行时参数自动生成
  不需要修改业务代码，直接在Lambda环境变量中添加配置：NODE_OPTIONS=--heap-prof --heap-prof-dir=/tmp --heap-prof-interval=30000，V8会在运行过程中按时间间隔自动生成堆快照到/tmp目录，执行结束后直接上传即可。该方式由V8底层在事件循环空窗期执行，不会出现锁死问题，Node.js 16及以上版本的Lambda运行时均支持。

• 方案3：低版本运行时通过Inspector协议生成
  无法升级运行时的场景下，可以绕过v8模块的直接调用，通过V8 Inspector协议触发快照生成，兼容性更好，参考代码：

const inspector = require('inspector');
const fs = require('fs');
const profilerSession = new inspector.Session();
profilerSession.connect();

exports.handler = async (event) => {
  // 原有业务逻辑
  const snapshotPath = '/tmp/current.heapsnapshot';
  const writeStream = fs.createWriteStream(snapshotPath);
  
  await new Promise((resolve, reject) => {
    profilerSession.on('HeapProfiler.addHeapSnapshotChunk', (chunkMsg) => {
      writeStream.write(chunkMsg.params.chunk);
    });
    profilerSession.post('HeapProfiler.takeHeapSnapshot', { reportProgress: false }, (err) => {
      if (err) return reject(err);
      writeStream.end(resolve);
    });
  });
  // 上传快照逻辑
  return { statusCode: 200 };
};

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