1. Databricks机器学习平台工程化导论
在真实企业环境中,机器学习项目失败的原因往往不是算法不够先进,而是工程化能力不足:数据口径不统一、特征重复开发、训练环境不可复现、模型上线靠手工脚本、线上效果无人监控。Databricks 作为统一的数据与 AI 平台,把数据工程、特征工程、模型训练、部署与监控收敛到同一套 Lakehouse 底座上,为 MLOps 工程化提供了可落地的载体。本节作为课程开篇,先明确课程目标、平台核心组件、工程化挑战与整体建设路线图,为后续章节建立统一的概念坐标系。
一、课程目标:从“能跑通”到“可运营”
本课程的目标不是教会读者在 Notebook 里训练一个模型,而是建立一套可交付、可复用、可治理的机器学习平台工程能力。具体可拆为四个层次:
- 平台层:理解 Databricks Lakehouse、Unity Catalog、Delta Lake、MLflow、Feature Store、Model Serving 等组件在 MLOps 链路中的位置与职责边界。
- 工程层:掌握数据版本、特征复用、实验追踪、模型注册、CI/CD 与自动化部署的实现方式,让模型从实验到生产有标准路径。
- 治理层:通过 Unity Catalog 统一管理数据、特征、模型、函数的权限与血缘,满足审计与合规要求。
- 运营层:建立模型监控、数据漂移检测、性能衰减告警与回滚机制,使模型上线后可持续运营。
换句话说,课程要回答三个问题:平台有哪些能力、工程上如何组织、运营上如何闭环。
二、平台核心组件与职责分工
Databricks 机器学习平台并非单一产品,而是由多个组件协同构成。理解它们之间的数据流与调用关系,是后续工程化设计的基础。
- Delta Lake:提供 ACID 事务、时间旅行与 Schema 演进,是训练数据、特征表和推理结果的可信存储层。
- Unity Catalog:统一元数据与权限控制,管理 catalog、schema、table、volume、model、function 等对象,是治理中枢。
- Feature Store:把特征从 Notebook 代码中抽离为可注册、可复用、可在线/离线一致读取的资产。
- MLflow:负责实验追踪(Tracking)、模型注册(Model Registry)与模型打包,是实验到生产的桥梁。
- Model Serving:提供在线推理端点与批推理能力,支持自动扩缩容和版本切换。
- Workflows / Jobs:编排数据准备、特征计算、训练、评估、部署等任务,是自动化流水线的执行引擎。
这些组件不是孤立工具,而是围绕“数据—特征—模型—服务—监控”形成一条可追踪的链路。下图给出该链路的整体结构关系。
三、MLOps 工程化面临的核心挑战
把模型送上生产,工程团队通常要跨过五道坎,这些坎也正是本课程后续章节要逐一解决的问题。
- 环境与依赖不可复现:本地训练用 pandas 1.5,集群上是 2.0,特征计算逻辑随版本漂移。解决方向是用 MLflow 记录依赖与参数,用容器化或集群库管理固定运行时。
- 特征重复与口径不一致:不同团队各自写 SQL 算“近 30 天活跃度”,离线训练和在线推理结果对不上。解决方向是 Feature Store 统一注册特征,并保证离线表与在线表由同一份逻辑生成。
- 实验管理混乱:几十次调参只留在 Notebook 输出里,无法比较、无法回溯。解决方向是 MLflow Tracking 记录每次运行的参数、指标、产物,并给模型打上可检索的标签。
- 上线靠手工、回滚靠运气:模型文件拷到服务器、重启服务,出问题只能人工回退。解决方向是 Model Registry 管理版本阶段,Serving 支持版本切换,Workflows 实现自动化部署。
- 上线后无人监控:输入分布变化、预测偏差增大没有告警。解决方向是把推理日志写入 Delta 表,建立漂移与性能监控指标,并触发再训练。
常见误区:把 MLOps 等同于“写一个定时训练脚本”。真正的工程化要求数据、特征、模型、服务、监控五个环节都有版本、有权限、有血缘、有回滚路径,缺一不可。
四、整体建设路线图
结合平台能力与工程挑战,建议按“先治理、再标准化、后自动化、最终闭环”的节奏推进,避免一上来就追求全自动而基础不牢。
| 阶段 | 建设重点 | 关键交付物 | 判断达成的信号 |
|---|---|---|---|
| 阶段一:数据与治理底座 | Delta Lake 分层建表、Unity Catalog 权限与命名规范 | bronze/silver/gold 分层表、catalog-schema 命名约定 | 数据可追溯、权限可审计、表口径统一 |
| 阶段二:特征与实验标准化 | Feature Store 注册核心特征、MLflow 统一实验记录 | 特征表清单、实验命名与标签规范 | 特征可复用、实验可对比、结果可复现 |
| 阶段三:训练与部署自动化 | Workflows 编排流水线、Model Registry 管理版本、Serving 发布 | 训练 Job、注册模型、推理端点 | 一键训练、版本可切换、部署可回滚 |
| 阶段四:监控与运营闭环 | 推理日志回流、漂移与性能监控、再训练触发 | 监控指标看板、告警规则、再训练 Job | 异常可发现、衰减可告警、模型可迭代 |
需要强调的是,四个阶段并非严格串行。治理底座可以在阶段二、三中持续补强,监控指标也可以在早期就埋点采集。路线图的价值在于给出优先级:没有可信数据和统一治理,后面的自动化只会加速错误传播。
五、一个贯穿课程的示例场景
为了让后续章节有统一的讨论对象,本课程设定一个示例场景:某零售企业要构建“客户流失预警模型”。数据来自订单、访问、客服三张 Delta 表;核心特征包括近 30 天订单数、近 7 天访问频次、近 90 天投诉次数;模型用梯度提升树,输出流失概率;服务方式为在线 API,供营销系统调用;监控关注特征分布漂移与预测正例率变化。后续章节将围绕这个场景,逐步展开数据准备、特征注册、实验追踪、模型注册、部署与监控的具体实现。示例中的参数与数据均为教学假设,不代表真实业务实测结果。
学习建议:每读完一章,回到本节的组件链路图,确认新学到的能力落在“数据—特征—模型—服务—监控”的哪个环节,以及它依赖哪些治理能力。这样能把零散知识点串成一条完整的工程链路。