导读:
a、什么场景下会使用到ETL?
b、ETL与ELT的区别是什么?
c、如何快速了解ETL开发流程?
图11、ETL介绍
ETL:是英文Extract-Transform-Load的缩写,用来描述将数据从来源端经过抽取(extract)、转换(transform)、加载(load)至目的端的过程。
ETL:概念通常用在数据仓库,但其对象并不限于数据仓库,什么意思呢?就是只要有涉及到数据搬运都是源到目标的过程,如:数据库迁移(Oracle迁移到MySQL)等。
使用ETL技术可以解决以下相关场景:
1、数据分散在各个系统中需要对数据进行整合,如:(图1)非常形象。
2、数据迁移到不同的环境,如:数据库、操作系统等
3、数据处理效率非常低下,如:有的用Python处理、Java处理等
2、ETLVSELT
ETL与ELT的最核心区别是:抽取源数据是否需要后再加载到目标
设计时需要思考的问题如:
1、数据的可追溯性
2、ETL服务器资源
3、数据库服务器资源
4、程序职责边界划分
目前业界互联网80%都是基于ELT开发,传统大型数仓都是基于ETL开发。如下:
1、基于Hadoop体系构建的数据仓库,都是基于开源工具来做数据同步(如:DataX、Sqoop、Kettle等),然后基于同步数据来做相应ETL操作。
2、基于RMDB(Teradata\PostgreSQL\Oracle\DB2\MySQL\SQLServer)构建数据仓库,都是基于ETL工具来开发设计,如:Informatica、DataStage、SSIS、Kettle等。
3、ETL开发流程
图2数仓ETL开发流程分别为:流程设计、概要设计、逻辑设计、代码实现、任务调度、数据质量
流程设计:是对数据整体链路流程描述说明概要设计:明确数据各环节处理过程逻辑设计:源到目标映射处理关系代码实现:是逻辑代码的具体实施调度任务:任务之间依赖关系与处理流程控制数据质量:监控源与目标是否准确无误产出:ETL开发设计文档、单元测试用例
3.1、流程设计
涉及ETL整体流程链路,明确源到目标之间过程描述
数据来源信息明确数据源相关详细信息,数据库需说明相关信息,如:IP、端口、用户名、密码、表名称;日志需说明相关信息,如:服务器信息、目录、文件名称等
数据处理过程指源数据处理存储逻辑概念描述,而非指具体处理过程。如:数仓、DataX等
数据目标输出指数据最终输出目标,目标可能是:Hive、MySQL、ClickHouse、API、File等
3.2、概要设计
基于源数据进行分析,确定数据抽取、装载、问题环节相关策略。
数据探查数据来源分两类:一类业务数据(DB);一类行为数据(日志)。两类数据都需要对结构、字段、字段值、字段解释进行探查。
表、日志结构表结构或日志结构实际是否与文档描述一致,如:业务方说某字段在表中是唯一,但实际表结构并未设置唯一键问题;防止发生少表问题。
字段实际是否与文档描述一致,防止发生缺少字段、新加字段问题。
字段值实际检查枚举值、状态值等是否与文档描述一致,防止与业务方描述不一样问题。
解释表结构、日志结构、字段都应当有具体文档解释说明。
抽取策略确定数据抽取口径(全量、增量);明确数据提取频次(如:时、天、周、月)
装载策略确定源数据到目标表装载策略类型(如:增量、Merge、全量)
问题处理问题处理方式确定,如:执行时间过长,配置超时告警。执行出失败,邮件告警(默认)。关键核心数据配置电话通知告警。
3.3、逻辑设计
源到目标过程具体字段处理逻辑说明
命名规范参见:《数仓命名规范》
映射关系源数据到目标表的字段映射关系
转换规则源数据到目标表字段处理逻辑
3.4、代码实现
基于逻辑设计编写程序实现具体功能
开发规范参见:《数仓开发规范》
脚本性能程序实现需要考虑具体性能问题,性能要求如下:
未能达到性能要求,不能上线生产环境(特殊情况需向研发负责人说明)
引擎策略根据具体业务要求采使用不同执行引擎,如:MR、Presto、Spark等
单元测试参见:《脚本测试》
3.5、调度任务
脚本开发完成后在调度系统中指定相应时间让任务运行
命名规范参见:《调度命名规范》
依赖配置配置脚本涉及到的所有前置任务依赖
资源控制合理控制任务并发数让资源合理使用,避免任务与任务之间出现资源争抢。
流程控制根据具体业务情况控制任务优先级、项目与任务之间关联关系
单元测试参见:《调度任务测试》
3.6、数据质量
确保数据从源到目标加工过程的准确性、完整性、一致性
命名规范参见:《数据质量命名规范》
源与目标校验校验源到目标数据,如:记录数、数值汇总、分维度+记录数+数值汇总校验
数据交叉校验校验源到多目标、多源到目标、相同指标跨表等数据,如:记录数、数值汇总、分维度+记录数+数值汇总校验
数据趋势校验校验目标表数据历史趋势情况,如:日、周、月、年周期环比、同比校验
单元测试参见:《数据质量测试》
4、ETL工具选型
ETL工具调研选型结合项目实际情况,主要考虑如下:
1、ETL工具是否收费(只考虑免费)
2、团队整体技术栈(比如:Java)
3、ETL工具熟练程度
4、工具社区活跃情况
5、工具文档完善程序
通过以上几点考虑,第1点就过滤了一大批收费工具,再经过筛选只剩下两款工具,分别是:DataX与Sqoop两款。它们之间的功能对比如下
DataX主要的缺点在于单机运行,而这个问题我们通过分布试调度系统规避,其他方面的功能均优于Sqoop,最终我们选择了基于DataX开发。