了解数据接入
数据接入是我公司自主研发的一款数据接入工具,提供可视化的界面方便用户进行数据的接入,支持数据以全量、增量、业务主键覆盖等方式将数据同步到本平台中。
| 目录 |
|---|
| View file | ||||
|---|---|---|---|---|
|
1. 概述
数据接入是我公司自主研发的一款数据接入工具,提供可视化的界面方便用户进行数据的接入,支持数据以全量、增量、业务主键覆盖等方式将数据同步到本平台中。
2. 界面概览
| 信息 | ||
|---|---|---|
| ||
| 信息 | ||
|---|---|---|
| ||
| 信息 | ||
|---|---|---|
| ||
| 信息 | ||
|---|---|---|
| ||
| 信息 | ||
|---|---|---|
| ||
| 信息 | ||
|---|---|---|
| ||
3. 数据接入
3.1 创建非实时应用
3.1.1创建mysql、sqlserver、oracle驱动类型的应用
创建应用: 点击添加,输入应用基本信息、联系人、驱动类型、服务器配置后,点击测试连接,连接通过,即可创建应用。
应用名称:一般是中文描述。
应用简称:一般是英文名称,类似数据库的架构名称。
应用负责人:一般是该系统的IT负责人,方便后续在数据接入的过程中,如果发现上游系统无法正常访问时,能够第一时间得到相应的帮助。
负责人邮箱:同应用负责人作用一样。
驱动类型:本平台支持的几种上游系统,如mysql、sqlserver、oracle、ftp文件系统、非实时api调用、RestfulAPI实时推送。
服务器配置:本平台同步数据时,用于连接上游系统的服务器基本信息
3.1.2创建物理表
1.新增一张物理表;
2.选择刚才新增的;
3.在页面的SQL编辑器中输入业务SQL;
4.进入字段映射配置页面
5.对字段进行配置
6.进入覆盖方式页面
数据类型:
- 文本:
- 存放文本类型数据。
- 设置长度。
- 整型:
- 存放数值类型,无小数类型。
- 时间戳:
- 存放时间类型数据。
- 浮点数:
- 存放小数类型数据。
- 设置精度。
- 字符串:
- 存放字符串类型数据。
- 设置长度。
3.2 创建ftp驱动类型的应用
点击管道进入管道设计界面,左侧是可拖拽的任务组件,分别是:开始、任务组、数据湖表任务、数仓表任务、分析模型任务。
- 开始:流程起点,用来设置整个流程的调度时间、频率,调度类型有两种:TIMER DRIVEN :TIMER DRIVEN 输入框输入的为秒(只能输入数字)或 CRON DRIVEN :自定义设置。
- 任务组:可以理解为任务的集合,可将多个任务(数据湖表任务、数仓表任务、分析模型任务)放在一个任务组里。
- 数据湖表任务:数据湖表对应数据接入中的物理表。
- 数仓表任务:数仓表对应数据建模中的物理表。
- 分析模型任务:分析模型对应数仓建模中分析指标模块中创建的表。
在左侧选中需要用到的组件拖拽到右侧的设计面板中。
连接管道,利用连接点连接管道活动,连接的顺序代表数据同步的顺序。
任务组件:
1.开始:
选择 CRON DRIVEN 点击自定义设计时间调度,弹出弹窗可自定义设计调度。
2.数据湖表任务
选中数据湖表任务,在左下角切换到数据表选项点击“+”图标弹出需要同步数据的物理表供用户选择。
3.数仓表任务:
数仓表任务的操作流程和数据湖表任务的流程相同,唯一不同点在于数仓表任务把物理表分成了维度表和事实表两类;
4.分析模型任务
同2、3 。
3.3 保存&发布
数据同步流程设计好了之后点击右侧的“保存&发布”按钮既可,稍后会根据设计的流程后台自动生产数据同步的调度任务,根据设置的调度频率自行调用。如果是点击的“保存”按钮,那么只会保存设计的流程,不会在系统后台生成调度任务。


















