java - 通过中间服务器连接到 Redshift

Question

我正在开发一个 Java 应用程序，该应用程序连接到 Redshift 数据库以运行无法在我们的硬件上运行的大量查询。该应用程序还消耗我们数据中心中的各种内部非 AWS 资源(例如 NAS、Oracle、MySQL 等上的文件...)。

遗憾的是，由于某些网络路由限制，应用程序无法直接连接到 Redshift。我可以通过 SSH 将生产 Redshift 集群手动连接到属于我们 VPC 的中间 EC2 实例 - 我希望以编程方式执行此操作。

在我的测试环境中，没有相同的路由限制，我可以使用如下数据源进行连接:

@Bean(name="dataSourceRedshift")
public DataSource dataSourceRedshift() throws SQLException {
    SimpleDriverDataSource dataSource = new SimpleDriverDataSource();
    dataSource.setDriver(new com.amazon.redshift.jdbc41.Driver());
    dataSource.setUrl("jdbc:postgresql://" + redshiftHost + ":" + redshiftPort + "/" + redshiftDatabase);
    dataSource.setUsername(redshiftUser);
    dataSource.setPassword(redshiftPass);
    return dataSource;
}

在我们的生产环境中，我无法直接连接到 Redshift，有没有办法调整数据源 bean(上面)以通过 EC2 实例设置 SSH 隧道？如果没有，“跳过”的最佳方式是什么？

Answer 1

我偶然发现了一种非常简单的方法来创建通过 SSH 建立隧道的数据源(由 Lucas Theisen 提供: https://github.com/lucastheisen/jsch-extension ):

@Bean(name="dataSourceRedshift")
public DataSource dataSourceRedshift() throws SQLException, JSchException {
    SimpleDriverDataSource dataSource = new SimpleDriverDataSource();
    dataSource.setDriver(new com.amazon.redshift.jdbc41.Driver());
    dataSource.setUrl("jdbc:postgresql://" + redshiftHost + ":" + redshiftPort + "/" + redshiftDatabase);
    dataSource.setUsername(redshiftUser);
    dataSource.setPassword(redshiftPass);

    DefaultSessionFactory defaultSessionFactory = new DefaultSessionFactory();

    TunneledDataSourceWrapper tunneledDataSource = new TunneledDataSourceWrapper(
            new TunnelConnectionManager(
                    defaultSessionFactory,
                    redshiftTunnel ),
            dataSource );

    return tunneledDataSource;
}

redshiftTunnel 字符串位于:

awoolford@localhost->awoolford@{{ ec2 instance in our VPC }}|127.0.0.1:5439:{{ redshift endpoint }}:5439