Amazon Athena Oracle 连接器
适用于 Oracle 的 Amazon Athena 连接器使 Amazon Athena 能够对存储在 Oracle（在本地或在 Amazon EC2 或 Amazon RDS 上运行）中的数据运行 SQL 查询。您还可以使用该连接器查询存储在 Oracle Exadata
先决条件
可以使用 Athena 控制台或 Amazon Serverless Application Repository 将该连接器部署到您的 Amazon Web Services 账户。有关更多信息，请参阅 部署连接器和连接到数据源 或 使用 Amazon Serverless Application Repository 部署数据源连接器。
使用此连接器前，应先设置 VPC 和安全组。有关更多信息，请参阅为数据源连接器创建 VPC。
限制
-
不支持写入 DDL 操作。
-
在多路复用器设置中，溢出桶和前缀在所有数据库实例之间共享。
-
任何相关的 Lambda 限制。有关更多信息，请参阅《Amazon Lambda 开发人员指南》中的 Lambda 配额。
条款
以下术语与 Oracle 连接器有关。
-
数据库实例 - 部署在本地、Amazon EC2 或 Amazon RDS 上的任何数据库实例。
-
处理程序 — 访问您数据库实例的 Lambda 处理程序。处理程序可以用于元数据或数据记录。
-
元数据处理程序 — 从您的数据库实例中检索元数据的 Lambda 处理程序。
-
记录处理程序 - 从您的数据库实例中检索数据记录的 Lambda 处理程序。
-
复合处理程序 - 从您的数据库实例中检索元数据和数据记录的 Lambda 处理程序。
-
属性或参数 - 处理程序用来提取数据库信息的数据库属性。您可以将这些属性配置为 Lambda 环境变量。
-
连接字符串 - 用于建立数据库实例连接的文本字符串。
-
目录 - 向 Athena 注册的非 Amazon Glue 目录，是
connection_string属性的必要前缀。 -
多路复用处理程序 — 可以接受和使用多个数据库连接的 Lambda 处理程序。
参数
使用本节中的 Lambda 环境变量来配置 Oracle 连接器。
连接字符串
使用以下格式的 JDBC 连接字符串连接到数据库实例。
oracle://${jdbc_connection_string}
使用多路复用处理程序
您可以使用多路复用器通过单个 Lambda 函数连接到多个数据库实例。按目录名称来路由请求。在 Lambda 中使用以下类。
| Handler | 类 |
|---|---|
| 复合处理程序 | OracleMuxCompositeHandler |
| 元数据处理程序 | OracleMuxMetadataHandler |
| 记录处理程序 | OracleMuxRecordHandler |
多路复用处理程序参数
| 参数 | 描述 |
|---|---|
$ |
必需。数据库实例连接字符串。将 Athena 中使用的目录的名称作为字符串前缀。例如，如果在 Athena 注册的目录是 myoraclecatalog，则环境变量名称为 myoraclecatalog_connection_string。 |
default |
必需。默认连接字符串。当目录为 lambda:${AWS_LAMBDA_FUNCTION_NAME} 时使用此字符串。 |
以下示例属性适用于支持两个数据库实例的 Oracle MUX Lambda 函数：oracle1（默认值）和 oracle2。
| 属性 | 值 |
|---|---|
default |
oracle://jdbc:oracle:thin:${Test/RDS/Oracle1}@//oracle1.hostname:port/servicename |
oracle_catalog1_connection_string |
oracle://jdbc:oracle:thin:${Test/RDS/Oracle1}@//oracle1.hostname:port/servicename |
oracle_catalog2_connection_string |
oracle://jdbc:oracle:thin:${Test/RDS/Oracle2}@//oracle2.hostname:port/servicename |
提供凭证
要在 JDBC 连接字符串中为数据库提供用户名和密码，可以使用连接字符串属性或 Amazon Secrets Manager。
-
连接字符串 — 可以将用户名和密码指定为 JDBC 连接字符串中的属性。
-
Amazon Secrets Manager - 要将 Athena 联合查询功能与 Amazon Secrets Manager 配合使用，连接到您的 Lambda 函数的 VPC 应该拥有互联网访问权限
或者 VPC 端点，以连接到 Secrets Manager。 您可以将 Amazon Secrets Manager 中的密钥名称放入您的 JDBC 连接字符串中。连接器将该密钥名称替换为来自 Secrets Manager 的
username和password值。对于 Amazon RDS 数据库实例，将紧密集成这种支持。如果您使用 Amazon RDS，我们强烈建议您使用 Amazon Secrets Manager 和凭证轮换。如果您的数据库不使用 Amazon RDS，请按以下格式将凭证存储为 JSON：
{"username": "${username}", "password": "${password}"}
带有密钥名称的示例连接字符串
以下字符串带有密钥名称 ${Test/RDS/Oracle}。
oracle://jdbc:oracle:thin:${Test/RDS/Oracle}@//hostname:port/servicename
该连接器使用该密钥名称来检索密钥，并提供用户名和密码，如以下示例所示。
oracle://jdbc:oracle:thin:username/password@//hostname:port/servicename
目前，Oracle 连接器可以识别 UID 和 PWD JDBC 属性。
使用单个连接处理程序
您可以使用以下单个连接元数据和记录处理程序连接到单个 Oracle 实例。
| 处理程序类型 | 类 |
|---|---|
| 复合处理程序 | OracleCompositeHandler |
| 元数据处理程序 | OracleMetadataHandler |
| 记录处理程序 | OracleRecordHandler |
单个连接处理程序参数
| 参数 | 描述 |
|---|---|
default |
必需。默认连接字符串。此字符串在无法识别目录时使用。 |
单个连接处理程序支持一个数据库实例，并且必须提供 default 连接字符串参数。将忽略所有其他连接字符串。
该连接器支持基于 SSL 的与 Amazon RDS 实例的连接。支持仅限于传输层安全性协议（TLS）以及客户端对服务器的身份验证。在 Amazon RDS 中不支持相互身份验证。下表中的第二行显示了使用 SSL 的语法。
以下示例属性适用于 Lambda 函数支持的单个 Oracle 实例。
| 属性 | 值 |
|---|---|
default |
oracle://jdbc:oracle:thin:${Test/RDS/Oracle}@//hostname:port/servicename |
oracle://jdbc:oracle:thin:${Test/RDS/Oracle}@(DESCRIPTION=(ADDRESS=(PROTOCOL=TCPS)
(HOST=<HOST_NAME>)(PORT=))(CONNECT_DATA=(SID=))(SECURITY=(SSL_SERVER_CERT_DN=))) |
溢出参数
Lambda 开发工具包可以将数据溢出到 Amazon S3。由同一 Lambda 函数访问的所有数据库实例都会溢出到同一位置。
| 参数 | 描述 |
|---|---|
spill_bucket |
必需。溢出桶名称。 |
spill_prefix |
必需。溢出桶密钥前缀。 |
spill_put_request_headers |
（可选）用于溢出的 Amazon S3 putObject 请求的请求标头和值的 JSON 编码映射（例如，{"x-amz-server-side-encryption" :
"AES256"}）。有关其他可能的标头，请参阅《Amazon Simple Storage Service API 参考》中的 PutObject。 |
数据类型支持
下表显示了适用于 JDBC、Oracle 和 Arrow 的相应数据类型。
| JDBC | Oracle | 箭头 |
|---|---|---|
| 布尔值 | 布尔值 | 位 |
| 整数 | 不适用 | Tiny |
| 短型 | smallint | Smallint |
| 整数 | integer | Int |
| 长整型 | bigint | Bigint |
| float | float4 | Float4 |
| Double | float8 | Float8 |
| 日期 | date | DateDay |
| 时间戳 | timestamp | DateMilli |
| 字符串 | text | Varchar |
| 字节 | bytes | Varbinary |
| BigDecimal | numeric(p,s) | 小数 |
| ARRAY | 不适用（见注释） | List |
分区和拆分
分区用于确定如何为该连接器生成拆分。Athena 将构建一个 varchar 类型的合成列，它将展示表的分区方案，以帮助该连接器生成拆分。该连接器不会修改实际的表定义。
性能优化
Oracle 支持本机分区。Athena Lambda 连接器可从这些分区并行检索数据。如果您想查询具有统一分区分布的超大型数据集，强烈建议使用本机分区。
许可证信息
使用此连接器，即表示您确认包含第三方组件（这些组件的列表可在此连接器的 pom.xml
另请参阅
有关最新 JDBC 驱动程序版本信息，请参阅 GitHub.com 上适用于 Oracle 连接器的 pom.xml
有关此连接器的更多信息，请访问 GitHub.com 上的相应站点