一、跨库关联处理

销售系统数据库中存放着订单表，应用库中存放着订单明细表，现在要将这两张表，通过「订单ID」主键关联后落库到应用库中。

1）新建任务，使用数据转换，拖入DB表输入算子将两个表的数据分别取出。

2）新增一个「数据关联」算子，将两个数据表输入连接至「数据关联」算子，点击连接方式和连接字段进行选择，即可进行跨库关联制作新的数据表，不需要编写任何代码。

跨库关联操作

3）对关联好的数据表进行字段设置，例如去掉重复字段。

4）使用DB表输出算子，将制作好的数据表并输出到应用库中即可。

二、数据列转行

销售明细表中包含了每个产品在不同省份的销售金额数据，我们希望对数据进行列转行，计算每个省份的销售总额后落入应用库中。

1）新建 ETL 任务，使用数据转换概述，拖入DB表输入将销售系统库中的「销售明细」取出。

2）使用「列转行」算子对「销售明细」数据进行转换，开发人员无需编写SQL，仅需输入字段名称，点击选择转换字段，即可将二维表地区销售数据转为一维表。

数据列转行操作

3）此时希望对已经列转行的数据继续进行处理，计算每个城市的总销售金额，可以使用「Spark SQL」算子，编写 SQL 语句进行操作。

4）数据处理完成后，使用DB表输出将数据输出到应用库中即可。

三、复杂SQL处理

使用数据同步将销售系统中的「年度资产分类表」进行复杂 SQL 处理后，输出到应用库中。

1）新建 ETL 任务，添加「数据同步」，在数据来源中编写SQL 语句进行取数。

2）在数据去向与映射中，将查询好的数据输出至应用库中即可。

使用数据同步可以大大提高取数速度，缓解数据加载缓慢问题。

数据同步-复杂SQL处理

四、任务调度管理

数据处理的任务设置好后，我们希望能够定时进行数据更新，可以在FineDataLink中设计调度周期，对任务进行管理。

1）新建 ETL 任务，添加「调用任务」。

2）新增「消息通知」，设置若三个任务执行失败，则通知某个任务执行失败。

3）使用连线将三个任务与失败执行的消息通知相连，设置在任务执行失败时，执行「消息通知-失败执行」。

4）同理，设置任务执行成功时的消息通知。

5）设置任务的执行频率，完成任务调度配置。

任务调度流程

任务调度计划

更多FineDataLink与FineReport组合应用内容请前往：FDL和FineReport组合应用示例