助睿实验作业1-订单利润分流数据加工
通过本次实验,熟悉了助睿零代码 ETL 平台的基本操作方法,包括创建项目、同步数据源、新建转换流、添加和配置组件、执行转换以及查看结果。掌握了表输入、记录集连接、字段选择、过滤记录、Excel 输出等常用组件的配置方法,理解了多表关联条件分析流数据处理中的应用。相比传统编写 SQL 和脚本的数据处理方式,助睿平台的零代码拖拽式操作更加直观,组件之间的数据流向清晰可见,便于理解和调试。对于初学者来说
一、实验背景
1.1 实验目的
本次实验旨在熟悉助睿零代码数据集成平台(ETL平台)的核心功能和操作方法,具体包括:
- 掌握新建转换、添加组件、执行转换等基本操作流程
- 熟悉表输入、记录集连接、字段选择、过滤记录、Excel输出等常用组件的配置方法
- 理解多表关联、数据过滤与分流处理的ETL设计思路
通过本次实验,学生能够独立使用助睿平台完成常见的数据加工任务,为后续更复杂的数据处理场景打下基础。
1.2 实验环境
- 助睿零代码在线实验平台:
https://lab.guilian.cn/
本次实验使用助睿数智(Uniplore)作为一站式数据科学平台。该平台覆盖从数据接入、ETL处理、机器学习建模到可视化展示的全链路要代功能,适用于数据分析教学与企业数据加工场景。产品官网为:
https://www.uniplore.com/
- 数据库:MySQL(含订单数据和产品信息表)
- 数据准备:订单表(business_anaylsis.order_detail)、产品表(business_anaylsis.product)
1.3 业务场景
在企业经营分析中,经常需要将多张表关联起来计算利润,并按利润正负对订单进行分类存储。本实验以订单利润分流为例,通过零代码拖拽方式完成这一数据处理任务。
1.4 数据加工流程
订单明细表与产品信息表进行左外连接,移除重复字段,按利润是否大于等于零进行分流,最后分别输出盈利订单和亏损订单到两个Excel文件。

二、实验步骤
2.1 登录实验平台
在贵兰在线对应的课程学习页面,点击“实验课1:助睿ETL入门实验”

点击课程实训说明中的“大数据实训平台”,即可前往实验地址 https://lab.guilan.cn/


从贵兰在线进入实验平台可以自动登录,登录成功后进入实验平台首页

2.2 基本概念了解
是什么: 助睿一站式大数据平台中的数据集成平台,通过可视化方式做数据ETL(抽取、转换、加载)。
表格内容
| 概念 | 说明 |
|---|---|
| Pipeline(转换) | 面向数据流,处理数据的一个功能单元,由多个Transform组成 |
| Workflow(作业) | 面向任务,完成一件完整的事,由多个Action组成,必须包含开始项 |
| Transform(步骤) | 转换内的最小单元,如"Excel输入"、"字段选择",每个步骤独立线程运行 |
| Action(任务项) | 作业的执行单位,如"启动"、"发送邮件" |
| Hops(节点连接) | 数据传输通道,连接步骤或任务项 |


2.3 团队管理
在该环节,每个小组的组长可以创建该小组的团队方便团队实验作业的管理
进入实验平台后,选择数据集成/ETL,进入数据集成页面

点击 团队管理 菜单,并点击 新增团队

在弹出的窗口中团队名称和团队描述,点击 确认

创建成功后,点击团队卡片右上角的更多,选择 添加成员

输入手机号查询组员,勾选后点击 添加 即可

2.4 创建实验项目
平台提供默认项目,可以使用默认项目进行实验,但为了方便管理,可以为课程创建专属项目。
选择创建的项目所属团队为“商业数据分析小组1”(也可以是个人)

点击“新建项目”

输入项目名称后点击 确定

创建成功后即可在数据集成页面看到新创建的项目

2.5 同步数据源
项目创建成功后点击该项目右上角“...”,点击“打开”

在项目页面,可以看到左侧有3个菜单:资源库、文件、元数据
资源库用于对工作流的管理,包括新建、删除、修改、查看工作流的信息;导出导入工作空间;调度管理等操作
文件库用于保存工作流中需要用到的文件和工作流产生的文件
元数据管理是数据集成的重要基石,可以为工作流定义“运行配置”、“数据库”、“flink集群”等配置
本次实验主要用到资源库和文件库

首先获取本次的实验数据集:点击“元数据”,右键根“关系数据库”,点击“同步数据源”

切换 文件库 菜单再切换回到元数据,可以看到成功同步的数据库 线上公共数据源

2.6 新建转换流
本次实验将创建订单利润分流处理转换流,实现订单数据与产品信息的关联,并根据利润正负将数据分流为盈利订单和亏损订单,分别输出到两个Excel文件。
整体逻辑: 订单明细表 → 左外连接产品信息表 → 移除重复ID字段 → 按利润>0分流 → 盈利订单/亏损订单分别输出
各组件作用:
| 组件 | 作用 |
|---|---|
| 表输入(订单/产品) | 读取原始数据 |
| 记录集连接 | 按产品ID关联两表 |
| 字段选择 | 移除重复的ID字段 |
| 过滤记录 | 根据利润正负分流 |
| Excel输出 | 分别输出盈利/亏损订单 |
新建转换流具体操作如下:
切换到资源库,同样右键根目录,点击“新建转换流”

输入转换流名字“订单利润分流处理”,点击“确定”

创建成功后进入转换流设计页面

2.7 添加组件
在建立转换任务后,可添加相应操作组件到转换任务中。
下面以订单数据(business_analysis.order_detail)和产品信息数据(business_analysis.product)生成盈利订单数据和亏损订单数据为例来创建转换任务,按如下顺序向转换中添加组件:
(1)添加表输入组件
本次实验需要将两类数据进行合并计算,所以需要添加2个表输入组件,读取2个不同表的数据。
点击“组件库”,由于组件库的组件数量较多,可以通过关键字搜索快速获取
在搜索输入框中输入“表输入”,即可查询到“表输入”

将表输入组件拖拽至画布中

再次拖拽表输入组件拖拽至画布中,即拖拽2个表输入组件至画布中

右键表输入组件,点击 编辑组件

修改步骤名称中为订单_详细订单,点击“确认”,此时画布中的对应表输入组件被命名为“订单_详细订单”

同样的,另一表输入组件修改为订单_产品信息

(2)添加记录集连接组件
使用表输入组件读取数据后,需要通过记录集连接组件将表输入组件的数据进行关联。
在搜索输入框中输入“记录集连接”,将记录集连接组件拖拽至画布中

创建两个表输入组件到记录集连接组件的连接线,如下:

在建立连接线时,会出现“排序需要”的提示。这是由于记录集连接组件是按接收数据的顺序进行记录关联的,如果接收的数据是无序的,可能会造成记录连接结果出错。

(3)添加字段选择组件
两个表数据进行连接后,会出现重复的字段“产品ID”。我们可以通过“字段选择”组件移除这个多余字段。
在搜索输入框中输入“字段选择”,将字段选择组件拖拽至画布中

将字段选择组件名字修改为“移除产品ID_1字段”

创建记录集连接组件到字段选择组件的连接线,如下图:

(4)添加过滤记录组件
本次实验是根据订单的利润情况对订单进行分流。使用“过滤记录”组件可以根据记录中某个字段的值进行记录分流。
在搜索输入框中输入“过滤记录”,将过滤记录组件拖拽至画布中

创建字段选择组件到过滤记录组件的连接线,如下图:

在选择连接线的弹窗中点击“主输出步骤”。由于在进行字段选择操作时,可能有记录不满足要求,导致记录被标记为错误。主输出步骤表示满足要求的记录通过该连接线传输数据。

(5)添加 excel 输出组件
记录经过“过滤记录”组件后会被分成2个记录流。我们可以根据业务需求将2个记录流输出到指定位置(文件、数据库表)。在本次实验中,我们选择将记录输出到 Excel 文件中。
在搜索输入框中输入“excel 输出”,将2个表输出组件拖拽至画布中

2个 excel 输出组件分别命名为“盈利订单”和“亏损订单”,并创建过滤记录组件到两个 excel 输出组件的连接线,在选择连接线类型的弹窗中分别选择“True输出”和“False输出”。
“True输出”表示满足过滤条件的记录输出。
“False输出”表示不满足过滤条件的记录输出。


至此,一个完整的转换任务流程构建完毕,如下图:

2.8 配置组件信息
组件添加完成后需要对其进行相应配置。
2.8.1 表输入组件配置
双击订单_详细订单表输入组件,弹出组件配置页面。在数据库连接下拉框中选择已同步的“线上公共数据源(Readonly)”如下图所示:

点击“获取SQL查询语句”,自动生成SQL查询语句。

点开“线上公共数据源(Readonly)”-“表”目录

下滑找到 business_anaylsis.order_detail 并点击它,再确定

系统自动填写了完整的 SQL 查询语句后,点击“确认”。当自动生成的 SQL 语句无法满足业务需求时,也可以通过在文本框输入自定义 SQL 语句。表输入组件的其他配置参数保持默认即可,

另一个订单_产品信息表输入也参考上述配置,获取表 Business_analysis.product 的 SQL 查询语句

2.8.2 记录集连接组件配置
双击记录集连接组件,在下拉列表中选择需要连接的数据来源
第一个 Transform 选择订单_详细订单,第二个 Transform 选择订单_产品信息,连接类型选择 LEFT OUTER

点击第一个 Transform 的连接字段中的“获得连接字段”按钮,即可获取表输入组件在订单_详细订单查询到的字段

同样的,获取第二个 Transform 的连接字段

第一个 Transform 字段保留 produc_id,第二个 Transform 的字段保留 id,连接类型选择 LEFT OUTER,表示使用订单_详细订单的字段 produc_id 与订单_产品信息的字段 id 进行左外连接
第一个 Transform 字段中除了 produc_id 外的其他字段,右键点击“删除选中的行”,第一个 Transform 字段中除了 id 外的其他字段,右键点击“删除选中的行”

删除完后,点击“确认”,若删除错误,可重新获取连接字段进行删除

2.8.3 字段选择组件配置
通过记录集连接后,我们可以发现,字段 produc_id 与字段 id 内容相同,只需要保留一个,因此,需要使用“移除产品ID_1字段”字段选择组件的移除选项移除字段 id,具体操作如下:
双击“移除产品ID_1字段”字段选择组件,点击“移除”,并点击“获取字段”

在获取的字段中选中除“id”字段以外的字段,右键点击“删除选中的行”

2.8.4 过滤记录组件配置
根据业务需求需要将盈利订单和亏损订单分开存储。两个订单可以使用字段利润来区分
双击“过滤记录”组件,在弹窗中的下拉列表中选择不同的后续处理步骤,如下图:

选择字段利润(profit)来作为判断字段,选中“profit(Number)”后点击“确定”

>=0 作为判断条件,点击“=”,在函数中选择“>=”,点击“确定”

点击“value”,值类型选择“Integer”,值输入“0”点击“确定”

2.8.5 Excel 输出组件配置
将接收到的结果写入到 Excel 表中。双击“盈利订单”excel 表输出组件,在配置弹窗中,文件名修改为“盈利订单”,选择文件拓展名“xlsx [Excel 2007 and above]”

在配置弹窗中点击“输出字段”,在空白表格处右键点击“获取字段”

“亏损订单”的 excel 组件也进行同样的设置

2.9 执行转换
组件配置完成后,可执行转换任务,点击启动按钮

在弹出的窗口中点击“启动”、

执行成功

2.10 查看执行日志
任务执行过程中,会将相关操作记录到日志中,任务执行完毕后,可查看执行结果及日志,如下所示

2.11 查看结果
点击“文件库”,右键根目录刷新,可以看到转换任务的输出结果:盈利订单和亏损订单,可以右键下载查看

三、实验结果
| 输出文件 | 内容 | 说明 |
|---|---|---|
| 盈利订单.xlsx | profit ≥ 0 的订单 | 可进一步分析高利润产品 |
| 亏损订单.xlsx | profit < 0 的订单 | 可用于亏损原因追踪 |
实验成功实现了订单数据的关联与分流处理,为后续的盈利分析提供了规范的数据基础。
四、核心组件说明
| 组件 | 作用 | 本实验配置要点 |
|---|---|---|
| 表输入 | 读取数据库表 | 配置数据源和 SQL,自动获取字段 |
| 记录集连接 | 多表关联 | 选择连接类型和连接字段 |
| 字段选择 | 字段筛选与重命名 | 移除重复的 id 字段 |
| 过滤记录 | 按条件分流 | 设置 profit ≥ 0 |
| Excel 输出 | 导出结果 | 配置文件名和输出字段 |
五、问题与解决
在实验过程中遇到了两个问题:
问题1:Excel 输出获取不到字段
解决方法:配置 Excel 输出时点击“获取字段”没有反应,原因是过滤记录到 Excel 输出的连接线类型选错了,盈利订单应连接“True 输出”,亏损订单应连接“False 输出”。重新创建连接线并正确选择后恢复正常。
问题2:Excel 输出组件因文件名相同导致执行报错
解决方法:配置完两个 Excel 输出组件后执行转换,系统报错。检查发现两个组件的默认输出文件名都是“file”,没有修改。两个输出步骤使用了相同的文件名,导致平台无法区分。将盈利订单和亏损订单的“文件名”分别修改为“盈利订单”和“亏损订单”后,重新执行正确。
六、实验总结
通过本次实验,熟悉了助睿零代码 ETL 平台的基本操作方法,包括创建项目、同步数据源、新建转换流、添加和配置组件、执行转换以及查看结果。掌握了表输入、记录集连接、字段选择、过滤记录、Excel 输出等常用组件的配置方法,理解了多表关联条件分析流数据处理中的应用。
相比传统编写 SQL 和脚本的数据处理方式,助睿平台的零代码拖拽式操作更加直观,组件之间的数据流向清晰可见,便于理解和调试。对于初学者来说,这种方式降低了学习门槛,能够快速上手完成常见的数据加工任务。
#助睿数智 #商业数据分析 #ETL数据加工 #数据实验
更多推荐



所有评论(0)