|
|
EDA365欢迎您登录！
您需要 登录 才可以下载或查看，没有帐号？注册
x
数据平台建设4 J4 T( V# P8 Q4 ^! t2 p1 Z$ u* W+ m
平台要解决的问题/ y; m/ m* G# V0 w/ u
8 f% h/ W2 W; g/ c- ~! l 数据质量层次不齐* V6 \% _. P) U6 s
数据交换和共享困难- L% R- U) s" ~; p y3 c
缺乏有效的管理机制$ u" G: y7 D. H& u2 C7 Z6 V4 W
存在数据安全隐患
2 G D: }5 G# z/ A9 J7 L6 {3 l+ K1 E9 k/ O
平台架构要求的能力( X+ X# J" x4 z ^& ^. }
+ {' ~5 M2 |+ v/ G3 X' H! @
无数据模型的架构! W( V5 z$ ?/ T3 P9 g- _
& q4 I+ E8 F$ [, T7 ]$ D9 L
很多时候数据处理都是在一个无模式或者非结构化或者半结构化的数据集上进行处理5 Z# }& U# L9 N$ b3 l/ y1 s
1 n' R& g7 {: ^& z' H6 j( [ 近实时的数据采集
2 u0 W& l# F! u7 I0 M
# [- y! a" X& q+ G0 a* g8 g! W$ c' m- {: f2 l 批量采集和实时采集" ^6 F# s8 m2 R
5 y3 }# ~, h, |; f 微批处理的能力. H- B, ~8 u# `1 a/ z
8 z1 w' M) O/ s1 s
基础设施的要求
- i! @" @- R: j# [" [ S7 P$ ?- Q# ^; d( p' ]- b
线性可扩展
( G1 r6 Z3 G" [7 u$ H. X7 Z 高吞吐量
2 x9 p9 h- H8 y! R: b/ V/ q 容错能力
: F5 r# N% r# J 分布式数据处理
: {5 y* Q/ k3 k& Q
' y3 [( k2 J/ I8 E0 A具体的平台化工具- d$ V: O4 o9 E! p
任务调度系统
( B; k% L/ @% [( E( N3 H
3 Z* q3 E; O! s; W# x 数据采集任务、数据同步任务、数据清洗任务、数据分析任务等；这些任务除了定时调度，还存在非常复杂的任务依赖关系，比如：数据分析任务必须等相应的数据采集任务完成后才能开始；数据同步任务需要等数据分析任务完成后才能开始；, e/ _$ A% T/ x! {# \
调度系统，更确切地说，作业调度系统（Job Scheduler）或者说工作流调度系统（workflow Scheduler）是任何一个稍微有点规模，不是简单玩玩的大数据开发平台都必不可少的重要组成部分。6 _- Z9 `% G. X7 C
/ k4 \' h/ l8 k. }) b# V( O" x W
除了Crontab，Quartz这类偏单机的定时调度程序／库。开源的分布式作业调度系统也有很多，比较知名的比如：oozie，azkaban，chronos，zeus等等，此外，还有包括阿里的TBSchedule，SchedulerX，腾讯的Lhotse，当当的elastic-job，唯品会的Saturn等等' @: H* [& P- d3 Z: K" O
, k$ r+ I+ \; y, M
可以说，几乎每家稍微有点规模的数据平台团队，都会有自己的调度系统实现方案，要不然自研，要不然在开源的基础上进行一些封装和改造（比如很多公司采取了封装oozie的方式）。0 I( Y) p; @2 r l! {3 [
9 j3 v1 C( e# R! U1 _/ Z
资源调度系统，它的工作重点是底层物理资源的分配管理，目标是最大化的利用集群机器的CPU／磁盘／网络等硬件资源，所调配和处理的往往是与业务逻辑没有直接关联的通用的程序进程这样的对象。5 X& O; ?* m" ?
+ V, d& }5 E! F8 Z8 l 作业调度系统有时也会考虑负载均衡问题，但保证负载均衡更多的是为了系统自身的健壮性，而资源的合理利用，作为一个可以优化的点，往往依托底层的资源调度系统来实现。
: O& H! |5 W& b) V7 U1 E& ]$ |$ i9 V! W
一个成熟易用，便于管理和维护的作业调度系统，需要和大量的周边组件对接，不仅包括各种存储计算框架，还可要处理或使用到包括：血缘管理，权限控制，负载流控，监控报警，质量分析等各种服务或事务。这些事务环节，在每家公司往往都有自己的解决方案，所以作业调度系统所处的整体外部环境，千差万别，再加上各公司各种业务流程的定制化需求进一步加大了环境的差异性，所以，调度系统很难做到既能灵活通用的适配广大用户的各种需求，又不落到太过晦涩难用的地步。 }/ _* B& V9 A8 g
; K5 n; `9 u4 ]6 D* W0 R- w& {! [调度类型* d, E! l3 S7 s
依赖调度0 c7 e& |" N0 B& G0 P$ F7 S% s
: p) Q" \8 D9 b1 p# o; c 父依赖执行完开始执行$ B7 g. T* @3 {+ r; F; D
: I; |' |( y0 W- P; Z9 ~时间调度
3 G3 v7 W* ]) G9 |7 j
2 k0 E) J) Y( _ ]6 O) W' M; s 到达特定的时间点开始执行
+ Q- N8 D* n& A& `7 u( I& N( j4 F+ R, Z" C- r" B- q
依赖推荐 a' H9 g3 W6 y
, T) k0 o$ x" @( x3 x( B7 j
随着数仓的建设，表越来越多，依赖推荐尤为重要，自动依赖推荐可以避免少添加依赖的数据错误(数据错误任务状态不会错误，不容易发现，只能通过数据质量监控平台或者业务方反馈)、多添加依赖的无用等待，以及循环依赖的致命错误
+ x" Q) F' V" g: R% W/ F A3 |
`* n3 G5 @3 L: s9 [8 N基线控制* C, R' B& T/ M2 ]7 j1 k1 w
9 u( G' w4 j4 V" |& g
大数据离线计算通常作业执行时间比较长，如果不能及时发现问题，重跑需要几个小时，显然来不及
0 A, K2 Y/ I4 U. l3 e3 W
) }, u" Z0 \* k0 l统一管理
/ O6 V( N: N$ s
X3 d$ k- h. w! `, @ q8 t 统一管理作业的完成时间、优先级、告警策略、保证数据加工按时完成，调度模块需要根据重要性、优先级、最短执行时间策略进行动态资源调整，让资源利用率最大化，损失最小化) s, O( I, |& `, x2 c3 j
& p+ Q% r& r1 U算法预测和调控
- m/ B" c# n& G5 d) A' ~$ n9 f b {# c3 U8 U. a9 l
算法对正常数据进行训练，当作业无法正正常产出和动态调整资源无法完成的时候，调度中心会通知运维和值班人员进行接入处理。0 R( O7 r$ _; ^! h( e6 Z
3 D- Y" A# t; V* G
代码校验$ w2 C" r5 v4 P3 g# ]% a- H! D
, J3 F! }1 A' N0 _' [. W- A) S+ ~
设计了代码上线时候的语法检测，并且设计了试运行和线上以及测试三种运行模式，上线的时候必须有试运行成功的记录
, g2 q8 _; i# x% Q G5 a% D% F0 e2 R( ^6 N1 e: o! ?( @
环境隔离' b$ ?. c5 t+ Q$ t# Y: @1 ?% R
) U7 o3 @$ d2 b% d 通过运行模式实现了测试和试运行以及线上形成了测试环境、uat环境、线上三种环境7 ], z. x0 ^: X. ~" c4 r. |9 ^
+ _7 O3 m; `3 u
多引擎支持
9 p6 F4 v3 h% F; x
9 a d ]2 ?6 p+ m }3 [ 支持自定义脚本，hive,sprk,python，等多种引擎& Z+ f, M1 W1 U7 d- k% w
Y% E9 Q8 y* |4 H2 P
功能* U4 M1 d5 X4 |
- b6 G" v3 L) F. G$ ?( F& \. I 用户可以在管控后台中，自主的对拥有权限的作业／任务进行管理，包括添加，删除，修改，重跑等。对没有权限的作业，只能检索信息。
" t0 @" t$ s: s: U6 e 支持当日任务计划和执行流水的检索，支持周期作业信息的检索，包括作业概况，历史运行流水，运行日志，变更记录，依赖关系树查询等。% d4 l0 V2 V! r# G4 l" Q
支持作业失败自动重试，可以设置自动重试次数，重试间隔等
3 x$ k; S9 i# P! j3 z. e 支持历史任务独立重刷或按照依赖关系重刷后续整条作业链路# |/ [7 ^+ ~( q- I
允许设置作业生命周期，可以临时禁止或启用一个周期作业' m$ T2 ^$ K6 H- u
支持任务失败报警，超时报警，到达指定时间未执行报警等异常情况的报警监控( v) S3 l; N# Q, a9 |
支持动态按应用／业务／优先级等维度调整作业执行的并发度 S1 O; |1 h, J3 N
调度时间和数据时间的分离& H$ \* z2 P9 j
6 o/ ]; ~) T+ H% v, W
支持灰度功能，允许按特定条件筛选作业按照特定的策略灰度执;根据血缘信息，自动建立作业依赖关系;任务日志分析，自动识别错误原因和类型: {0 m$ |3 H) j( O
) W5 w+ R3 k, R0 i
元数据管理系统(元数据治理)! R& m; b6 U' I
数据安全$ ^4 B: h- ]+ \7 S3 v8 v" p
数据安全——权限/ Y- N/ E4 }% e, z. P4 T2 [
/ }& I# A' F* n2 }! ^
核心数据的权限管理
0 P- h) h+ j2 _) X2 S0 Z0 t. q0 [3 r _6 |1 k% `! ^
数据安全——脱敏
% r' b) ~* N/ ~- U: Q) g
- p, a- _7 I4 c, r1 w2 o% g 数据脱敏9 q( A% F( s# H F [2 _7 S
; {1 ?+ s( h. k d/ \血缘关系 H' y( W* C. @4 S! D M# A+ b; G
数据生命周期管理. j! H$ h3 i7 L6 c
数仓的治理规范的落地; R7 E- J9 U" K
7 M6 P6 G3 N+ x) ?1 p6 p& D 建表的权限; s$ j, j% `; |' r& E G
命名是否规则. K2 Y: k- j2 j3 u& D O
7 U9 X8 R7 n- e3 w数据质量监控平台 ~% U2 s: Q7 i) E& \$ U
0 w+ T: r4 Q' |4 Z
随着大数据时代的带来，数据的应用也日趋繁茂，越来越多的应用和服务都基于数据而建立，数据的重要性不言而喻。而且，数据质量是数据分析和数据挖掘结论有效性和准确性的基础，也是这一切的数据驱动决策的前提！如何保障数据质量，确保数据可用性是每一位数据人都不可忽略的重要环节。: o! s1 ^ l; J& \. N0 z
0 n/ @( p9 z1 _. z$ `
完整性、准确性、一致性和及时性
+ H4 s( v9 W. y) Y( d4 `7 C
: c p2 F6 U0 c+ S4 {( r5 w
2 u" \ R- r' m( N完整性 i/ k" D1 c: [
$ R" @& A: D% n+ M1 Y 完整性是指数据的记录和信息是否完整，是否存在缺失的情况。数据的缺失主要包括记录的缺失和记录中某个字段信息的缺失，两者都会造成统计结果不准确，所以说完整性是数据质量最基础的保障$ F7 V; `: m* a8 Z8 C
考虑两个方面：一是，数据条数是否少了，二是，某些字段的取值是否缺失。完整性的监控，多出现在日志级别的监控上，一般会在数据接入的时候来做数据完整性校验。: p: A x' B" b
( y, b0 D0 P8 z* x2 V
数据同步工具故障5 @. r" Z: `4 a. f: Y$ G
数据被归档
8 [% l; h* i% _& U; v$ c: w准确性
+ }, ~! [# S4 r) e1 R0 ~- T6 ]: X, U- `9 a
准确性是指数据中记录的信息和数据是否准确，是否存在异常或者错误的信息。7 W8 S7 H( I! \8 S3 q
直观来讲就是看数据是否上准确的。一般准确性的监控多集中在对业务结果数据的监控，比如每日的活跃、收入等数据是否正常
% g4 O5 [8 e% e- v3 J5 o8 p; v 常见的度量规则，空值检测、重复值检测、相关性检测、波动性检测、阈值检测、业务逻辑规则检测(非常重要)
+ E6 @6 S2 P& P; I8 b& w
3 [1 g2 B: C& i5 |( E' v7 {一致性9 x7 ^1 x. C9 [+ m( I E
# D( T7 C, B; A, a4 M9 N 一致性是指同一指标在不同地方的结果是否一致
}5 a) i4 Y* u 数据不一致的情况，多出现在数据系统达到一定的复杂度后，同一指标会在多处进行计算，由于计算口径或者开发人员的不同，容易造成同一指标出现的不同的结果。; e, z( q7 \, y+ r$ |4 G
( c8 \" N2 t: e5 [, g& j [# d* K及时性
0 t9 h* a5 s) J4 v' }" @: d. c" F
在确保数据的完整性、准确性和一致性后，接下来就要保障数据能够及时产出，这样才能体现数据的价值
! _/ D8 \% L+ @, B8 R X' y 及时性很容易理解，主要就是数据计算出来的速度是否够快，这点在数据质量监控中可以体现在监控结果数据数据是否在指定时间点前计算完成。
$ M/ d6 ~7 t! P* }$ v 主要随着数据规模的变化，导致边界问题对数据的及时性的影响越来越大(集群故障、网络故障、流量激增) h& U9 X. S9 f. d
3 W) E: _: m. p8 `+ [- U9 V 其实主要是数据源的监控、数据指标的监控、数据表的监控、高级一点的会涉及到全链路的监控, C' f$ r( L& w U, V; v
( ^6 Z2 e) l7 F( A$ W0 h
监控平台设计思路- c* [0 u# s6 f; F
, {* m+ o, F5 z5 d" Q6 r6 }数据：主要是需要被数据质量监控到的数据，数据可能存放在不同的存储引擎中，比如Hive、PG、ES等。1 p$ }: B8 ]/ @' }
! i1 G* Q9 _3 n2 y3 y
规则：是指如何设计发现异常的规则，一般而言主要是数值的异常和环比等异常监控方式。也会有一些通过算法来发掘异常数据的方法。
5 @4 w& @7 r/ f
' T1 @; R/ E- k; U. {; Y0 I告警：告警是指出发告警的动作，这里可以通过微信消息、电话、短信或者是微信小程序的方式来触发告警内容。
% k3 d. u8 d0 |+ a% I& X# _$ r0 A) Z: i/ Y V
反馈：这里需要特别注意，反馈是指对告警内容的反馈，比如说收到的告警的内容，那么负责人要来回应这个告警消息是否是真的异常，是否需要忽略该异常，是否已经处理了该异常。有了反馈的机制，整个数据质量监控才容易形成闭环。更能体现业务价值。2 ?; g6 E( x/ o* O/ R- k2 ^
! }: R, } m- ~4 l0 z" R 1
% b. X' i# [1 M; C/ ^7 O9 Y 2
7 m+ C% Q6 c; A' Y 3
& @, P3 X0 R" F) q. S 4# W' a4 W" V) p/ m) D. b
5# k" q$ M! M( o* e* s
6
: I* V( g* i# f/ s) \; b8 f 77 Y* F' P& o& V; T) j
! K/ e7 P2 `$ @& Y# T
( A/ {) Q9 p( T% w. j' u! g& Z: R$ g, h5 i# W
问题:告警信息太多了,容易被忽略,主要是思路是提高告警的准确率，避免无用的告警' d @( I$ m2 T5 V8 ? K
/ t, x& {; b* h3 t* L3 @' u
多使用机器学习算法的方式来发现异常点，比如：异常森林。
- {: P( p' I7 s9 V8 W! A- E2 J, F2 ^: c" S, z _4 S9 U2 }
加入反馈机制，如果业务负责人认为该告警是正常的，就打上正常的tag，后续告警规则根据反馈进行优化。* |4 B D9 c$ A
% ]* Y! E W' N; ?# e* w
加入屏蔽功能，屏蔽不感兴趣的告警。; h7 E0 H& ~ Z* p8 w: g1 k
9 @7 k1 @$ ~% R' ?9 |% p数据同步平台
# k9 W, E* s0 d" |: I, q
$ @! S$ r: R! A2 o9 L( E8 j 主要有增量同步、全量同步、基于binlog 的实时同步，不论哪种方式到最后都涉及到数据更新合并的问题
) [( p, F4 b7 I4 r) |$ B/ ] 由于数据湖的发展，可能会改变基于binlog 的同步方式(离线——(kafka/hbase),实时——hbase)- }, \" O- d9 D: N) e
这个平台也很重要，因为这是一切的数据来源，而且随着业务的发展，要对接各种各样的数据源，数据同步平台的稳定与准确是一切的基础保障( B) Z7 @& K# c9 p% [
( F% G# g4 v# H- V! M- I' h; w数据同步方式(工具)' f# O# ^8 p1 {/ b6 x/ f6 N
数据库直连同步
4 |+ S; U- u/ e3 _5 P* s2 [* c5 b. m# N8 o
-sqoop
* w; p) m, s3 d2 [& t数据库文件同步 y; l; p. n+ F. G) t+ J
2 s( L5 z8 B7 B2 q9 j1 D) \
自定义脚本
& w6 ]5 c8 H# c0 g5 A5 i% q& N) W# ?5 |: G9 T
会遇到两个问题，一个是网络波动可能会丢包，另一个是源文件比较大需要进行压缩传输。因而通常在传输数据文件的同时，会上传一个校验文件，检测数据量、文件大小等信息，以保证数据同步的准确性' h E3 l0 F& y3 m! o; D
; V, e5 l, V- B# t
数据库日志解析同步
8 G+ x+ ~& w) S0 v4 e9 \# |* \# k
# S9 y. I& g# _- c maxwell、cancel
5 O5 l3 N3 G' C5 z* r& r% X
; O8 _+ z# J& L: ~/ P0 e% L 大多数主流数据库都可以通过日志文件的方式进行系统的恢复，并且由于日志文件的信息记录非常完整，格式解析也很稳定，因而完全可以通过解析数据库日志文件来获得发生变更的数据，再更新离线系统以最大提升效率
$ D. k+ k/ E( o, C* e
3 O, [5 ?% k5 [2 }7 f& u% p1 E; _1 ^数据更新# P% c: B1 T1 n8 W' a
1 ~' Y: Q' M5 Q. |3 L4 p) | 数据库日志解析实现了准实时同步的能力，对业务系统的影响也很小，因而广泛的应用在了从业务系统到数据仓库的增量数据同步应用之中。值得注意的是，由于数据仓库对于更新操作支持比较差，通常会采用先删除、再插入的方式来模拟更新操作
/ ~7 ?* K P* ^: K. b1 {% F, S$ H& z 主要实现方式有两种，一种是通过join 的方式，另外一种是row_number()的方式
$ k) L9 z" h: ?, ^% S
1 Y% u- C& | z. E6 W( S 数据延迟、处理数据量较大及数据漂移，因而中间系统的建设也需要进行一定的编码开发，以消除数据不一致的情况
! ]: b7 [1 j* [! H
4 E- ^& q. X# o% h数据资产服务平台$ k5 W3 n! W$ D
* F' ~& T+ E- t3 c1 D& c 数据资产的定义是由企业拥有或者控制的，能够为企业未来带来经济利益的，以物理或者电子方式记录的数据资源，如文件资料或者数字资料2 W2 f3 S9 e {4 a% N+ B/ M) z) `2 v
对外提供数据支持，直接服务于各个业务线已经公司的数据分析师，只有业务能够读懂能够理解的数据才叫数据资产3 Q1 ~( g4 X. @; o0 O
, P- |0 i0 r6 a5 V
数据分析平台(adhoc)
' s& {, ?) f' b* _: W
$ i- e3 W' p+ j5 c- H 相对于adhoc 而言提供了可视化的功能. V$ A# U+ [9 s
zeeplin
) w% w W2 Y3 e& s& A; W* ? superset* { @% F! K0 r4 n) b* D- {% p
adhoc(自研); z) p0 w4 T# V$ B- e9 ?
- z r2 d. I8 M0 g接口服务(数据资产服务平台)
' O! Q9 |& J v1 m8 C
' w6 E6 O7 t+ r/ b) M$ f 提供sql 的方式进行接口配置，对接口进行统一管理，安全、性能、稳定性、生命周期、监控9 X( _0 ]2 F' H1 o4 b& [
充当数据的提供方，报表数据、计算指标、明细数据、用户画像数据
# x$ V. b" J7 ?1 P! @6 ^# `4 c* A" S! `
报表服务(数据资产服务平台)
' Y7 r8 n" U& ~9 T* ]8 y5 p
, ^+ W% ]7 o% Y r+ C& s/ N BI 工具，支持报表和 Dashboard+ k$ j+ E7 A: R3 f7 H
需要接口服务的接口(其实也可以直接采用sql 配置的方式)
, _; L& Q8 [/ z5 |" e! d4 o: G( L8 D9 ?# D6 A! W0 o
实时数仓8 l+ b _3 B' g
" i! C1 N* ?$ @0 A 资源层面——所有调度任务只能在业务闲时（凌晨）集中启动，集群压力大，耗时越来越长；- X3 _. c$ T8 ?$ d4 T
业务层面——数据按T+1更新，延迟高，数据时效价值打折扣，无法精细化运营与及时感知异常。% |. ~' [! W7 |3 `( v
2 z. @* O* t& u3 g9 R 实时数仓即离线数仓的时效性改进方案，从原本的小时/天级别做到秒/分钟级别。& g, f5 c9 I U( G: E0 c
& ^6 t; x8 B/ c K2 b
底层设计变动的同时，需要尽力保证平滑迁移，不影响用户（分析人员）之前的使用习惯( j5 i5 |- H! F9 ]: U
. d7 }9 r0 [* Z/ o/ e指导思想：Kappa架构- E* l) c! v; I
计算引擎4 e M2 [* s2 F; J
: |+ v2 d5 H& [( U% H+ A 批流一体化——能同时进行实时和离线的操作
: f/ Z4 ?$ }) x+ w- P4 u( [ 提供统一易用的SQL inteRFace——方便开发人员和分析人员3 R' ?+ y9 @9 K' A) ]
6 A/ J6 v2 {+ x' {# E
底层（事实数据）存储引擎
' M( U( u5 f/ l& G2 u: O
+ b( `" s( \: u' t 可靠存储——有一定持久化能力，高可用，支持数据重放。3 x! k3 V6 |& O4 v- Q" s5 y
/ p7 S# ]" @6 |& w
kafka
G3 f2 m: Y: w: ~6 G- _* f& j f8 ?) H" m
实时平台; u# e o0 Z$ k; s% I) J
9 o: B9 p9 F% O9 @* }7 P |
|
/1 
发表于 2023-3-15 14:45
收藏
淘帖
支持！
反对！