如何在AWS Serverless架构中通过Lambda访问第三方MySQL数据库？

我来帮你捋清楚这个问题——其实在Serverless架构下Lambda里处理MySQL的核心差异，和你本地Express环境主要在依赖打包、网络访问这两个关键点上，咱们一步步解决：

你在本地Express里能正常用require('./mysqldata')，是因为本地已经安装了mysql或mysql2这类依赖，且模块路径正确。但Serverless部署Lambda时，需要把这些依赖一起打包上传，不然Lambda运行时会找不到模块。

解决步骤：

• 在你的Serverless项目根目录（就是放serverless.yml的文件夹），安装MySQL依赖：

  npm install mysql2 --save
  

• 检查serverless.yml的打包配置，别不小心排除了依赖：
  默认情况下Serverless会打包node_modules里的内容，但如果你自定义了package.exclude，要确保没把mysql2相关文件排除。示例配置：

  package:
    exclude:
      - .git/**
      - tests/**
      # 不要写 - node_modules/** 这类会排除所有依赖的规则
  

• 确认本地自定义模块mysqldata.js的路径正确：如果它和Lambda handler文件在同一目录，require('./mysqldata')没问题；如果在子目录，要调整路径比如require('./utils/mysqldata')。

这是最容易踩坑的点！如果你的第三方MySQL部署在私有网络（比如自己的VPC、云服务商私有实例），Lambda默认运行在AWS公有网络里，根本连不上目标MySQL。

操作步骤：

• 在serverless.yml的函数配置里，把Lambda加入到MySQL所在的VPC中：

  functions:
    yourFunctionName:
      handler: handler.yourMainHandler
      vpc:
        securityGroupIds:
          - sg-xxxxxx # 这个安全组要允许访问MySQL的3306端口
        subnetIds:
          - subnet-xxxxxx # 填写MySQL所在VPC的子网ID（建议至少填两个跨可用区的子网）
  

• 同步调整MySQL的安全组规则：允许来自Lambda所在安全组的入站流量（端口3306），不然就算Lambda进了VPC，MySQL也会拒绝连接。

Lambda是无状态的，每次调用可能触发冷启动，所以不能像Express那样保持长连接，推荐用连接池来提高效率，避免频繁创建销毁连接。

给你一个mysqldata.js的示例（用mysql2连接池）：

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

// 用环境变量存配置，绝对不要硬编码敏感信息！
const pool = mysql.createPool({
  host: process.env.MYSQL_HOST,
  user: process.env.MYSQL_USER,
  password: process.env.MYSQL_PASSWORD,
  database: process.env.MYSQL_DB,
  connectionLimit: 5, // 根据Lambda并发量调整
  waitForConnections: true
});

async function fetchThirdPartyData() {
  let connection;
  try {
    connection = await pool.getConnection();
    const [rows] = await connection.execute('SELECT * FROM your_target_table WHERE condition = ?', [someParam]);
    return rows;
  } catch (err) {
    console.error('MySQL查询出错:', err);
    throw err;
  } finally {
    if (connection) connection.release(); // 把连接放回池里，不要直接关闭
  }
}

module.exports = { fetchThirdPartyData };

然后在Lambda handler里调用：

const { fetchThirdPartyData } = require('./mysqldata');
const dynamodbdata = require('./getMember');

exports.handler = async (event) => {
  try {
    // 获取MySQL数据
    const mysqlResult = await fetchThirdPartyData();
    // 执行DynamoDB的CRUD操作
    await dynamodbdata.saveMember(mysqlResult);
    return { statusCode: 200, body: JSON.stringify({ success: true }) };
  } catch (err) {
    return { statusCode: 500, body: JSON.stringify({ error: err.message }) };
  }
};

另外，把MySQL的敏感配置放到Lambda环境变量里，在serverless.yml里配置：

functions:
  yourFunctionName:
    handler: handler.yourMainHandler
    environment:
      MYSQL_HOST: your-mysql-host-address
      MYSQL_USER: your-mysql-username
      MYSQL_PASSWORD: ${ssm:/your/mysql/password} # 推荐用SSM参数存储密码，不要明文写
      MYSQL_DB: your-target-database-name

如果还是不行，去CloudWatch Logs看Lambda的运行日志：

• 若报错Cannot find module 'mysql2'：说明依赖没打包进去，用serverless package生成部署包，解压看看里面有没有node_modules/mysql2；
• 若报错ETIMEDOUT/ECONNREFUSED：网络问题，检查VPC子网、安全组规则，确认MySQL端口开放，Lambda能解析到MySQL的域名/IP；
• 若报错Access denied for user：检查环境变量里的用户名密码是否正确，同时确认MySQL用户权限允许从Lambda的IP访问（比如用户权限是user@'%'而非user@特定IP）。

内容的提问来源于stack exchange，提问作者Asgar Ali Khachay