数据仓库分层及模型设计
数据仓库前置知识
数据仓库分层
使用数据分层目的，减少重复开发，隔离原始数据，按照业务需求设计层次。较为常见的为早期的四层架构（贴源层ods、明细层dwd、汇总层dws、集市层ads），如果是复杂数仓使用传统的四层架构不能满足需求，多采用五层架构（技术缓冲层ITL、贴源模型层IOL、主题模型层IML、共性加工层ICL、应用集市层IDL），针对每层功能在下面章节详细介绍。
数据存储策略
存储策略分类
数据存储方式分为增量与全量两大类。
增量存储，即每天新增的，这类数据存储方式为每天只抽取增量部分，抽取新增的数据进行存储，一般增量存储都采用分片的方式进行存储，即使用分区的方式进行存储，每天一个分区。
全量存储，即每天存储最新一天全量数据，每天在源系统全量提取最新数据，进行存储，全量存储又分为保存历史与不保存历史，保存历史的通常叫做全量快照表，每天全量保存到一个分区中，另外一种不保存历史的方式则为在数据仓库中只保存一份最新的表，没有分区，不能查询历史某个时间节点的数据。
如上，每天只从源系统抽取跑批日期当天的数据，插入到数仓中跑批日期当天的分区中。
如上，每天从源系统全量抽取，没有where条件，然后插入到数仓的快照表的指定跑批日期的分区中，每天保存一份。
如上，每天从源系统全量抽取数据，覆盖到数仓中的全量表里，但是在覆盖前一定要做数据备份，避免数据丢失，可以在数据插入完成之后，将备份表再删除。
拉链表
拉链表概述
拉链表核心思想，像个拉链，有开链与闭链，我们通常将最新的数据称为开链数据，历史数据称为闭链数据，拉链表支持历史数据查询，且空间占用较小，但是数据加工处理较为繁琐，属于时间换空间的设计方式，拉链表一个时间维度中同一个用户只保存一条用户状态。拉链表通常会增加三个技术字段“开始日期startdate、结束日期enddate、状态标识mark”。
通过主键（PK）与历史数据进行对比，判断拉链表中最新的数据与历史数据是否一致，如果发生变化或者新增则进行相应的开链、闭链操作。
**开链：**是一个开放的区间，一条数据从一个开始时间(startdate)开始一直持续到了现在仍然没有变化，我们也不知道他在未来哪一天才会变化，所以我们通常将enddate设置成一个较大的时间29991231或者30000101。
**闭链：**是一个闭合的区间，指数据在一个时间区间内的状态，有开始时间与结束时间。
拉链表示例
拉链表查询某个时间节点（2021年01月06日）最新状态：
Select * from zip_table where startdate<=20210106 and enddate>20210106;
此时在拉链表中命中了一条数据，即:{xxxname:xxx,gfname:002,startdate:20210105,enddate:20210201}
如上查询方式通常叫做"卡拉链"，startdate<=querydate and enddate>querydate
拉链表形态示例：
| Xxxname | Gfname | Startdate | Enddate |
|---|---|---|---|
| Xxx | 001 | 20210101 | 20210105 |
| Xxx | 002 | 20210105 | 20210201 |
| Xxx | 003 | 20210201 | 29991231 |
如上示例拉链表供记录了三个id的历史变化情况，支持任何时间段历史数据的查询。
拉链表适用场景
有历史某个时间节点查询需求、数据量较大、变化比较缓慢的数据。
如用户基本信息表，数据量非常庞大，手机号这类基本字段不经常变化，但是有变化的可能性，为了满足支持历史某个时间节点的状态查询，有两种实现方式，可以使用全量快照的方式进行存储，但是由于数据量比较大，并且变化的数据较少，每天重复的保存了未变化的数据，造成磁盘空间的严重浪费，第二种方式则为拉链表存储，在数仓中只保存一份数据，某个时间段内只保存一份数据，不重复存储，并且支持历史查询。
类似应用场景还有一些字典表、码表、规则表等。
拉链表算法设计
设计思想，每天从上游抽取全量数据，与拉链表中最新的数据进行对比，针对不同情况处理方式如下：
*修改类：通过对比发现上游系统最新数据与拉链表中的数据不一致，在拉链表中闭链该条数据，同时开启一条新的开链数据，状态标识为"I"；
* 新增类：通过对比发现上游系统有，但是拉链表中没有，在拉链表中新增一条新的开链数据，状态标识为"I"；
* 删除类：通过对比发现上游系统没有，但是拉链表中有，在拉链表中闭链该条数据，状态标识为"D"；
* 未变化：通过对比发现上游系统数据与拉链表中的数据一致，则保持拉链表中现有状态不变；
拉链表SQL分析
数据准备
-- 拉链表建表语句
CREATE TABLE xinniu.zip_table(pk string,col1 string, col2 string,starttime string, endtime string, mark string)ROW FORMAT DELIMITED FIELDS TERMINATED BY '|' STORED AS TEXTFILE;-- 拉链表初始化数据加载
load data local inpath '/tmp/xinniu/zipinitdata' into table zip_table;-- 上游系统建表语句
CREATE TABLE xinniu.source_table(pk string,col1 string, col2 string)
PARTITIONED BY (datatime string)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
STORED AS TEXTFILE;-- 上游系统数据加载
load data local inpath '/tmp/xinniu/sourcedata-20210107' into table xinniu.source_table partition (datatime='20210107');
- step1:拆分开链数据与闭链数据
- 创建开链表zip_table_bk、闭链表zip_table_bf；
- 查询拉链表中开链数据与闭链数据分别插入开链表与闭链表中，在插入数据前需要判断备份表是否为空，如果不为空则不进行插入，避免数据异常;
-- 创建开链表
CREATE TABLE IF NOT EXISTS xinniu.zip_table_bk stored AS orc tblproperties ("orc.compress" = "SNAPPY") AS
SELECT
pk,
col1,
col2,
startTime ,
endTime ,
mark
FROMxinniu.zip_table
WHERE1 = 0 ;-- 抽取开链数据到开链表INSERTINTOxinniu.zip_table_bk
SELECTpk,col1,col2,startTime ,endTime ,mark
FROMxinniu.zip_table join (select count(1) cnt from xinniu.zip_table_bk limit 1) b
WHEREstartTime < '${hiveconf:batch_date}'AND endTime >= '${hiveconf:batch_date}'AND b.cnt = 0;-- 创建闭链表
CREATE TABLE IF NOT EXISTS xinniu.zip_table_bf stored AS orc tblproperties ("orc.compress" = "SNAPPY") AS
SELECTpk,col1,col2,startTime ,endTime ,mark
FROMxinniu.zip_table
WHERE1 = 0 ;--抽取闭链数据到闭链表
INSERTINTOxinniu.zip_table_bf
SELECTpk,col1,col2,startTime ,endTime ,mark
FROMxinniu.zip_table join (SELECTcount(1) cntFROMxinniu.zip_table_bfLIMIT 1) b
WHEREendTime < '${hiveconf:batch_date}'AND b.cnt = 0 ;
- step2:开链表与上游系统新数据关联，提取出发生变化(新增、修改、删除)的数据插入到zip_table_nw变化表中。
-- 中间加工表清空
DROP TABLE IF EXISTS xinniu.zip_table_nw;-- 创建中间表 新增变化修改中间表
CREATE TABLE IF NOT EXISTS xinniu.zip_table_nw stored AS orc tblproperties ("orc.compress" = "SNAPPY") AS
SELECTpk,col1,col2,startTime ,endTime ,mark
FROMxinniu.zip_table
WHERE0 = 1;-- 与上游数据对比，将变化数据插入到变化表中
INSERTINTOTABLE xinniu.zip_table_nw
SELECTnvl(n.pk,o.pk),nvl(n.col1,o.col1) ,nvl(n.col2,o.col2) ,CASEWHEN n.pk IS NULL THEN o.startTimeELSE '${hiveconf:batch_date}'END AS startTime ,CASEWHEN n.pk IS NULL THEN '${hiveconf:batch_date}'ELSE '29991231'END AS endTime ,CASEWHEN ( n.pk is null ) THEN 'D'ELSE 'I'END AS mark
FROM(SELECTpk, col1,col2FROMxinniu.source_tableWHEREdataTime = '${hiveconf:batch_date}' ) n
FULL JOIN xinniu.zip_table_bk o ON o.pk = n.pk
WHERE(o.pk IS NULL )OR (n.pk IS NULL )OR (nvl( CAST(o.col1 AS string) , '' ) <> nvl( CAST(n.col1 AS string) , '' )OR nvl( CAST(o.col2 AS string) , '' ) <> nvl( CAST(n.col2 AS string) , '' )) ;
- step3:开链表与变化表关联对比，生成未变化数据，已变化数据闭链,插入到zip_table_od表。
-- 清空中间表
DROP TABLE IF EXISTS xinniu.zip_table_od;-- 创建中间表 未变化中间表
CREATE TABLE IF NOT EXISTS xinniu.zip_table_od stored AS orc tblproperties ("orc.compress" = "SNAPPY") AS
SELECTpk, col1, col2,startTime ,endTime ,mark
FROMxinniu.zip_table
WHERE0 = 1;-- 对比开链表与变化表，闭环已变化数据，生成未变化数据，插入到zip_table_od表
INSERTINTOTABLE xinniu.zip_table_od
SELECTo.pk,o.col1,o.col2,o.startTime ,CASEWHEN n.startTime IS NOT NULL THEN '${hiveconf:batch_date}'WHEN o.endTime >= '${hiveconf:batch_date}' THEN '29991231' ELSE o.endTimeEND AS endTime ,'I' AS mark
FROMxinniu.zip_table_bk o
LEFT JOIN xinniu.zip_table_nw n ON o.pk = n.pk
WHEREnvl(n.endTime,'29991231') <> '${hiveconf:batch_date}';
step4:清空拉链表，合并变化表nw、闭链表bf、未变化与已变化闭链表od。
-- 清空拉链表
TRUNCATE TABLE xinniu.zip_table;-- 插入数据到拉链表INSERTINTOTABLE xinniu.zip_table
SELECT*
FROMxinniu.zip_table_nw
UNION ALL
SELECT*
FROMxinniu.zip_table_od
UNION ALL
SELECT*
FROMxinniu.zip_table_bf ;
- 最后清空所有临时表
DROP TABLE xinniu.zip_table_bk;
DROP TABLE xinniu.zip_table_bf;
DROP TABLE xinniu.zip_table_nw;
DROP TABLE xinniu.zip_table_od;
可以将上面的所有步骤分装到一个文件中，使用hive -f的方式调用sql文件，使用-hiveconf的方式传入跑批日期，实现调度系统自动调用。
数据架构设计
本次课程采用五层的架构模式，即技术缓冲层ITL、贴源模型层IOL、主题模型层IML、共性加工层ICL、应用集市层IDL，如下图
通俗理解数仓
技术缓冲层
技术缓冲层概述
技术缓冲层(ITL)，贴源抽取，只增加需要的技术字段（ETL date），其他字段保持与源系统一致，该层数据用于给贴源模型层供数，增加缓冲层的目的是为了实现贴源模型层数据处理缓冲，避免计算过程积压在ETL过程。
如上图，如果没有增加缓冲层，贴源模型层如果做拉链表，那么就只能在ETL阶段实现，这样对ETL步骤压力较大，因为ETL服务器性能远不如大数据集群，甚至有些ETL服务器还是单点部署。如果采用了技术缓冲层，那么ETL阶段只需要直抽上游数据到大数据平台即可，不需要在ETL阶段做复杂计算，向贴源模型层的装数动作在大数据平台完成。
同时技术缓冲层可以避免数据加载错误，在数据抽取有误时，在技术缓冲层及时检核发现，进行数据重新抽取，避免数据直接接入贴源层。
本层特点
数据完全贴源抽取，中间不做逻辑计算，只增加技术字段；
在本层需要严格把控数据检核；
数据保存周期一般为一周，采用分区方式保存；
贴源模型层
贴源模型层概述
贴源模型层(IOL)，采用贴源建模的方式加载，数据加工场景通常适合于数据整合度低、时效性要求较高且需要进行加工但又无法直接通过文件加工获得的应用，可以以开放数据库直连的方式对外提供服务，也可以导出数据文件给下游系统的方式对外供数。就应用而言，贴源模型层主要是满足数据的快速接入，建设时效性要求比较高、跨系统的数据分析，从而减轻业务系统的压力，同时支持数据检查和监管类的应用。数据保存周期一般为永久保留，提供多部门任意历史数据查询。
针对多种源系统数据，通过技术缓冲层将数据进行表级关联或历史拉链等算法，将数据存入贴源模型层中，本层中主题设计不会设计特别多，只是针对下游系统对时效性要求较高的场景进行建设，当下游系统有简单模型划分时在本层划分主题，否则交由主题模型层进行主题详细划分。
本层特点
整合度低且不能通过文件加工获得，对建设时效性要求较高,则通过简单处理及模型拆分的方式对下供数；
跨系统数据分析需求，则关联后，使用宽表落地，否则数据保留在技术缓冲层；
数据存储周期一般为永久存储；
主题模型层
主题模型层概述
主题模型层（IML），作为数据仓库中最重要的基础存储区，此数据区将按照分析型业务的特点对所有进入大数据平台的源数据按照主题进行分类存储，主题的划分是对分析型应用系统对数据需求的分类归纳，如金融行业较为权威的九大主题模型，主题模型层数据来源于技术缓冲层和贴源模型层，主题模型层采用弱三范式进行数据组织。
主题模型层会对历史数据进行累积和保存，与技术缓冲层和贴源模型层相比，主题模型层的数据涉及范围更广、存储周期更长。
主题模型层表类型分为以下几类：
第一类、带有时间戳且不会更新的事件表或者几乎每天都会发生变化的流水表；
第二类、会增删改的状态表，数据体量大但是变化频率低，即缓慢变化维SCD（Slowly Changing Dimensions）；
对于第一类表，需要从技术缓冲层获取增量信息，并根据数据映射加载到主题模型层的目标表中，而对于第二类表，在从技术缓冲层获取到数据后，需要使用时间拉链算法进行数据加载和转换，在目标表中以开始日期和结束日期以及标识状态来保留历史数据。
本层特点
偏重于历史和整合；
建设周期较长；
适合实现较长历史周期的数据需求；
适合实现一些站在全局角度的高端分析应用及随机查询需求；
实现多种业务整合的应用需求；
金融主题模型示例
共性加工层
共性加工层概述
共性加工层（ICL），是从业务视角出发，提炼出对数据平台具有共性的数据访问和统计需求，从而构建一个面向支持应用的、提供共享的数据访问服务的公共数据。
共性加工层的数据来源于贴源模型层或主题模型层，数据组织形式采用逆三范式的方式，所以该层的表都是一些较大的宽表，涉及维度较多，这样才能从应用的角度出发设计，基于这种设计初衷，针对多种应用系统进行业务调研，设计出共性部分以及汇总部分，构建共性加工层。
共性加工层的构建主要完成对基础数据的预连接、预计算、预汇总，主要实现目标如下：
同时服务于多个不同应用，实现数据加工结果的共享，减少系统重复加工的开销；
提高用数查询效率；
降低应用开发和数据查询的复杂程度；
实现对常用业务统计口径的定义和维护，避免不同的应用系统加工出来不同口径的结果，如码表、计算规则、营销策略等；
由于不同业务各有特点，所以不同业务的维度和指标将不尽相同，所以共性加工层也需要按照业务适当的划分成不同主题域，如金融领域可划分为：合约级、客户级、产品级、机构级，列举主题域如下：
**合约级：**合约级是银行账户、合同、借据、行用卡等数据的分类汇总，银行账户包括存款账户、贷款账户、内部账户、信用卡账户等，合同包括个人贷款合同、对公贷款合同等，借据包括贷款借据、贴现借据等。
**客户级：**客户级数据汇总主要是针对客户账务数据和基本信息汇总 ，以及客户整合、客户贡献的方案等，一般客户级可以划分为个人客户汇总、个人客户存款汇总、个人客户贷款汇总、个人客户额度汇总、个人客户理财汇总、个人客户其他资产汇总、对公客户汇总、对公客户存款汇总、对公客户贷款汇总、对公客户贴现汇总。
**产品级：**产品级数据汇总主要是按照不同业务产品口径进行的汇总，如贷款业务条线余额统计、中间业务产品收益统计。
**机构级：**机构级主要是对存贷款账户、信用卡、客户主题数据按机构属性的汇总，机构级数据汇总可以由合约级汇总得到，按照机构维度划分，如内部机构信息表、机构对公贷款汇总、机构个人存款汇总、机构对公存款汇总、机构拆借汇总、机构内部账户汇总、机构授信汇总、机构贴现汇总。
应用集市层
应用集市层（IDL），用于支持各种分析型的应用，除了高级分析人员可以对大数据平台进行灵活查询以外，大数据大数据平台上的应用均以数据集市的方式对外提供数据服务，应用集市层不同于共性加工层，其数据仅面向于特定的应用，在应用间不做数据共享，如果应用间使用存在数据共享需求，那么在共性加工层实现共性加工，应用集市层可以构建在大数据平台内，也可以构建在大数据平台以外（应用子系统平台内），其数据组织形式没有固定限制，按照实际应用子系统决定数据组织形式，其数据来源于上层基础数据区与共性加工层。
各种应用集市的建设都依赖于业务实现的需求，所以设计侧重点和设计方法都不同。
转载自海汼部落，原文链接：http://hainiubl.com/topics/75543
数据仓库分层及模型设计相关推荐
- 数据仓库dw层_数据仓库分层之辩
前言,这篇文章最早见过是在2009年的某一个论坛上并保存了下来, 今天发出来读了一遍,不禁思考本质上这些年我们到底进步了什么? 数据仓库的分层可以算是数据仓库架构的子话题.在前段时间参与的一次讨论中, ...
- oracle 数据立方_大数据之数据仓库分层
大数据之数据仓库分层 1. 什么是数据分层? 2. 数据分层的好处 一种通用的数据分层设计 3. 举例 4. 各层会用到的计算引擎和存储系统 5. 分层实现 6.数据分层的一些概念说明 7.大数据相关 ...
- 数据仓库分层和元数据管理
数仓的分层架构 按照数据流入流出的过程,数据仓库架构可分为三层--源数据.数据仓库.数据应用. 数据仓库的数据来源于不同的源数据,并提供多样的数据应用,数据自下而上流入数据仓库后向上层开放应用,而数据 ...
- 数据仓库分层类型-具体实例
数据仓库分层类型 架构发明者 建模方式[5] 著作 数据仓库特点 架构图 Kimball Ralph Kimbal 维度建模 The Data Warehouse Toolkit 自底向上 Inmon ...
- 深度 | 数据仓库分层存储技术揭秘
简介: 作者: 沄浩.士远 一 .背景 据IDC发布的<数据时代2025>报告显示,全球每年产生的数据将从2018年的33ZB增长到2025年的175ZB,平均每天约产生491EB数据.随 ...
- 两种数据仓库分层实例
数据仓库分层,目前见到的两种分层: 分层一 标准的数据仓库分层:ods(临时存储层),pdw(数据仓库层),mid(数据集市层),app(应用层) ods:历史存储层,它和源系统数据是同构的,而且这一 ...
- 数据仓库分层存储技术揭秘
一 背景 据IDC发布的<数据时代2025>报告显示,全球每年产生的数据将从2018年的33ZB增长到2025年的175ZB,平均每天约产生491EB数据.随着数据量的不断增长,数据存储 ...
- 数据仓库面试题——数据仓库分层
答案来源:大数据面试题V3.0,523道题,679页,46w字 问过的一些公司:字节 x 2,字节(2021.07)-(2021.08)-(2021.10),阿里 x 2,爱奇艺,百度 x 2,百度( ...
- 为什么要对数据仓库分层？
存储在ODS层的数据显然是不能直接使用的,要经过层层处理:如果一步到位计算出各类指标将来业务变化的时候又要重头开始开发一遍,因此数据仓库分层是很有必要的. 数据仓库分层主要有以下几点好处: 1.把复杂 ...
- B06 - 004、数据仓库分层架构
初学耗时:0.5h 注:CSDN手机端暂不支持章节内链跳转,但外链可用,更好体验还请上电脑端. 一.数据仓库分层架构 1.1 数据仓库架构分层. 1.2 数据仓库架构分层详解. 1.3 ...
最新文章
- 刷题：二叉树的遍历方式及根据遍历结果还原二叉树
- Quartz.NET基础知识概述
- 特别的需要名言警句提醒一下自己
- [转载]婚姻不只是娶一个女人那么简单
- 使用Spring-AOP
- 210串口控制台-210移植printf不好使
- 支撑日活百万用户的高并发系统，应该如何设计其数据库架构？
- mysql 随机选取一条记录
- 【BZOJ2456】mode，卡内存
- platform_device_add()函数分析
- 曾经很火的迅雷，为什么现在不怎么火了？
- ruby分割字符串_Ruby中常用的字符串处理函数使用实例
- 《信号与系统学习笔记》—信号与系统（一）
- 人人译视界 for Mac(智能协同翻译)
- html多重阴影效果,如何使用css3实现文字的单阴影效果和多重阴影效果（附完整代码）...
- 安装wsl kali 遇到WslRegisterDistribution failed with error: 0x80070057 Error: 0x80070057解决
- Fibonacci Additions （区间加优化）
- 三分学习（解决凸函数or凹函数的极值）
- 微信关注公众号跳转关注页面
- lisp 阿基米德螺旋_用CAD如何画阿基米德螺旋线