Sequelize在AWS Lambda环境中查询数据偶发失败的解决方法咨询

为什么「每次请求开关连接」的方案不生效 #

• Lambda 存在执行环境复用机制：冷启动创建的容器会被后续的请求复用，你在单次请求结束时关闭了连接，但保存在内存中的Sequelize实例没有被销毁，下次请求拿到的是已经被关闭的无效连接实例，自然会查询失败。
• 你的代码存在异步逻辑错误：ps.connection.close() 是异步方法，你在city存在/不存在的分支中调用时没有加 await，连接还没完成关闭流程函数就已经返回，导致连接状态混乱，复用容器时就会出现随机失败的问题。
• 多余的符号错误：你返回City not found的消息里多写了一个反引号 'City not found'`，会导致JSON序列化异常，也是你返回空响应的诱因之一。

• 修正基础逻辑错误 #

  所有调用 ps.connection.close() 的位置都补充 await，删除响应消息中多余的反引号，避免语法级别的异常。

• 复用数据库连接，不要每次请求都销毁 #

  将Sequelize连接实例的初始化逻辑放到函数全局作用域，仅在冷启动时创建一次连接，后续复用容器时直接使用已经初始化的连接，避免频繁创建销毁连接带来的性能损耗和状态异常：

  // 全局初始化，仅冷启动时执行一次
  const { Postgresql: ps } = require('../libs/utils/potsgresql');
  const City = require(/* 你的模型路径 */);
  
  const findCityByPk = async (pathParameters) => {
    const { id } = pathParameters;
    // 业务逻辑
  }
  

• 调整Sequelize连接池配置适配Lambda #

  Lambda单容器同一时间只能处理一个请求，连接池可以调整为如下配置，避免拿过期连接：

  conn = new Sequelize(string_connection, { 
    logging: false, 
    pool: { 
      max: 2, // 单请求场景预留1个备用连接即可
      min: 0, 
      idle: 10000, // 闲置10秒后销毁连接
      acquire: 3000, // 获取连接超时时间3秒
      evict: 2000 // 每2秒扫描一次闲置连接
    } 
  });
  

• 增加连接存活检测逻辑 #

  每次执行业务查询前先调用 sequelize.authenticate() 检测连接是否存活，如果连接失效则自动重建，避免用过期连接查询：

  try {
    // 先检测连接
    await ps.connection.authenticate();
    const city = await City.findByPk(id);
    // 后续逻辑
  } catch (err) {
    // 连接失效时重建
    ps.connection = createConnection();
    // 重试查询或者返回错误
  }
  

• 正常场景不要主动关闭连接 #

  去掉请求结束后的close调用，把连接还给连接池由连接池自动管理生命周期，只有捕获到连接级别的致命错误时再主动销毁连接。

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