1. 概述

1.1 背景

数仓调度场景概述 介绍了如何使用 FineDataLink 将不同数据源数据整合并搭建数据仓库，通过设置定时任务更新调度实现数据仓库数据的持续更新。

其中在构建 ODS 层数据时，用户需要将大量业务系统数据进行原表原样迁移，使用「 数据开发」完成此环节时，需要设置多个调度任务、数据同步/数据转换节点，配置复杂的更新逻辑。

使用「 数据管道」功能，则可以实现整个数据库或者多张数据表原表原样实时同步，大大方便了搭建数据仓库，提升开发效率。

1.2 思路

• 首先将分散在各个业务系统的原始数据使用 FDL 的「 数据管道」功能批量实时同步至数据仓库的 ODS层；
• 其次通过定时同步将 ODS 层数据表中新增部分，写入到 DW 层数据表，用户可以根据实际情况选择合适的数据更新方式，详情参见： 数据更新专题
• 最后通过定时同步将 DW 层的数据进行汇总，集中至 DM 层数据表，用户同样需要根据数据实际情况进行 数据更新设置，形成可供直接分析的结果数据。

1.3 效果预览

FineDataLink 中的数据处理过程，详情参见： https://demo.finedatalink.com/ 「场景案例>数据仓库场景」下的「04实时&定时组合数仓调度示例」文件夹。

任务层级如下图所示：

2. 操作步骤

2.1 设置数据仓库ODS层任务

在设置任务前，请先参考  数据管道概述第二节 进行环境准备。

2.1.1 设置销售数据管道任务

点击数据管道>新建管道任务，如下图所示：

将存放「销售数据」的「demo」数据库中对应的原始选中，如下图所示：

点击「下一步」，将数据同步至目标数据库，也就是存放 ODS 层数据的「test_1」数据库，如下图所示：

点击下一步，修改目标表名称，如下图所示：

点击下一步，设置异常通知和通知方式等，如下图所示：

最后保存并运行任务即可，如下图所示：

2.2 设置财务数据管道任务

同理，新建管道任务，并将存放「财务数据」的「test_2」数据库中对应的原始选中，并同步至存放 数据仓库ODS 层数据的「test_1」数据库中，如下图所示：

然后设置字段映射和异常通知，并保存和启动任务，如下图所示：

完成后的管道任务如下图所示：

此时，ODS 层数据库「test_1」中即会出现原表原样实时同步的「财务」和「销售」数据表，如下图所示：

2.2 设置DW层任务

DW 层任务的设置方式与 数仓调度场景概述同理，详情参见 设置DW层任务，此处不在赘述。

2.3 设置 DM 层任务

DM 层任务的设置方式与 数仓调度场景概述同理，详情参见 设置DM层任务，此处不在赘述。

2.4 设置总调度任务

搭建数据仓库中三个层级的数仓都已经设置完成，接下来就可以将 ODS、DW、DM 层的调度任务进行组合，通过调用任务的形式组合在一个任务中，方便后续的任务管理和触发。

由于此处 数据仓库ODS 层任务使用了「数据管道」功能，因此不需要对其进行调度任务设置，只需要对 DW 层和 DM 层进行调度即可，如下图所示：

操作步骤与 设置总调度任务同理，本文不在赘述。

3. 结果查看

设置好以上任务后，即可运行任务「调度总任务」，消息通知任务运行情况：

在数字化时代下，大数据治理对企业数据建设的重要性不言而喻，然而实现的困难有时也让人望而却步，因此选择合适的技术和工具会达到事半功倍的效果。帆软 FineDataLink——中国领先的低代码/高时效 数据集成产品，能过为企业提供一站式的数据服务，通过快速连接、高时效融合多种数据，提供低代码Data API敏捷发布平台，帮助企业解决数据孤岛难题，有效提升企业数据价值。

数据集成平台产品更多介绍： www.finedatalink.com

                          免费体验Demo 咨询方案

上一篇: 数据库管理员工信息实操：ETL工具高效应用下一篇: 实操演示：业务环节中数据仓库的调度怎么做