Node.js v12至v16异步函数处理差异致Lambda执行异常求助

问题代码 #

const pool = require('pg');

dbConfig = {};

async function getClient(dbConfig) {
    const pool = new Pool(dbConfig);
    pool.connect().then(() => console.log('connected'))
        .catch(err => console.error('connection error', err.stack));
    return pool;
}

async function getDBConnection() {
    const client = await getClient(dbConfig);
    await client.connect(function(err){
        if (err) {
          console.error('could not connect to postgres', err);
        }     
      });
    return client;
}

async function main() {
    const client = await getDBConnection();
    const query = "SELECT * FROM table limit 10";
    let response = "NO";

    await client.query(query, [])
                    .then(res => response = res.rows)
                    .catch(e => console.log(e.stack));
                console.log("DEBUG: ", client);
    console.log(response);
    return "***";
}

main().then(res => console.log(res));

问题描述 #

上述代码在Node.js v12环境中运行时，main()方法会等待执行完成；但在Node.js v16环境中，main()未等待执行完成就直接结束，Promise在后台处于pending状态，导致Lambda函数执行失败。需要明确Node.js v12到v16在异步函数处理上的重大变更，以及代码问题所在。

问题分析与解答 #

代码本身的核心问题 #

你的代码存在未正确等待异步操作完成的逻辑缺陷，在v12中可能因事件循环的旧行为掩盖了问题，而v16的严格处理暴露了这个问题：

1. 模块导入错误：const pool = require('pg');应该改为const { Pool } = require('pg');，否则无法正确实例化连接池。
2. 未等待连接完成：getClient中调用pool.connect()后未用await等待，直接返回pool，此时连接可能还未建立；getDBConnection中client.connect()传入了回调函数，该模式下不会返回Promise，await完全无效，相当于没等连接成功就返回了client。
3. 连接池使用错误：pg连接池无需手动调用connect()获取client后再查询，直接使用pool.query()即可自动管理连接。

Node.js v12到v16的关键异步处理变更 #

• 事件循环退出逻辑优化：v16调整了事件循环的退出判定，当顶层Promise完成后，进程会更快退出，不会像v12那样可能等待事件循环中剩余的异步任务。如果代码中存在未被正确等待的Promise，v16会直接终止进程，而v12可能会继续等待这些任务完成。
• UnhandledRejection处理升级：v16默认将未处理的Promise拒绝（unhandledRejection）视为致命错误，会终止进程；而v12仅会输出警告信息，不会终止进程。
• 微任务队列优先级调整：v16对微任务的执行时机做了更严格的规范，确保Promise的状态变更能被及时处理，避免了v12中可能出现的异步任务延迟执行的情况。

修复后的代码示例 #

const { Pool } = require('pg');

// 填入实际的数据库配置
const dbConfig = {
    host: 'your-db-host',
    user: 'your-db-user',
    password: 'your-db-password',
    database: 'your-db-name',
    port: 5432
};

async function getDBConnection() {
    const pool = new Pool(dbConfig);
    try {
        // 等待连接成功，验证连接有效性
        await pool.connect();
        console.log('数据库连接成功');
        return pool;
    } catch (err) {
        console.error('数据库连接失败', err.stack);
        throw err; // 抛出错误让上层处理
    }
}

async function main() {
    let pool;
    try {
        pool = await getDBConnection();
        const query = "SELECT * FROM table limit 10";
        // 直接用pool执行查询，自动管理连接
        const res = await pool.query(query);
        console.log("DEBUG: ", pool);
        console.log('查询结果:', res.rows);
        return "***";
    } catch (e) {
        console.error('执行出错', e.stack);
        throw e;
    } finally {
        // 关闭连接池，避免Lambda函数残留连接导致资源泄漏
        if (pool) {
            await pool.end();
            console.log('连接池已关闭');
        }
    }
}

// 捕获main的错误，避免未处理的Promise拒绝
main().then(res => console.log(res)).catch(err => process.exit(1));

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