3. 工程分析平台数据架构:平台典型数据流、数据仓库与数据湖的融合、元数据管理的重要性

工程分析平台的数据架构是支撑主数据集成与访问控制联动配置的骨架。一个设计良好的数据架构,需要清晰定义数据从采集到消费的流动路径,合理融合数据仓库与数据湖的存储优势,并通过元数据管理实现数据的可发现、可理解与可管控。本章将围绕这三个核心维度展开。

3.1 平台典型数据流

工程分析平台的数据流通常遵循“采集 → 集成 → 存储 → 计算 → 服务”的五阶段模型。每个阶段都涉及不同的数据形态与处理逻辑。

阶段 数据形态 典型组件 关键活动
采集 原始日志、IoT 流、API 消息 Kafka、Flume、Logstash 实时/批量接入,协议解析
集成 结构化/半结构化中间表 ETL 引擎、数据同步工具 清洗、去重、主数据匹配
存储 原始文件、列式表、对象存储 HDFS、MinIO、Delta Lake 分层存储,生命周期管理
计算 中间结果、特征宽表 Spark、Flink、Presto 批处理、流计算、OLAP 查询
服务 聚合视图、API 响应 REST API、GraphQL、BI 工具 权限过滤、数据脱敏、结果输出
关键洞察: 在“集成”阶段,主数据(如设备编码、物料号、组织架构)必须与业务数据完成关联,并打上访问控制标签(如部门、密级),后续所有阶段才能基于标签执行权限过滤。

下图展示了工程分析平台中一条典型的“设备振动数据”从采集到仪表盘展示的完整流动路径,并标注了主数据标签注入点。

工程分析平台典型数据流 典型数据流:设备振动监测场景 IoT 传感器 Kafka 消息队列 流处理引擎 Delta Lake API 服务 主数据标签注入点:设备ID + 部门密级 数据流关键说明: 1. 传感器数据经 Kafka 进入流处理引擎,在此处与主数据(设备主数据)进行关联。 2. 流处理引擎根据主数据中的部门信息,自动为每条记录打上访问控制标签(如“研发部-密级2”)。 3. 带标签的数据写入 Delta Lake,后续 API 服务根据用户身份过滤标签,实现行级权限控制。

3.2 数据仓库与数据湖的融合

工程分析平台需要同时处理大规模原始文件(如仿真结果、3D 模型)和高性能结构化查询(如报表、KPI 看板)。单一架构难以兼顾,因此采用“湖仓一体”架构,即数据湖与数据仓库的融合。

架构原则: 数据湖(Data Lake)负责“存”,以原始格式存储所有数据,成本低、灵活性高;数据仓库(Data Warehouse)负责“管”,对结构化数据进行建模、聚合与权限管控,查询性能高。两者通过统一的元数据层和存储层(如 Iceberg / Delta Lake)实现无缝互通。

下表对比了两种模式在工程分析场景下的典型分工:

维度 数据湖 数据仓库
数据格式 原始文件(Parquet、ORC、JSON、二进制) 结构化宽表、星型/雪花模型
典型数据 CAE 仿真结果、点云数据、日志归档 设备台账、质量统计、项目进度
写入模式 追加写(Append-only) 覆盖写(Upsert / Merge)
查询性能 中等(需扫描大量分区) 高(预聚合、索引、物化视图)
访问控制粒度 文件级 / 目录级 行级 / 列级(通过 SQL 引擎)

下图展示了湖仓一体架构中,数据如何从湖流入仓,以及主数据如何作为“粘合剂”贯穿两层。

数据仓库与数据湖融合架构 湖仓一体融合架构 数据湖 (Data Lake) 原始仿真文件 IoT 历史归档 日志与审计 3D 模型文件 数据仓库 (Data Warehouse) 设备维度表 质量事实表 项目宽表 KPI 聚合表 ETL 主数据层:设备、物料、组织架构(贯穿湖与仓)
常见误区: 不要试图将所有数据都加载到数据仓库中。工程分析中的大型二进制文件(如仿真结果 .h5、点云 .las)应保留在数据湖中,仓库只存储其元数据索引(如文件路径、仿真参数、关联设备ID)。这样既能保持仓库查询性能,又不浪费湖的存储成本。

3.3 元数据管理的重要性

元数据是“关于数据的数据”。在工程分析平台中,元数据管理直接决定了主数据集成与访问控制能否落地。没有良好的元数据,数据湖会退化为“数据沼泽”,数据仓库的权限模型也无法追溯。

元数据管理在平台中承担三大核心职责:

  1. 数据发现与血缘追踪: 用户能够搜索到某个设备ID出现在哪些表、哪些报告中,以及数据从哪个传感器、经过哪些ETL步骤而来。
  2. 主数据映射与标签继承: 主数据中的属性(如部门、密级)通过元数据自动映射到所有关联的物理表和列,实现“一次定义,全局生效”。
  3. 访问控制策略的元数据驱动: 权限规则不再硬编码在应用层,而是作为元数据存储在策略引擎中,支持动态调整和审计。
元数据类型 示例 对主数据集成的影响
技术元数据 表结构、分区键、文件格式 确保主数据字段在目标表中正确映射
业务元数据 业务定义、数据所有者、数据质量规则 明确主数据的业务含义与责任方
操作元数据 ETL 运行日志、数据更新时间、行数变化 监控主数据同步的时效性与完整性
安全元数据 数据密级、授权用户/角色、脱敏规则 直接驱动访问控制联动配置
最佳实践: 建议在平台建设初期就引入企业级元数据管理工具(如 Apache Atlas、DataHub 或 Alation),并将主数据模型作为“黄金实体”注册到元数据中心的实体注册表中。后续所有数据集成任务都必须引用该注册表,确保主数据 ID 和标签的一致性。

下图展示了元数据如何作为“中枢神经”连接数据源、主数据、访问控制策略和数据消费端。

元数据管理核心地位 元数据管理:平台中枢神经 元数据中心 实体注册表 + 策略引擎 数据源 主数据系统 访问控制策略 数据消费端 注册 同步 下发 查询
实施建议: 在工程分析平台中,元数据管理不应是事后补充,而应与数据管道同步建设。建议在每条数据管道上线前,先在元数据中心注册其输入输出实体、主数据关联字段以及预期的访问控制标签。这能大幅减少后期数据治理的返工成本。