1. 企业数据湖与分析平台蓝图

企业数据湖与分析平台的建设,本质上不是“买几个 Azure 服务拼起来”,而是围绕数据从产生到消费的全生命周期,设计一套可治理、可扩展、可演进的架构体系。Azure 提供了从存储、计算、集成、治理到可视化与 AI 的完整服务矩阵,但真正决定平台成败的,是能否根据企业自身的数据规模、实时性要求、团队技能和合规约束,做出合理的服务选型与分阶段建设路线。

一、整体架构:分层与职责边界

一个典型的 Azure 企业数据湖与分析平台可以划分为五个逻辑层,每层承担明确职责,层与层之间通过标准接口解耦:

  • 数据源层:业务数据库(Azure SQL、SQL Server)、SaaS 应用(Dynamics 365、Salesforce)、日志与事件流(Event Hubs、IoT Hub)、文件与半结构化数据(本地文件、API 返回)。
  • 数据接入与集成层:Azure Data Factory 负责批量与调度式抽取,Azure Databricks 或 Synapse Pipeline 处理复杂转换,Event Hubs 与 Stream Analytics 承担实时流接入。
  • 存储层:以 ADLS Gen2 为核心,按 Bronze(原始)、Silver(清洗)、Gold(聚合)三层组织数据,配合 Delta Lake 提供 ACID 事务与时间旅行能力。
  • 计算与分析层:Azure Synapse Analytics 提供 SQL 池与 Spark 池,Databricks 提供协作式 Notebook 与 ML 运行时,二者按场景分工。
  • 治理与服务层:Microsoft Purview 负责数据目录、血缘与分类,Microsoft Entra ID 负责身份与访问控制,Power BI 与 Azure ML 面向最终消费。

这五层并非必须全部独立部署。中小规模企业可以将计算与存储合并到 Synapse 工作区,用无服务器 SQL 池直接查询 ADLS 中的 Parquet 文件;大型企业则更适合将 Databricks 作为统一计算引擎,Synapse 仅承担 SQL 数据仓库角色。关键在于:存储与计算分离是 Azure 数据湖的底层原则,任何选型都不应破坏这一原则。

数据源层 业务数据库 SaaS 应用 日志 / 事件流 文件 / API 接入与集成层 Data Factory Event Hubs Stream Analytics Databricks 转换 存储层 — ADLS Gen2 + Delta Lake Bronze 原始区 原始格式 · 不可变 · 全量保留 Silver 清洗区 去重 · 标准化 · 类型转换 Gold 聚合区 业务指标 · 宽表 · 星型模型 计算与分析层 Synapse SQL 池 Synapse Spark 池 Databricks 集群 治理与服务层 Purview 目录/血缘 Entra ID 权限 Power BI 可视化 Azure ML 建模

二、核心服务选型:三条典型路线

服务选型没有唯一正确答案,但可以归纳为三条典型路线,企业应根据自身情况选择其中一条作为主线,避免“什么都用一点”导致架构碎片化。

路线核心组合适用场景主要权衡
Synapse 一体化ADLS Gen2 + Synapse 工作区(SQL 池 + Spark 池 + Pipeline)团队以 SQL 为主,数据量中等,希望统一工作区管理Spark 生态灵活性弱于 Databricks,SQL 池成本需精细控制
Databricks 主导ADLS Gen2 + Databricks + Delta Lake + Synapse 仅作 SQL 服务层数据工程与 ML 团队强,需要复杂转换与协作开发Databricks 集群成本较高,需配套成本管控策略
实时优先Event Hubs + Stream Analytics + ADLS + Synapse 无服务器 SQLIoT、风控、实时监控等低延迟场景流处理逻辑复杂度高,Exactly-Once 语义需仔细设计

以某零售企业为例:其日均订单数据约 2000 万条,历史数据 5 年,团队 8 人中有 5 人熟悉 SQL、2 人熟悉 Python、1 人熟悉 Scala。该企业选择“Synapse 一体化”路线,用 Data Factory 每日凌晨批量抽取订单库到 Bronze 区,Synapse Spark 池完成清洗写入 Silver 区,Synapse SQL 池构建 Gold 层星型模型供 Power BI 直连。实时部分仅对支付异常事件使用 Event Hubs + Stream Analytics 做告警,不纳入主数据链路。这一选型与其团队技能结构高度匹配,避免了引入 Databricks 后无人维护的困境。

三、建设路线图:四个阶段

平台建设不宜一次性铺开,建议按以下四个阶段推进,每阶段有明确的交付物和验收标准。

阶段一:基础打通(1~2 个月)。创建 ADLS Gen2 存储账户,启用分层命名空间;建立 Bronze/Silver/Gold 目录结构;配置 Entra ID 服务主体与最小权限访问;用 Data Factory 打通 1~2 个核心数据源的批量抽取。验收标准:核心源数据每日可稳定落入 Bronze 区,数据量、文件数、时间戳可核对。

阶段二:清洗与建模(2~3 个月)。在 Silver 区实现去重、空值处理、字段标准化、缓慢变化维处理;在 Gold 区构建 3~5 个核心业务主题的星型模型。验收标准:Silver 区数据质量规则通过率 ≥ 99%,Gold 层指标与源系统对账差异在可接受范围内。

阶段三:治理与消费(2~3 个月)。接入 Purview 扫描元数据与血缘;配置行级/列级安全;发布 Power BI 数据集与报表;建立数据目录供业务方自助查询。验收标准:关键数据资产 100% 登记目录,敏感字段分类标签完整,业务方可通过目录申请访问。

阶段四:实时与智能(持续演进)。按需引入 Event Hubs 与 Stream Analytics 处理实时场景;在 Databricks 或 Azure ML 上构建预测模型;将模型输出回写 Gold 区供报表消费。验收标准:实时链路端到端延迟满足业务 SLA,模型上线后有明确的监控与回滚机制。

选型检查清单:在确定主线路线前,逐项确认——① 团队中能维护 Spark 作业的人数;② 数据量级与增长预期;③ 实时性要求是秒级、分钟级还是小时级;④ 合规要求是否强制数据驻留特定区域;⑤ 预算中计算与存储的占比预期。五项中若有任意一项不明确,应先做小规模 PoC 再定路线。

四、关键设计原则

无论选择哪条路线,以下原则应贯穿始终:存储与计算分离,使计算资源可独立伸缩而不影响数据持久性;分层组织数据,Bronze 保留原始、Silver 保证质量、Gold 面向消费,避免在原始层直接建模;元数据先行,每张表、每个字段都应有明确的负责人、更新频率和分类标签;成本可观测,为每个工作负载打标签,按项目或部门分摊存储与计算成本;安全默认开启,网络隔离、私有终结点、托管标识应作为默认配置而非事后补救。

蓝图的最终价值不在于画得漂亮,而在于让团队在每一个具体决策点上都有据可依:当有人问“这个数据放哪里”“用 Synapse 还是 Databricks”“什么时候上实时”,蓝图能给出清晰的判断依据。这正是本章后续各节要逐一展开的内容。