到 Sequelize PostgreSQL 数据库的 SSH 隧道

Question

我正在尝试访问隐藏在堡垒 EC2 实例后面的一个远程数据库 (AWS RDS)。我可以通过我的 SQL 客户端轻松访问数据库，但无法通过我正在构建的 CLI 工具（使用 Sequelize 和 tunnel-ssh）访问它。我一直在关注这个 GitHub Gist，但它到处都使用相同的值，不幸的是，这让人很困惑。

我承认我对 SSH 隧道的一般理解很差，这在下面的示例中可能很明显。我的配置有问题吗？

数据库配置

Host:     wdXXXXXXXXXXXX.XXXXXXXXX.XX-XXXXX-X.rds.amazonaws.com
Port:     5432
User:     [DB_USER]
Password: [DB_PASSWORD]
Database: [DB_NAME]

堡垒配置

Server:   35.183.XX.XXX
Port:     22
Password:
SSH Key:  ~/.ssh/id_rsa.aws

const config = {
  // I don't need to specify any local values, do I?
  // localHost: "127.0.0.1",
  // localPort: 5432,

  // This should be bastion config, correct?
  username: "ec2-user",
  host: 35.183.XX.XXX,
  port: 22,
  privateKey: require("fsf").readFileSync("/path/to/ssh/key"),

  // This should be destination (database) config, correct?
  dstHost: wdXXXXXXXXXXXX.XXXXXXXXX.XX-XXXXX-X.rds.amazonaws.com,
  dstPort: 5432
};

// NOTE: If I don't have an "await" here, nothing seems to run inside the function itself (no consoles, etc)
const server = await tunnel(config, async (error, server) => {
  if (error) return console.error(error);

  const db = new Sequelize(DB_NAME, DB_USER, DB_PASSWORD, {
    dialect: "postgres",
    // NOTE: If this is already the destination in the SSH tunnel, should I use it again vs localhost?
    host: "wdXXXXXXXXXXXX.XXXXXXXXX.XX-XXXXX-X.rds.amazonaws.com",
    port: 5432
  });

  db.authenticate().then(async () => {
    const orgs = await db.organization.findAll();

    console.log("Successful query", orgs);
  }).catch(err => {
    console.error("DB auth error": err);
  });
});

是不是我上面的配置有问题？我对隧道的理解是否因我在隧道配置中使用的值而存在缺陷？

此外，为什么似乎没有调用隧道回调除非我 await 函数（这似乎不是 Promise )?

P.S。还有这个 Sequelize GitHub 问题提到通过 SSH 隧道连接 Sequelize，但没有给出示例。

Answer 1

我最终弄明白了并解决了问题（问题开始后 12 小时）...数据库和堡垒配置在技术上是正确的，但我错误地传递了一些值（由于理解有缺陷） SSH 隧道）。

数据库配置

Host:     wdXXXXXXXXXXXX.XXXXXXXXX.XX-XXXXX-X.rds.amazonaws.com
Port:     5432
User:     [DB_USER]
Password: [DB_PASSWORD]
Database: [DB_NAME]

堡垒配置

Server:   35.183.XX.XXX
Port:     22
Password:
SSH Key:  ~/.ssh/id_rsa.aws

const config = {
  // I have confirmed that the local values are unnecessary (defaults work)

  // Configuration for SSH bastion
  username: "ec2-user",
  host: 35.183.XX.XXX,
  port: 22,
  privateKey: require("fs").readFileSync("/path/to/ssh/key"),

  // Configuration for destination (database)
  dstHost: wdXXXXXXXXXXXX.XXXXXXXXX.XX-XXXXX-X.rds.amazonaws.com,
  dstPort: 5432
};

// NOTE: Moved to its own function, refactor likely fixed a few issues along the way
const getDB = () => new Promise((resolve, reject) => {
  const tnl = await tunnel(config, async error => {
    if (error) return reject(error);

    const db = new Sequelize(DB_NAME, DB_USER, DB_PASSWORD, {
      dialect: "postgres",
      // NOTE: This is super important as the tunnel has essentially moved code execution to the database server already...
      host: "localhost",
      port: 5432
    });

    return resolve(db);
  });
});

最后，主要的变化是在 Sequelize 配置中使用 localhost 作为数据库实例上的 SSH 隧道 "emerges"，因此它应该引用自己。可能还有其他一些必要的调整（据我所知我曾经尝试过），但最终我完好无损。

到 Sequelize PostgreSQL 数据库的 SSH 隧道

SSH tunnel to Sequelize PostgreSQL database

database

ssh-tunnel

sequelize.js