我来帮你搞定这个Lambda里MySQL连接复用的问题——这绝对是无服务器场景里的高频坑，很多人一开始都会像你示例里那样走弯路。先拆解下你现有代码的问题，再给你一套靠谱的实现方案。

先说说你当前代码的问题 #

你的示例里在Lambda handler内部创建连接，还调用了db.getConnection().end()关闭连接，这就完全失去了复用的意义：每次请求都新建、关闭连接，不仅性能差，还会触发MySQL的连接数限制。另外，就算你把连接移到handler外部，不处理连接超时/断开的情况，也会遇到闲置连接被MySQL服务器踢掉后，下次请求报错的问题。

正确的实现思路：用连接池+Lambda容器复用 #

Lambda的容器复用特性是关键——当你的函数被频繁调用时，AWS会复用之前的容器，所以我们可以在handler外部初始化连接池，让连接池在容器生命周期内保持，从而实现连接复用。同时要配置连接池的超时参数，处理连接断开后的自动重连。

第一步：编写db.js（连接池初始化）

"use strict";
const mysql = require('mysql2/promise'); // 用promise版本更适合异步场景

// 配置连接池参数
const poolConfig = {
  host: '你的MySQL主机地址',
  user: '用户名',
  password: '密码',
  database: '数据库名',
  connectionLimit: 10, // 根据你的Lambda并发数调整，别超过MySQL的max_connections
  connectTimeout: 10000, // 连接超时时间（毫秒）
  acquireTimeout: 10000, // 获取连接超时时间
  waitForConnections: true, // 没有可用连接时等待
  queueLimit: 0, // 无限制等待队列
  enableKeepAlive: true, // 启用TCP长连接
  keepAliveInitialDelay: 30000 // 30秒后发送第一个keepalive包
};

// 创建连接池
const pool = mysql.createPool(poolConfig);

// 监听连接错误，方便排查问题
pool.on('connection', (conn) => {
  console.log(`新建MySQL连接，线程ID：${conn.threadId}`);
});

pool.on('error', (err) => {
  console.error('MySQL连接池错误:', err);
  // 如果连接断开，连接池会自动尝试重建，无需手动处理
});

module.exports = pool;

第二步：编写Lambda Handler

"use strict";
const pool = require('./db');

exports.handler = async (event, context) => {
  // 关键设置：告诉Lambda不要等待事件循环为空再返回
  // 避免因为连接池保持连接导致函数超时
  context.callbackWaitsForEmptyEventLoop = false;

  let connection;
  try {
    // 从连接池获取连接
    connection = await pool.getConnection();
    console.log(`复用MySQL连接，线程ID：${connection.threadId}`);

    // 执行查询
    const [result] = await connection.execute(
      "INSERT INTO employee(name,salary) VALUES(?,?)",
      ['Joe', 8000]
    );
    console.log(`新增员工成功，影响行数：${result.affectedRows}`);

    return {
      statusCode: 200,
      body: JSON.stringify({ message: "Database operation done" })
    };
  } catch (err) {
    console.error('数据库操作失败:', err);
    return {
      statusCode: 500,
      body: JSON.stringify({ error: "Database operation failed" })
    };
  } finally {
    // 释放连接回连接池，而不是关闭连接
    if (connection) {
      connection.release();
      console.log(`连接已释放回池，线程ID：${connection.threadId}`);
    }
  }
};

核心要点解释 #

• 连接池放在handler外部：利用Lambda容器复用，连接池会在容器启动时初始化一次，后续请求直接复用池中的连接。
• 配置长连接和超时参数：enableKeepAlive和keepAliveInitialDelay能防止TCP连接被中间网络设备断开；connectTimeout和acquireTimeout避免请求因为等待连接超时失败。
• 不要关闭连接池：只需要在每次请求后release连接，把连接放回池里供下一次请求复用。
• 设置callbackWaitsForEmptyEventLoop为false：Lambda默认会等待事件循环为空才返回结果，而连接池的连接会保持在事件循环里，设置这个参数能让函数执行完后立即返回，避免超时。

额外注意事项 #

• 调整connectionLimit：根据你的Lambda并发上限来设置，比如如果你的函数最大并发是50，那connectionLimit设为10-20就够了，别超过MySQL的max_connections（默认一般是151）。
• 测试连接断开场景：比如重启MySQL服务器，看Lambda是否能自动从连接池获取新连接，不会报错。
• 监控连接数：在MySQL里用SHOW PROCESSLIST查看连接数，确保不会出现连接耗尽的情况。

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