Azure Function调用PostgreSQL pg模块失败求助

一、解决"Cannot find module 'pg'"错误 #

你猜测的没错，这个错误是因为Azure Function运行环境中缺少PostgreSQL的Node.js客户端模块pg，可按以下场景对应安装：

• 本地开发部署场景：在Azure Function项目根目录（包含function.json的目录的上层目录）打开终端，执行命令：

  npm install pg
  

  执行完成后，将项目文件（含自动生成的package.json、package-lock.json和node_modules目录）一同部署到Azure。
• Azure Portal直接编辑场景：
  1. 进入你的Function App，点击左侧菜单的「高级工具(Kudu)」。
  2. 在Kudu中选择「Debug console」→「CMD」。
  3. 导航到site\wwwroot\<你的Function名称>目录（例如你的示例中是IoTHub_EventHub2）。
  4. 执行npm install pg完成安装。

二、代码中的其他问题及修正 #

除了模块缺失，你的代码还有几处会导致运行失败或存在风险的问题，修正后的代码如下：

module.exports = async function (context, IoTHubMessages) {
    const pg = require('pg');
    
    const config = {
        host: 'myserver.postgres.database.azure.com',
        user: 'granted@myserver',     
        password: 'password',
        database: 'telemetry',
        port: 5432,
        ssl: true
    };

    let client;
    try {
        client = new pg.Client(config);
        // 等待数据库连接建立完成
        await client.connect();
        
        // 使用参数化查询避免SQL注入，同时修正变量名错误
        const query = 'INSERT INTO tempdata(deviceid, data) VALUES($1, $2);';
        const values = [IoTHubMessages.deviceId, JSON.stringify(IoTHubMessages)];
        
        context.log(`执行查询: ${query}，参数: ${JSON.stringify(values)}`);
        // 等待插入操作完成
        await client.query(query, values);
        
        context.log('数据插入成功！');
    } catch (err) {
        context.log.error('操作失败:', err);
        throw err; // 抛出异常标记Function执行失败
    } finally {
        // 确保无论操作成功或失败，都关闭数据库连接
        if (client) {
            await client.end();
            context.log('数据库连接已关闭');
        }
    }
};

主要修改点说明： #

• 变量名统一：将代码中错误的eventHubMessages替换为函数参数IoTHubMessages，避免未定义错误。
• 参数化查询：不再直接拼接SQL字符串，改用$1、$2作为参数占位符，彻底规避SQL注入风险，提升查询安全性与稳定性。
• 异步操作处理：所有异步方法（connect()、query()、end()）都添加await，确保操作按顺序执行，不会在数据库操作完成前就关闭连接。
• 错误处理：添加try-catch-finally块，捕获并记录异常，同时在finally中确保数据库连接被关闭，避免资源泄漏。

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