1. 概述
1.1 背景
数仓调度场景概述 介绍了如何使用 FineDataLink 将不同数据源数据整合并搭建数据仓库，通过设置定时任务更新调度实现数据仓库数据的持续更新。
其中在构建 ODS 层数据时，用户需要将大量业务系统数据进行原表原样迁移，使用「数据开发」完成此环节时，需要设置多个调度任务、数据同步/数据转换节点，配置复杂的更新逻辑。
使用「数据管道」功能，则可以实现整个数据库或者多张数据表原表原样实时同步，大大方便了数据仓库的搭建，提升开发效率。
1.2 思路
首先将分散在各个业务系统的原始数据使用 FDL 的「数据管道」功能批量实时同步至数据仓库的 ODS层；
其次通过定时同步将 ODS 层数据表中新增部分，写入到 DW 层数据表，用户可以根据实际情况选择合适的数据更新方式，详情参见：数据更新专题
最后通过定时同步将 DW 层的数据进行汇总，集中至 DM 层数据表，用户同样需要根据数据实际情况进行数据更新设置，形成可供直接分析的结果数据。
1.3 效果预览
任务层级如下图所示：
2. 操作步骤
| 步骤 | 说明 |
|---|---|
| 设置 ODS 层任务 | 设置 ODS 层任务需要将来自不同数据库的「财务数据」和「销售数据」通过使用 FineDataLink 的「数据管道」功能原表原样实时同步落库至指定数据库 |
| 设置 DW 层任务 | DW 层任务即将 ODS 层数据中更新的数据同步至 DW 层数据中。若已有的 DW 层数据中最新更新时间（比如最新的销售时间）晚于 ODS 层数据中的时间，即 ODS 层有新数据生成，需要将其同步至 DW 层中，同时记录更新的开始时间和结束时间，并发送消息通知。 |
| 设置 DM 层任务 | DM 层使用更新的数据进行数据处理，将 DW层的销售数据和财务数据进行关联，合并成宽表并输出至指定数据库，为其他报表等可视化工具提供数据源。 |
| 设置总调度任务 | 三个层级的数仓都已经设置完成，接下来就可以将 ODS、DW、DM 层的调度任务进行组合，通过调用任务的形式组合在一个任务中，方便后续的任务管理和触发。 |
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. 结果查看
设置好以上任务后，即可运行任务「调度总任务」，消息通知任务运行情况：
