Node/Express部署AWS Lambda后出现间歇性未处理Promise拒绝异常

1. 确保Express正确适配Lambda环境 #

使用serverless-http包装Express应用，并配置callbackWaitsForEmptyEventLoop: false，避免Lambda因等待事件循环空而滞留未处理的Promise：

const serverless = require('serverless-http');
const express = require('express');
const app = express();

// 注册路由、中间件...

// 全局错误处理中间件（必须放在所有路由之后）
app.use((err, req, res, next) => {
  console.error('全局错误栈:', err.stack);
  res.status(500).json({ message: '服务器内部错误' });
});

module.exports.handler = serverless(app, {
  callbackWaitsForEmptyEventLoop: false
});

2. 严格捕获所有异步操作的异常 #

所有S3、RDS的异步操作必须用try/catch包裹，或通过.catch()兜底，杜绝异常冒泡到全局：

const { S3Client, GetObjectCommand } = require('@aws-sdk/client-s3');

let s3Client;
const getS3Client = () => {
  if (!s3Client) {
    s3Client = new S3Client({ region: 'us-east-1' });
  }
  return s3Client;
};

app.get('/fetch-s3-file', async (req, res, next) => {
  try {
    const client = getS3Client();
    const command = new GetObjectCommand({ Bucket: 'my-bucket', Key: 'demo.txt' });
    const response = await client.send(command);
    // 处理响应逻辑
    res.send('操作完成');
  } catch (err) {
    console.error('S3操作失败:', err);
    next(err); // 交给全局错误中间件统一处理
  }
});

3. 优化数据库连接池配置 #

Lambda执行环境会复用，需限制连接池大小避免连接耗尽，且每次使用后主动释放连接：

const mysql = require('mysql2/promise');

let dbPool;
const getDbPool = async () => {
  if (!dbPool) {
    dbPool = mysql.createPool({
      host: 'rds-hostname',
      user: 'db-user',
      password: 'db-pass',
      database: 'db-name',
      connectionLimit: 3, // 适配Lambda资源，避免连接过载
      waitForConnections: true
    });
  }
  return dbPool;
};

app.get('/fetch-db-data', async (req, res, next) => {
  let connection;
  try {
    const pool = await getDbPool();
    connection = await pool.getConnection();
    const [rows] = await connection.query('SELECT * FROM users LIMIT 10');
    res.json(rows);
  } catch (err) {
    next(err);
  } finally {
    if (connection) connection.release(); // 释放连接回池
  }
});

4. 定位具体错误来源 #

• 查看Lambda的CloudWatch日志，找到未处理Promise拒绝的完整栈跟踪，定位到具体代码行
• 检查是否有遗漏的异步操作（比如未用await的Promise，或未添加.catch()的链式调用）

5. 处理Lambda环境复用的异常 #

Lambda热启动会复用之前的执行环境，若全局初始化的客户端（S3/RDS）出现异常，需添加重新初始化逻辑：

const getS3Client = () => {
  // 如果客户端已损坏，重新创建实例
  if (!s3Client || s3Client._destroyed) {
    s3Client = new S3Client({ region: 'us-east-1' });
  }
  return s3Client;
};

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