Oracle 数据传输简介
您可以使用适用于 Oracle 的 BigQuery Data Transfer Service 连接器将数据从 Oracle 数据库加载到 BigQuery。本文档提供了 Oracle 转移作业的配置选项,以及有关数据类型映射和转移元数据的信息。
如需了解如何安排 Oracle 转移作业,请参阅 将 Oracle 数据加载到 BigQuery。
数据注入选项
以下部分详细介绍了设置 Oracle 数据传输作业时可用的数据注入选项。
TLS 配置
Oracle 连接器支持传输层安全协议 (TLS) 配置,以加密向 BigQuery 进行的数据传输。Oracle 连接器支持以下 TLS 配置:
“加密数据并验证 CA 和主机名”模式 。此模式使用基于 TCPS 协议的 TLS 对服务器执行完整验证。它会加密所有传输中的数据,并验证数据库服务器的证书是否由可信的证书授权机构 (CA) 签名。此模式还会检查您要连接的主机名是否与服务器证书上的通用名称 (CN) 或主体备用名称 (SAN) 完全匹配。此模式可防止攻击者使用不同网域的有效证书来冒充您的数据库服务器。
如果您的主机名与证书 CN 或 SAN 不一致,连接将会失败。您必须配置 DNS 解析以与证书匹配,或使用其他安全模式。使用此模式可获得最安全的选项,以防止中间人 (PITM) 攻击。
“加密数据并仅验证 CA”模式 。此模式使用基于 TCPS 协议的 TLS 加密所有数据,并验证服务器的证书是否由客户端信任的 CA 签名。不过,此模式不会验证服务器的主机名。只要证书有效且由可信的 CA 颁发,此模式就会成功连接,无论证书中的主机名是否与您要连接的主机名一致。
如果您想确保连接到证书由可信 CA 签名的服务器,但主机名无法验证或您无法控制主机名配置,请使用此模式。
“仅加密”模式 。 此模式使用 Oracle 的原生网络加密通过标准 TCP 端口加密客户端和服务器之间传输的所有数据。 它不会执行任何证书或主机名验证。
此模式通过保护传输中的数据来提供一定程度的安全性,但可能会受到 PITM 攻击。
如果您需要确保所有数据都经过加密,但无法或不想验证服务器的身份,请使用此模式。我们建议您在使用私有 VPC 时使用此模式。
“不加密或验证”模式 。此模式不会加密任何数据,也不会执行任何证书或主机名验证。所有数据都以纯文本形式发送。
我们不建议在处理敏感数据的环境中使用此模式。我们仅建议在安全不是问题的隔离网络中将此模式用于测试目的。
可信服务器证书 (PEM)
如果您使用的是“加密数据并验证 CA 和主机名”模式 或“加密数据并验证 CA”模式 ,那么您还可以提供一个或多个 PEM 编码的证书。在某些情况下,BigQuery Data Transfer Service 需要在 TLS 连接期间验证数据库服务器的身份,此时需要使用这些证书:
- 如果您使用的是由组织内的私有 CA 签名的证书或自签名证书,则必须提供完整的证书链或单个自签名证书。对于由受管云提供商服务的内部 CA(例如 Amazon 关系型数据库服务 (RDS))颁发的证书,这是必需的。
- 如果您的数据库服务器证书由公共 CA(例如 Let's Encrypt、DigiCert 或 GlobalSign)签名,则无需提供证书。BigQuery Data Transfer Service 预安装并信任这些公共 CA 的根证书。
您可以在转移作业配置的可信 PEM 证书 字段中指定 PEM 编码的证书,但需满足以下要求:
- 证书必须是 PEM 编码的有效证书链。
- 证书必须完全正确。链中缺少任何证书或内容不正确都会导致 TLS 连接失败。
- 对于单个证书,您可以提供数据库服务器中的单个自签名证书。
- 对于由私有 CA 颁发的完整证书链,您必须提供完整的信任链。这包括数据库服务器的证书以及任何中间 CA 证书和根 CA 证书。
完整转移或增量转移
在设置 Oracle 转移作业时,您可以在转移作业配置中选择 完整 或增量 写入 偏好设置,以指定数据加载到 BigQuery 的方式。 预览版支持增量转移。
您可以配置完整数据传输,以便在每次数据传输时传输 Oracle 数据集中的所有数据。或者,您也可以配置增量数据传输 (预览版) 以仅传输自上次数据传输以来更改的数据,而不是 在每次数据传输时都加载整个数据集。如果您为数据传输选择增量,则必须指定附加 或 upsert 写入模式,以定义在增量数据传输期间如何将数据写入 BigQuery。以下部分介绍了可用的写入模式。
附加写入模式
附加写入模式只会向目标表中插入新行。此选项会严格附加转移的数据,而不检查是否存在现有记录,因此这种模式可能会导致目标表中的数据重复。
选择附加模式时,您必须选择水位线列。Oracle 连接器需要一个水位线列来跟踪源表中的更改。
对于 Oracle 转移作业,我们建议选择仅在创建记录时更新的列,且该列不会随后续更新而变化,例如CREATED_AT 列。
Upsert 写入模式
upsert 写入模式会通过检查主键来更新目标表中的行或在其中插入新行。您可以指定主键,以便 Oracle 连接器确定需要进行哪些更改才能使目标表与源表保持同步。如果在数据传输期间,指定的主键存在于目标 BigQuery 表中,则 Oracle 连接器会使用源表中的新数据更新该行。如果在数据传输期间不存在主键,则 Oracle 连接器会插入新行。
选择 upsert 模式时,您必须选择水位线列和主键:
- Oracle 连接器需要一个水位线列来跟踪源表中的更改。
- 选择一个每次修改行时都会更新的水位线列。我们建议使用类似于
UPDATED_AT或LAST_MODIFIED的列。
- 选择一个每次修改行时都会更新的水位线列。我们建议使用类似于
主键可以是表中的一列或多列,Oracle 连接器需要使用这些列来确定是否需要插入或更新行。
选择包含非 null 值且在表的所有行中都唯一的列。我们建议使用包含系统生成的标识符、唯一参考代码(例如自动递增的 ID)或不可变、基于时间的序列 ID 的列。
为防止潜在的数据丢失或数据损坏,您选择的主键列必须具有唯一值。如果您对所选主键列的唯一性有疑问,建议您改用附加写入模式。
增量注入行为
当您更改数据源中的表架构时,这些表的增量数据传输会以以下方式反映在 BigQuery 中:
| 数据源更改 | 增量注入行为 |
|---|---|
| 添加新列 | 系统会将新列添加到目标 BigQuery 表中。 此列的所有先前记录都将具有 null 值。 |
| 删除列 | 已删除的列仍保留在目标 BigQuery 表中。系统会使用 null 值填充此已删除列的新条目。 |
| 更改列中的数据类型 | 连接器仅支持
ALTER COLUMN DDL 语句支持的数据类型转换。
任何其他数据类型转换都会导致数据传输失败。如果您遇到任何问题,建议您创建新的转移 作业配置。 |
| 重命名列 | 原始列将按原样保留在目标 BigQuery 表中,同时系统会使用更新后的名称将新列添加到目标表中。 |
数据类型映射
下表将 Oracle 数据类型映射到相应的 BigQuery 数据类型:
| Oracle 数据类型 | BigQuery 数据类型 |
|---|---|
BFILE |
BYTES |
BINARY_DOUBLE |
FLOAT |
BINARY_FLOAT |
FLOAT |
BLOB |
BYTES |
CHAR |
STRING |
CLOB |
STRING |
DATE |
DATETIME |
FLOAT |
FLOAT |
INTERVAL DAY TO SECOND |
STRING |
INTERVAL YEAR TO MONTH |
STRING |
LONG |
STRING |
LONG RAW |
BYTES |
NCHAR |
STRING |
NCLOB |
STRING |
NUMBER (without precision and scale) |
STRING |
NUMBER (with precision and scale lower than the BigQuery Numeric range) |
NUMERIC |
NUMBER (with precision and scale lower than the BigQuery BigNumeric range) |
BIGNUMERIC |
NUMBER (with precision and scale greater than the BigQuery BigNumeric range) |
STRING |
NVARCHAR2 |
STRING |
RAW |
BYTES |
ROWID |
STRING |
TIMESTAMP |
DATETIME |
TIMESTAMP WITH LOCAL TIME ZONE |
DATETIME |
TIMESTAMP WITH TIME ZONE |
TIMESTAMP |
UROWID |
STRING |
VARCHAR |
STRING |
VARCHAR2 |
STRING |
转移元数据
您还可以使用 Oracle 连接器将元数据转移到 Knowledge Catalog。如需了解更多 信息,请参阅将 Oracle 元数据加载到 Knowledge Catalog。价格
如需了解 Oracle 传输相关的价格信息,请参阅 Data Transfer Service 价格。
后续步骤
- 了解如何 设置 Oracle 转移作业。
- 详细了解 BigQuery Data Transfer Service。