java实时数据集成简介(6)

您可以快速检查哪些行在表日志中(右键单击相关的数据存储，选择 Changed Data Capture，然后选择 Journal Data…)，也可以执行接口(在编辑器中再次打开它，并单击屏幕右下角的 Execute)。

由于您已经使用所创建的第一个接口将最初的数据集合载入目标数据中心，现在可以创建一个 Oracle Data Integrator 程序包来执行下列步骤：

检查 ORDERS 和 CUSTOMER 日志记录数据，以查看是否已添加新的或经过更改的数据记录。如果检测到预定义数量的日志记录，运行程序包的其余部分或跳到最后一步，无需加载任何数据。

如果检测到日志记录数据，扩展日志窗口。

执行该接口，以读取日志记录数据，将其与文件联合，并加载目标数据存储。

清除日志窗口。

再次启动该程序包。

创建该程序包然后将其作为 Oracle Data Integrator 案例部署可有效地创建一个实时、连续运行的 ETL 过程。使用 Oracle Data Integrator 的事件检测功能，该程序包将在检测到预先设置的更改数据记录数或经过指定的毫秒数后自行启动。通过为日志记录数据的数量和超时设置相应的阈值，您可以创建一个延迟最小的实时集成过程。

要创建该程序包，导航到 Designer 应用程序的 Projects 选项卡，找到包含您先前定义的接口的文件夹，找到 Packages 项，右键单击该项，然后选择 Insert Package。为该程序包指定一个名称，然后导航到程序包详细信息对话框的 Diagram 选项卡。

使用右侧的工具箱，转至 Event Detection 文件夹并将 OdiWaitForLogData 工具添加到程序包画布中，如下图所示。该工具将定期轮询日志记录数据，如果未找到任何行，该工具将失败，如果在日志中检测到预先设置的行数，该工具将进入程序包的下一个步骤。

您可以将工具属性设置为检查先前定义的更改数据捕获集合，并在发现 3 个日志行或检查开始一分钟后退出。

java实时数据集成简介(7)

现在，您可以添加一个扩展日志窗口以读入新数据的步骤。为此，导航到模型列表，并将 Oracle 模型拖放到画布上。选择该模型，查看属性，然后将 Model Type 列表更改为 Journalizing Model，如下图所示。

然后，单击 Extend Window 复选框，以表明该日志步骤将扩展日志窗口。

接下来，将从日志提取数据的接口添加到映射，然后将 Oracle 模型再次添加到程序包中，但这次选择 Purge Window 选项，以便在读取日志后将其清除。最后，将 Utilities 文件夹中的 OdiStartScen 工具添加到工具箱，以便在其完成后再次重启，您还可以添加显示步骤流程的连接器(如下图所示)，具体取决于第一个步骤是否检测到日志行。

由于最后的 OdiStartScen 步骤指的是程序包生产版本中的情况，您可以在 Designer 应用程序的 Project 选项卡中找到要使用的程序包，右键单击该程序包，并选择 Generate Scenario。创建了案例之后，您可以编辑 OdiStartScen 步骤的属性，使其引用您刚刚生成的案例名称。将这最后一步添加到程序包之后，您就可以确保它连续运行，并以实时方式将 Oracle 源表中新的和经过更改的数据传播到目标数据库。

总结

Oracle Data Integrator 是 Oracle 融合中间件产品系列的一个新成员，您可以利用它跨众多平台执行面向数据、事件和服务的集成。它对 Oracle Warehouse Builder 进行了补充，并为特定于 Oracle 数据库的功能(例如，批量数据加载和 Oracle 更改数据捕获)提供了图形界面。本

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务，公司网站：http://www.lingzhong.cn 为了给广大客户了解更多的技术信息，本技术文章收集来源于网络,凌众科技尊重文章作者的版权，如果有涉及你的版权有必要删除你的文章，请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息，谢谢!