☰
一文看懂智驾数据闭环湖仓架构整体设计
2026/10/5 6:54:20 网站建设 项目流程

先说一个反常识的判断:智能驾驶的竞争,早已不是谁跑的里程多,而是谁的数据闭环转得快。一支量产车队每天回传的数据以 TB 计,一年攒下来就是 PB 级——但行业里真正被用于训练、验证和模型迭代的数据,普遍不到 5%。剩下 95% 不是没价值,而是「没有被工程体系接住」:找不到、看不懂、不敢用。

接住这 95%,靠的不是某一个大模型,而是两套彼此咬合的架构:一套是承载全量数据的湖仓底座,一套是从数据里淘金的数据挖掘平台。过去 23 篇文章,我们把这两套架构的每个零件拆开讲了一遍;这一篇,把它们装回去——用一篇文章讲完整体设计:数据从车端出发,如何一路变成训练集、变成模型、再通过 OTA 回到车上,完成一圈闭环。

全文较长,建议先收藏再读。文末有全部系列的导航地图,以及获取完整设计文档的方式。

📖 全文导读 · 九章结构

一、总蓝图:两套架构,一个闭环

二、湖仓底座:四层骨架与 11 个数据域

三、数据进出湖:三通道入湖与双路查询

四、数据挖掘平台:控制面与数据面分离

五、AI 挖掘流水线:从抽帧到文搜图

六、两套架构如何咬合:闭环发动机

七、十条设计哲学

八、行业坐标系

九、系列导航与下一步

一、总蓝图:两套架构,一个闭环

整个方案的素材来自两份设计文档:《智驾数据闭环湖仓架构设计文档》约 1,600 行,回答「数据放在哪、怎么管」;《数据挖掘与多模态检索平台架构设计》约 1,100 行,回答「数据怎么用、怎么变聪明」。两份文档加起来覆盖 8 大业务环节、11 个数据域、90 余张表、16 个平台章节——它们不是两个孤立系统,而是一个闭环的两半。

先看骨架。智驾数据闭环共8 大环节:采集 → 回传 → 标注 → 挖掘 → 训练 → 仿真 → 部署 → OTA,再回到采集。湖仓底座横贯全部 8 个环节,是每个环节的数据中枢;挖掘平台则深耕其中「挖掘」一环,并向上游反哺采集、向下游供给训练。下面这张动图,就是整个体系的心跳:

▲ 智驾数据闭环 8 环节:每转一圈,就是一次模型进化

两套架构的分工,可以用一句话概括:湖仓是骨架,让数据可存、可查、可治理;挖掘是大脑,让数据可发现、可检索、可回补。后面八章,就是沿着数据流动的方向,把这两半逐层拆开、再装回去。

二、湖仓底座:四层骨架与 11 个数据域

▲ ODS → DWD → DWS → ADS 四层骨架,11 个数据域沿闭环环节铺开

湖仓底座以Apache Paimon为存储与建模内核,采用经典四层架构:ODS 贴源层原样承接车端与各业务系统数据;DWD 明细层做清洗、拉平与标准化,是全湖体量最大的一层;DWS 汇总层按主题聚合出日粒度指标;ADS 应用层直面业务,11 张数据产品表开箱即用——从闭环大盘、产线瓶颈到存储成本看板,管理者要的答案都在这里。

四层之上,按业务切分出11 个数据域:10 个业务过程域与闭环 8 环节一一对应(含采集、标注、挖掘、训练等),外加 1 个跨域闭环域专管全链路追溯与效率度量。域间关系一句话:一环主环、一反馈环、一跨域支撑——10 个业务域沿主环单向流转,挖掘域双路回补数据资产域与采集域,闭环域贯穿全程做度量。全湖共90 余张表,统一遵循四段式命名公式(层级_数据域_业务主题_粒度),分区与 Bucket 策略逐表定制。

把散落的数据串成一条链的,是贯穿 7 个环节的三级 ID 体系:data_id(采集单元,一个 clip)、clip_id(标注/挖掘片段)、image_id(单帧,且内嵌 data_id 免查表回溯)。任何一个训练样本,都能凭 ID 一路回溯到车端原始数据——这是后面血缘追溯、Badcase 复盘的地基。

三、数据进出湖:三通道入湖与双路查询

骨架立起来之后,数据怎么进来、怎么出去,是湖仓的两道大门。

▲ 三道入湖通道各管一类数据,双路查询出口各管一类场景

入口是三通道:①Flink CDC 通道实时同步业务库变更,断点续传 + Exactly-Once,平台配置秒级入湖;②Kafka 通道消费车端回传的元信息与事件流;③OSS 通道承接采集大文件(视频/点云),走「车端脱敏 → 合规室上传 → 合规云脱密 → 智驾云入湖」的五步合规链路。所有数据进门前都要过一道五步质量门禁:完整性 → 格式 → 业务规则 → 异常告警 → 隔离重放,坏数据进不了主环。

出口是双路查询:①External Catalog 外部表即席查——StarRocks 直查 Paimon,湖数据零搬迁;②ADS 内表物化毫秒直查——高频场景由 StarRocks 离线物化为内表,双路互为降级。治理上则配齐三件套:血缘追溯(Paimon + Neo4j 湖图双引擎,表级到字段级)、质量门禁、生命周期管理(五级存储分层,预热/降冷/淘汰,让成本增速远低于数据量增速)。

四、数据挖掘平台:控制面与数据面分离

镜头转向第二份文档。数据挖掘平台要解决的矛盾很尖锐:挖掘是重计算的,但平台绝不能成为第二份数据副本——一旦平台自持主数据,两套数据迟早走向不一致,闭环就断了。于是整个平台最重要的一条架构决策是:控制面与数据面分离。

▲ 平台只存任务与配置,主数据全部沉淀湖仓

具体切法:运行态(任务、配置、调度状态)留在平台侧 MySQL,轻量、高频、随改随用;所有主数据(抽帧明细、标签、向量、挖掘结果)全量沉淀湖仓,MySQL 里的配置也通过 Flink CDC 实时同步入湖。平台拆分为 11 个组件服务、K8s 三区部署,GPU 资源分时复用:白天跑 VLM 推理,凌晨 6 点前跑 Embedding 向量化——一份算力,两种产出。

这条决策还带来一个副产品:挖掘域顺带为湖仓贡献了9 张新表(1 ODS + 6 DWD + 1 DWS + 1 ADS),从规则配置到标签覆盖度指标全部登记在册。平台与湖仓不是「对接」关系,而是长在一起。

五、AI 挖掘流水线:从抽帧到文搜图

挖掘平台内部,是一条五站流水线。TB 级采集数据进来,可检索的场景资产出去:

▲ 抽帧 → 统一标签 → 双引擎挖掘 → 向量化 → 多模态检索

第一站,分层抽帧。不是所有帧都值得看:均匀抽帧保底、事件触发抓关键时刻(前后各 10 秒窗口)、场景感知按质量分挑帧,三级闸门把 TB 级数据压缩成高价值帧集合。

第二站,统一标签。采集、规则、VLM 三个来源的标签统一收口:字典映射到五大类别受控词表、幂等去重、血缘填充,四态状态机(candidate/active/deprecated/merged)管住词表不爆炸。

第三站,双引擎挖掘。规则引擎走「规则即数据」——SQL + 可视化双模表达,批流双模执行(T+1 Spark 批跑亿级 4 小时内 + Flink 准实时),擅长结构化条件;VLM 推理引擎让多模态大模型看图说话,输出结构化标签 + caption 双结果,专补规则够不着的长尾语义场景。两者互为补充,共同构成「规则粗筛 → 模型细筛 → 检索扩散」的三级漏斗。

第四站,向量化。CLIP 双塔模型每日凌晨批量生产 Embedding,标签变了图片不变就不重算,向量带版本灰度切换。

第五站,多模态检索。一句「雨天夜间行人横穿」,五步之内(查询向量化 → 标量过滤 → ANN 检索 → 重排 → 结果组装)返回相似场景,P95 ≤ 2 秒。

六、两套架构如何咬合:闭环的发动机

单看两半都清楚,真正的功夫在咬合处。这套体系的咬合点有四个,缺一个闭环就转不起来:

▲ 单一事实源、ID 贯穿、结果回写、覆盖度反哺——四个咬合点

咬合点一:单一事实源。平台不持有任何主数据副本,湖仓(DLF + Paimon)是唯一的权威存储,StarRocks 只做加速——所有消费方读到的永远是同一份数据。

咬合点二:ID 贯穿。挖掘产出的每一行明细都携带 data_id / clip_id / image_id,与采集、标注、训练各域天然对齐,跨域 JOIN 不靠猜。

咬合点三:结果回写。挖掘命中的场景双写回统一标签服务与湖仓结果表,同时异步触发事件补抽帧——挖出一个 Badcase,自动召回它的完整上下文。

咬合点四:覆盖度反哺。标签覆盖度日指标(dws_mining_tag_coverage_daily)暴露「哪类场景还没挖到」,直接反哺采集策略,指挥车队去该去的地方。数据从被动产物变成主动指令,闭环才算真正闭上。

七、十条设计哲学:架构背后的为什么

技术选型会过时,设计原则不会。把两份文档里的关键决策抽出来,浓缩成十条,是这个体系真正的「干货」:

#

原则

一句话解释

1

湖仓单一事实源

主数据只在湖仓,平台只存运行态,杜绝双副本漂移

2

两流合一

数据流与服务流同图设计,每个环节既有数据落点又有服务支撑

3

ID 贯穿全链路

三级 ID 打通采集到训练 7 环节,任何样本可回溯原始数据

4

规则即数据

挖掘规则配置化入湖,可版本化、可审计、可批量执行

5

未审核不进训练集

标签候选池四态治理,质量门禁是训练数据的唯一闸门

6

三级漏斗挖掘

规则粗筛 → 模型细筛 → 检索扩散,算力花在刀刃上

7

双路查询出口

外部表即席查 + 内表毫秒直查,互为降级,永不断路

8

血缘先行

每张表落地的同时登记血缘,湖图双引擎支撑字段级追溯

9

成本生命周期化

五级存储分层 + 自动预热降冷,PB 级数据成本可控收敛

10

度量反哺采集

闭环效率与标签覆盖度指标直接驱动采集策略,闭环自加速

八、行业坐标系:头部厂商在做什么

这套设计不是闭门造车。

🚘 特斯拉的 Data Engine 用触发器 + 影子模式实现百万车队全自动回传,其「自动标注 + 挖掘驱动训练」与本方案的三级漏斗同源;

🌀 Momenta 的数据飞轮强调量产数据反哺算法迭代速度;

🧪 Waymo 以每周数千万英里的仿真验证构筑安全门禁;

🚙 蔚来的群体智能与 🚗 小鹏的众包采集,则展示了量产车队作为采集网络的两条路径。

共同点只有一个:没有一家把宝押在「多跑车」上,全押在「闭环转速」上。下一站,我们就会逐环节拆解特斯拉的完整引擎。

九、系列导航与下一步

本文收拢了三个系列共 23 篇的精华。想深挖某个模块,按图索骥:

系列

篇数

核心内容

系列一 · 智驾数据闭环

7 篇

8 环节全景、行业对标、四层架构、三级 ID、ADS 数据产品、闭环度量、存储治理

系列二 · 湖仓实战

8 篇

Paimon 分层建模、表命名规范、双路查询、Flink CDC 入湖、血缘追溯、质量门禁、向量索引、合规入湖

系列三 · 智驾数据挖掘

7 篇

平台架构、分层抽帧、统一标签、规则挖掘、VLM 推理、向量化流水线、多模态检索

📌 本文要点

① 湖仓是骨架、挖掘是大脑,两套架构靠单一事实源、ID 贯穿、结果回写、覆盖度反哺四个咬合点连成闭环发动机;

② 数据进门三通道、出门双路查询,治理三件套保质量保成本;

③ 挖掘五级流水线(抽帧→标签→双引擎→向量化→检索)把 TB 级数据炼成可检索的场景资产;

④ 十条设计哲学是比选型更长久的资产。

📌 下一篇预告

全景收拢完毕,下一站进入「行业对标」系列——S4-01《特斯拉 Data Engine 深度拆解:触发器、影子模式与数据飞轮》。百万级车队的数据引擎是怎么全自动运转的?我们逐环节对标本方案,看看「别人家的闭环」到底强在哪。

需要专业的网站建设服务?

联系我们获取免费的网站建设咨询和方案报价,让我们帮助您实现业务目标

立即咨询