如何在JS版Azure函数中访问连接串并查询Azure SQL数据库

我来帮你搞定这个问题——你碰到的"x未定义"错误，本质是Azure函数不会把连接字符串直接暴露成全局变量，得从环境变量里按规则读取。下面一步步给你说明怎么操作：

一、正确获取连接字符串 #

你在「应用设置-连接字符串」里创建的名为x的连接串，在Node.js环境的Azure函数中，需要通过process.env["ConnectionStrings:x"]来获取它的值。Azure会自动把连接字符串的键名加上ConnectionStrings:前缀注入到环境变量中，所以直接写x肯定会报错未定义。

二、执行SELECT查询的完整流程 #

我们用微软官方推荐的mssql库来连接Azure SQL，这是Node.js环境下最稳定的SQL Server连接工具。

1. 安装依赖 #

在你的函数应用项目目录（如果是单函数项目，就到函数对应的文件夹下），打开终端运行：

npm install mssql

2. 编写函数代码（index.js） #

下面是完整的示例代码，包含IoT Hub消息接收、连接串读取、SQL查询和结果比对的逻辑：

const sql = require('mssql');

// IoT Hub触发的函数入口
module.exports = async function (context, IoTHubMessage) {
    context.log('收到IoT Hub消息:', IoTHubMessage);

    // 1. 读取连接字符串
    const dbConnectionString = process.env["ConnectionStrings:x"];
    if (!dbConnectionString) {
        context.log.error('未找到连接字符串x，请检查应用设置中的配置');
        context.done();
        return;
    }

    // 2. 解析IoT Hub传入的数据（根据你的实际消息结构调整）
    // 如果消息是JSON格式，先解析成对象
    const incomingData = typeof IoTHubMessage === 'string' ? JSON.parse(IoTHubMessage) : IoTHubMessage;
    const targetValue = incomingData.yourFieldName; // 替换成你要比对的字段名

    try {
        // 3. 建立SQL连接并执行查询
        await sql.connect(dbConnectionString);
        // 用参数化查询避免SQL注入，替换成你的表名和查询条件
        const queryResult = await sql.query`SELECT * FROM YourTable WHERE YourColumn = ${targetValue}`;

        // 4. 比对查询结果
        if (queryResult.recordset.length > 0) {
            context.log('找到匹配数据:', queryResult.recordset[0]);
            // 这里添加你的后续业务逻辑，比如生成告警、更新数据等
        } else {
            context.log('未找到匹配的数据');
        }
    } catch (error) {
        context.log.error('数据库操作失败:', error.message);
    } finally {
        // 确保关闭SQL连接
        await sql.close();
    }

    context.done();
};

3. 注意事项 #

• 数据库防火墙设置：要确保你的Azure SQL服务器允许Azure函数访问，可以在SQL服务器的防火墙设置中开启「允许Azure服务和资源访问此服务器」选项，或者添加函数应用的出站IP地址。
• 参数化查询：示例中用了模板字符串的参数化查询方式，这能有效避免SQL注入风险，不要直接拼接字符串生成查询语句。
• 消息结构适配：如果IoT Hub传入的是二进制或非JSON格式的消息，你需要根据实际情况调整数据解析逻辑。

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