使用Node.js Lambda通过Sequelize连接Amazon Redshift查询报错如何解决

报错根因说明 #

SequelizeHostNotFoundError: getaddrinfo ENOTFOUND 本质是程序无法通过DNS解析到你填写的数据库主机地址，90%以上的场景是配置错误导致，可按以下步骤逐一排查修复：

修复步骤 #

• 第一步：修正主机地址配置
  不要把完整的JDBC/ODBC连接串直接填入DB_HOST环境变量，正确的Redshift主机地址需要从连接串中单独提取，格式为[集群ID].[随机串].[区域].redshift.amazonaws.com，不要带jdbc:redshift://前缀、端口、数据库名后缀。
  提取后可先在本地终端执行nslookup 你提取的主机地址验证是否能正常解析，如果终端都返回解析失败，说明地址提取错误或者集群未开通公网访问。

• 第二步：补全端口配置，替换适配的方言
  Redshift默认端口是5439，不是PostgreSQL默认的5432，且原生PostgreSQL方言和Redshift存在兼容性问题，需要先安装专门的Redshift适配包：

  npm install sequelize-redshift
  

  再修改你的Sequelize初始化配置，补充端口、替换方言即可。

修正后的完整配置参考 #

const fs = require('fs');
const path = require('path');
const Sequelize = require('sequelize');
require('sequelize-redshift'); // 引入redshift适配

const basename = path.basename(__filename);
const db = {};

const sequelize = new Sequelize(
  process.env.DB_REDSHIFT, // 单独填Redshift数据库名
  process.env.DB_USER, // 数据库用户名
  process.env.DB_PASS, // 数据库密码
  {
    host: process.env.DB_HOST, // 只填提取后的纯主机地址
    port: 5439, // Redshift默认端口，必须显式配置
    dialect: 'redshift', // 替换原postgres方言
    ...process.env.NODE_ENV !== 'dev' && {
      logging: false,
    },
    define: {
      underscored: true,
    },
    dialectOptions: {
      multipleStatements: true,
      dateStrings: true,
      typeCast: (field, next) => {
        if (field.type === 'DATETIME' || field.type === 'TIMESTAMP') {
          return field.string();
        }
        return next();
      },
    },
    pool: {
      max: 1,
      min: 0,
      idle: 10000,
    },
  },
);

fs.readdirSync(__dirname).filter((file) => {
  return (file.indexOf('.') !== 0) && (file !== basename) && (file.slice(-3) === '.js');
}).forEach((file) => {
  const model = sequelize.import(path.join(__dirname, file));
  db[model.name] = model;
});

Object.keys(db).forEach((modelName) => {
  if (db[modelName].associate) {
    db[modelName].associate(db);
  }
});

db.sequelize = sequelize;
db.Sequelize = Sequelize;

module.exports = db;

后续验证 #

修改完成后先跑最简连接测试，不要直接加载全量模型：

const { sequelize } = require('./上述配置文件的路径');
async function testConnect() {
  try {
    await sequelize.authenticate();
    console.log('Redshift连接成功');
    // 连接成功后再执行查询逻辑
  } catch (err) {
    console.error('连接失败', err);
  }
}
testConnect();

如果连接测试通过还是无法查询已存在的表，只需定义和Redshift表字段对应的Model即可，不需要执行sequelize.sync()同步表结构。

网络权限排查（前几步都正确还是报错时检查） #

• 如果是公网连接Redshift：检查Redshift集群安全组的入站规则，放开你本地设备公网IP对5439端口的访问，同时确认集群已开启公网可访问权限。
• 如果是VPC内部连接：确认代码运行环境和Redshift集群在同一个VPC下，且VPC安全组允许互通。

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