指标宽表 · 标签画像 · 专题数据集市
特征服务
数据质量
Flink 流计算
② 沉淀
贴源沉淀 → 明细治理 → 主题汇总 → 应用宽表
运营分析
数据产品
Flink CDC
权限脱敏
④ 服务
ODS 贴源层
原始落库 · 增量归档 · 可追溯回溯
机器学习
标准规范
实时查询
服务上送应用
元数据目录
生命周期
主题域汇总 · 轻度聚合 · 复用中间表
数据源
对象与文件
血缘影响
02
业务库 CDC
清洗归一 · 维度关联 · 事实明细
Spark 批处理
API 网关
ADS 应用层
⑥ 治理闭环
Kafka 总线
三方 API
计算引擎
批量同步
经营看板
① 接入
消息队列
XX数据平台 · 湖仓一体架构
开放共享
03
IoT / 传感
DWD 明细层
自助分析
风险预警
智能推荐
DWS 汇总层
04
OLAP 分析
01
数据 API
③ 加工
说明:湖仓分层承接采集结果,计算引擎读写各层;数据服务统一对外,治理规则约束全链路读写与共享。
埋点与日志
数据应用层
标签画像
数据湖仓分层
多元接入 → 湖仓分层 → 双引擎计算 → 统一服务 → 业务应用 治理与安全贯穿全链路
数据服务
⑤ 消费
数据治理与安全
采集接入
统一指标