node.js - Azure 函数与 Node.js 中的 Postgres 集成

Question

我想从 Azure 函数访问 Azure Postgres DB。下面是 Azure 函数的 node.js 源代码。

 module.exports = async function (context, req) {
try {
    context.log('Start function!');
    var pg = require('pg');

    const config = {
        host: 'taxiexample.postgres.database.azure.com',
        user: 'postgres@taxiexample',
        password: 'QscBjk10;',
        database: 'taxi',
        port: 5432,
        ssl: false
    };

    var client = new pg.Client(config);
    const query = 'insert into taxi values (\'2\');';
    context.log(query);
    client.connect();
    var res = client.query(query);
    await client.end();

    context.log(res);

} catch (e) {
    context.log(e);
} finally {
    context.res = {
        status: 200,
        body: "ok"
    };
}

};

记录未插入，res对象返回以下错误：

2020-03-04T23:03:59.804 [Information] Promise {
  <rejected> Error: Connection terminated
      at Connection.<anonymous> (D:\home\site\wwwroot\HttpTrigger1\node_modules\pg\lib\client.js:254:9)
      at Object.onceWrapper (events.js:312:28)
      at Connection.emit (events.js:228:7)
      at Socket.<anonymous> (D:\home\site\wwwroot\HttpTrigger1\node_modules\pg\lib\connection.js:78:10)
      at Socket.emit (events.js:223:5)
      at TCP.<anonymous> (net.js:664:12)
}
2020-03-04T23:03:59.811 [Information] Executed 'Functions.HttpTrigger1' (Succeeded, Id=944dfb12-095d-4a28-a41d-555474b2b0ee)

你能帮助我吗？谢谢

Answer 1

我已经解决了，这是一个微不足道的编程错误。下面是正确的源代码

module.exports = async function (context, req) {

    try {
        context.log('Start function!');
        var pg = require('pg');

        const config = {
            host: 'example.postgres.database.azure.com',
            user: 'postgres@example',
            password: 'passwd;',
            database: 'test',
            port: 5432,
            ssl: true
        };

        var client = new pg.Client(config);
        const query = 'insert into test values (\'2\');';
        context.log(query);

        client.connect(err => {
            if (err) {
                console.error('connection error', err.stack);
            } else {
                console.log('connected');
                client.query(query, (err, res) => {
                    if (err) throw err;
                    console.log(res);
                    client.end();
                })
            }
        });

    } catch (e) {
        context.log(e);
    } finally {
        context.res = {
            status: 200,
            body: "ok"
        };
    }

};