Node.js连接Redshift无数据返回问题求助

你的代码存在几个关键问题，导致查询后没有输出，甚至可能让程序处于无响应状态，以下是具体分析和修复方案：

核心问题点 #

1. Promise未正确处理reject分支
   原代码中，connect回调里的throw err无法被外部Promise捕获，会导致Promise一直处于pending状态，既不resolve也不reject，后续逻辑完全无法执行；同时parameterizedQuery的错误分支只打印日志但未调用reject，同样会让Promise挂起。

2. SQL语法错误（隐藏坑）
   user是Redshift的保留关键字，直接在SQL中使用FROM user会触发语法错误，但原代码的错误日志太简略，无法定位这个问题。

3. 回调嵌套导致错误捕获盲区
   多层回调嵌套容易漏掉错误处理，一旦某个环节出错但未正确传递错误，就会出现"无输出"的静默失败。

修复后的代码 #

改用async/await风格重构代码，同时完善错误处理和日志输出：

const Redshift = require('node-redshift');

const config = {
    user: '*****',
    database: '*****',
    password: '*****',
    port: *****,
    host: '*****.redshift.amazonaws.com',
};

const redshiftClient = new Redshift(config, { rawConnection: true });

exports.handler = async (event) => {
    // 提前检查必要参数
    if (!event?.user_id) {
        console.error('缺少必要参数：user_id');
        throw new Error('缺少必要参数user_id');
    }

    try {
        // 建立连接
        await new Promise((resolve, reject) => {
            redshiftClient.connect((err) => {
                if (err) {
                    console.error('Redshift连接失败:', err);
                    return reject(err);
                }
                resolve();
            });
        });

        // 执行参数化查询（注意用双引号包裹关键字user）
        const data = await new Promise((resolve, reject) => {
            redshiftClient.parameterizedQuery(
                'SELECT top 10 * FROM "user"',
                [event.user_id],
                { raw: true },
                (err, queryData) => {
                    if (err) {
                        console.error('查询执行失败:', err);
                        return reject(err);
                    }
                    resolve(queryData);
                }
            );
        });

        console.log('查询结果:', data);
        return data;
    } catch (err) {
        console.error('处理流程出错:', err);
        throw err;
    } finally {
        // 无论成功失败都关闭连接，避免资源泄漏
        await new Promise((resolve) => {
            redshiftClient.close(() => resolve());
        });
    }
};

额外注意事项 #

• 日志要具体：不要只打印"error"，要输出完整错误信息，方便定位问题。
• 关键字转义：Redshift的保留关键字（如user、order）需要用双引号包裹才能作为表名/列名使用。
• 资源清理：用finally块确保连接一定会被关闭，避免长期占用连接资源。

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