amazon-athena - AWS Athena ODI JDBC 连接

Question

有没有人尝试过从 Oracle Data Integrator 连接 AWS Athena。

我一直在尝试这个，但我找不到合适的 JDBC 连接字符串。

我遵循的步骤
https://docs.aws.amazon.com/athena/latest/ug/connect-with-jdbc.html#jdbc-url-format

从 AWS

下载了 AthenaJDBC42_2.0.7.jar 驱动程序

复制到ODI的userlib目录下

在 ODI 中创建新技术

尝试添加数据服务器。无法形成 JDBC url。

JDBC 字符串示例格式(不起作用):

jdbc:awsathena://AwsRegion=[Region];User=[AccessKey];Password=[SecretKey];S3OutputLocation=[Output];

请问有人可以帮忙吗？谢谢。

Answer 1

这是我为 Athena 实现的 JDBC 的分类器版本。这只是 POC，我们希望使用 AWS SDK 而不是 jdbc，尽管在这里不太重要。

package com.poc.aws.athena;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class AthenaJDBC {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        Connection connection = null;
        Class.forName("com.simba.athena.jdbc.Driver");
        connection = DriverManager.getConnection("jdbc:awsathena://AwsRegion=us-east-1;User=EXAMPLEKEY;"
                + "Password=EXAMPLESECRETKYE;S3OutputLocation=s3://example-bucket-name-us-east-1;");

        Statement statement = connection.createStatement();
        ResultSet queryResults = statement.executeQuery(ExampleConstants.ATHENA_SAMPLE_QUERY);
        System.out.println(queryResults.next());

    }
}

这里唯一重要的一点与 url 相关。
jdbc:awsathena://AwsRegion=us-east-1;User=EXAMPLEKEY;"
+ "Password=EXAMPLESECRETKYE;S3OutputLocation=s3://example-bucket-name-us-east-1; 。

us-east-1 必须替换为您的实际区域，如 us-west-1 等

EXAMPLEKEY 必须替换为具有 Athena 访问权限的 AWS Access key。

EXAMPLESECRETKEY 必须替换为具有 Athena 访问权限的 AWS Secret key。

example-bucket-name-us-east-1 必须替换为您的 S3 bucket，在 keys 上面也有写访问权限。

还有其他键 simba 驱动程序支持，但在这里不太重要。

我希望这有帮助。