基于JavaScript的Azure Functions复用SQL Server数据库连接方法咨询

好问题！在Azure Functions里复用SQL连接池的关键在于利用Node.js模块级作用域的缓存特性——Azure Functions会在同一个执行进程中复用模块实例，所以把连接池定义在模块顶层，就能让所有函数共享同一个池，避免每次函数调用都新建连接，提升性能还能减少数据库负载。

步骤1：创建独立的数据库连接模块 #

首先，我们把连接池的初始化逻辑抽成单独的模块（比如db-pool.js），这样所有函数都可以导入复用：

const sql = require('mssql');

// 推荐从Azure Functions的环境变量读取配置（不要硬编码！）
const dbConfig = {
  user: process.env.SQL_USER,
  password: process.env.SQL_PASSWORD,
  server: process.env.SQL_SERVER,
  database: process.env.SQL_DATABASE,
  options: {
    encrypt: true, // Azure SQL必须开启加密
    trustServerCertificate: false
  },
  pool: {
    max: 10, // 根据你的需求调整连接池最大连接数
    min: 0,
    idleTimeoutMillis: 30000
  }
};

// 模块级作用域的连接池：只会在模块第一次加载时初始化一次
const pool = new sql.ConnectionPool(dbConfig);
const poolConnectionPromise = pool.connect();

// 监听连接池全局错误，避免连接断开导致后续请求失败
pool.on('error', (err) => {
  console.error('SQL连接池发生错误:', err);
  // 这里可以添加告警或自动重试逻辑
});

// 导出连接池和连接Promise供其他函数使用
module.exports = {
  sqlPool: pool,
  waitForPoolConnection: poolConnectionPromise
};

步骤2：在Azure Functions中复用连接池 #

现在，在你的任意Function文件里，只需要导入这个模块，等待连接池准备好后就可以执行查询了：

const { waitForPoolConnection, sqlPool } = require('./db-pool');
const sql = require('mssql');

module.exports = async function (context, req) {
  try {
    // 等待连接池完成初始化（第一次调用会等待，后续调用直接复用已连接的池）
    await waitForPoolConnection;

    // 使用共享的连接池创建请求对象
    const request = new sql.Request(sqlPool);
    
    // 执行查询（这里可以替换成你的业务SQL）
    const queryResult = await request.query('SELECT TOP 10 * FROM YourTableName');

    context.res = {
      status: 200,
      body: { data: queryResult.recordset }
    };
  } catch (err) {
    context.log.error('数据库操作失败:', err);
    context.res = {
      status: 500,
      body: { message: '内部服务器错误' }
    };
  }
};

关键注意事项 #

• 不要在函数内部创建连接池：如果把连接池定义在Function的处理函数里，每次函数调用都会新建一个池，很快就会达到SQL Server的连接数上限，导致性能问题甚至报错。
• 处理连接池错误：一定要监听pool.on('error')，SQL Server可能会主动断开闲置连接，这个事件可以帮你及时处理异常，避免后续请求失败。
• 使用环境变量存储配置：把数据库的用户名、密码、服务器地址放在Azure Functions的环境变量里（在Azure门户的Function App配置中设置），不要硬编码在代码里，更安全也更便于维护。
• 调整连接池参数：根据你的函数并发量调整pool.max等参数，平衡性能和资源消耗。

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