API网关调用Lambda函数时出现间歇性500状态码错误如何解决

报错Cannot read property 'query' of undefined的核心原因是代码未处理pool.getConnection的错误：当数据库连接获取失败时，返回的connection对象为undefined，直接调用query方法就会触发该报错。

偶发、且看起来仅部分课程触发的原因：

• 连接池未配置connectionLimit参数，默认最大连接数为10，当Lambda并发请求量上升时，连接池耗尽就会导致连接获取失败
• Lambda执行环境复用、RDS闲置连接超时会导致池中的连接失效，此时获取连接也会返回错误
• 查询频率更高的课程更容易命中上述场景，所以看起来和特定课程绑定，实际和课程数据无关

除此之外，原代码直接拼接SQL参数存在严重的SQL注入漏洞，需要同步修复。

核心修改点 #

1. 新增pool.getConnection的错误捕获逻辑，连接获取失败时直接返回错误，不操作空的connection对象
2. 补充连接池配置参数，设置合理的连接数上限、超时时间
3. 将拼接SQL改为参数化查询，避免SQL注入风险
4. 调整连接释放逻辑，无论查询是否成功都先释放连接，避免连接泄漏

修复后代码 #

const mysql = require("mysql");
const config = require("./config.json");

const pool = mysql.createPool({
  host: config.dbhost,
  user: config.dbuser,
  password: config.dbpassword,
  database: config.dbname,
  multipleStatements: true,
  // 新增连接池配置，可根据实际业务场景调整参数值
  connectionLimit: 10,
  acquireTimeout: 3000,
  timeout: 6000
});

exports.handler = (event, context, callback) => {
  context.callbackWaitsForEmptyEventLoop = false;
  pool.getConnection(function (err, connection) {
    // 新增连接错误判断，是解决当前报错的核心
    if (err) {
      return callback(new Error(`数据库连接失败: ${err.message}`));
    }
    // 改为参数化查询，避免SQL注入
    connection.query(
      "SELECT * from course where id = ?",
      [event.pathParameters.id],
      function (error, results, fields) {
        // 优先释放连接，避免连接泄漏
        connection.release();
        if (error) {
          return callback(new Error(`查询失败: ${error.message}`));
        }
        callback(null, results[0] || {});
      }
    );
  });
};

如果仍偶发连接错误，可做进一步优化：

• 将Lambda部署到和RDS相同的VPC私有子网中，避免公网网络波动导致连接失败
• 配置RDS Proxy统一管理数据库连接，避免高并发场景下RDS连接数被打满
• 在连接池中添加心跳检测逻辑，定期清理失效的闲置连接

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