岗位能力与进阶

本页把全站知识映射到「数据湖仓一体架构师」岗位的能力模型与面试准备:先给出六层技术栈的能力矩阵与「架构师 vs 高级开发」的差异,再逐条解读一条典型 JD 的六条职责;随后补上信创国产化适配、AI+湖仓融合两个高阶命题;最后用 8 道高频面试题与 90 天学习计划完成从学习到求职的闭环。

用法建议:先用能力矩阵自查短板,再对照 JD 解读校准目标公司的侧重点,面试题用于组织自己的答案结构,90 天计划则是从零到面试Ready的执行路径。本页所有章节链接均指向本站对应页面——面试前最后一轮复习,按链接回读即可。

能力模型 JD 解读 信创适配 面试准备 先修:全站十章

能力模型

六层技术栈 × 掌握程度的能力矩阵,逐层给出关键能力点与对应学习章节。

进入学习 →

JD 解读

典型架构师 JD 的六条职责逐条拆解,每条挂到本站对应章节。

进入学习 →

高频面试题

8 道高频题的答题思路:结构化的思维框架,不是背出来的八股。

进入学习 →

90 天计划

三阶段 12 周执行表:每周一个主题、一个可运行实践项目。

进入学习 →

架构师能力模型

能力模型对齐 总体架构 的六层参考架构:底座四层(存储、计算、查询、集成)要求精通——能讲原理、能做选型、能落地规范、能救火;平台两层(调度资源、可观测)要求熟练——能用好、能定位问题,不必逐行排查内核。

技术栈层级 掌握程度 关键能力点 对应章节
存储与表格式 精通 对象存储与 Parquet 文件布局;Iceberg / Hudi / Delta 三家对比;分区与聚簇设计;快照、Schema 与分区演进;COW 与 MOR 写入路径 存储层
计算引擎 精通 Spark 批处理与 shuffle 调优;Flink 流处理、Checkpoint 与状态管理;批流一体的表级落地;作业级资源画像 计算层
查询引擎 精通 Trino 联邦与缓存机制;Doris / ClickHouse 建模、索引与物化视图;并发隔离与队列治理;查询加速三板斧 查询层
数据集成 精通 Flink CDC 链路;多源入湖规范;Schema 演进与断点续传;质量前置校验;Exactly-Once 语义 数据集成
调度与资源 熟练 DolphinScheduler / Airflow DAG 编排与补数重跑;YARN / K8s 队列配额与弹性;多租户资源隔离策略 调度资源
可观测性 熟练 小文件 / Compaction / 查询延迟指标体系;Prometheus + Grafana 大盘;告警分级与值班闭环;容量水位监控 可观测

六层之上还有三块横向放大器:数据治理(规范、质量、权限、生命周期——架构师的「立法权」)、性能调优(小文件、Compaction、查询与资源调优——架构师的「救火权」)、场景实战(本体、RAG、时序、时空、图——架构师的「变现权」)。六层决定你能不能干,三块决定你干得是否出彩。

架构师与高级开发的差异

高级开发:把功能做对。深度在「点」:吃透一两个组件的原理与实现,追求单服务性能与代码质量;成功标准是功能如期上线、SLA 达标、线上无事故;影响半径是自己所在的小团队。
架构师:把体系立起来。深度在「面」:选型、分层、规范与权衡(成本 / 风险 / 演进速度三角);成功标准是三年后这套体系还撑得住业务量级、别人照着你的规范也能做对;影响半径是整个数据团队甚至跨部门。

差异可以拆成四点:时间尺度(迭代周 vs 演进年,架构师要为三年后的成本负责);评价对象(代码 vs 决策,架构师的核心产出是决策记录 ADR 与规范);影响半径(团队 vs 组织,靠规范与评审放大杠杆);知识形态(实现细节 vs 权衡结论,后者必须能讲清「当时有什么约束、放弃了什么」)。

JD 逐条解读

下面是一条市场典型的「数据湖仓一体架构师」JD,六条职责逐条拆解。读法:每条先看考察点(面试官真正想听什么),再看对应章节(回读哪页准备答案)。

职责一:负责数据湖仓一体平台的整体架构设计与持续迭代

考察点:能不能画出六层架构图并讲清每层的职责、边界与数据流向;「持续迭代」考的是演进式架构思维——每季度评审一次技术雷达,哪些组件升级、哪些降级、哪些引入、哪些下线。

对应章节:总体架构、可观测(迭代依据来自监控指标)。

职责二:负责技术选型与数据分层、存储规范、冷热策略、版本治理

考察点:三层意思——分层(ODS / DWD / DWS / ADS 各层职责与粒度约定);存储规范(命名、分区、文件大小、表格式版本,如 format-version=2 与 target-file-size 的平台默认值);冷热策略(介质分层 + TTL + 生命周期任务);版本治理(Schema 演进流程、表属性变更评审、快照过期策略)。这条考「平台立法能力」。

对应章节:总体架构(选型方法论)、存储层(表格式与分区规范)、数据治理(版本与生命周期)。

职责三:基于 Iceberg / ClickHouse / Doris 构建统一存储底座,支撑本体建模、数据流水线、AI 检索与时空分析

考察点:三引擎的分工是否清晰(Iceberg 做事实源、ClickHouse 做时序热层、Doris 做高并发多维分析);更关键的是「支撑上层场景」——本体建模(实体/关系表设计)、数据流水线(CDC + 调度)、AI 检索(原文向量同库)、时空分析(网格分区)。这条是区分「平台运维」与「架构师」的分水岭。

对应章节:存储层、查询层、场景实战(五类场景逐一对号)。

职责四:负责性能调优——小文件治理、Compaction 调度、查询加速与资源隔离

考察点:写入端(文件大小、并行度、提交频率)、存储端(Compaction 与快照过期)、查询端(分区裁剪、缓存、物化视图)三板斧是否成体系;资源隔离(队列拆分、大作业隔离、抢占策略)能否给出量化指标(文件数阈值、队列水位)。

对应章节:性能调优、调度资源。

职责五:制定入湖规范,建设数据质量、权限、生命周期与灾备体系

考察点:治理四件套的落地——入湖规范(各模态格式/分区/质量规则,见场景实战的统一规范表);质量分层(入湖前校验、加工中断言、出库前核验);权限(Ranger 行列级 + Catalog 级联);生命周期与灾备(TTL、快照保留、RTO/RPO 与演练制度)。

对应章节:数据集成(入湖规范与质量前置)、数据治理、可观测。

职责六:支撑上层业务场景——报表、风控、AI 与检索

考察点:架构师懂不懂业务消费模式:报表要口径统一与高并发,风控要多源融合与图研判,AI 与检索要原文向量同库与权限过滤。场景决定底座形态,「只谈组件不谈场景」的候选人会被判为纸面架构师。

对应章节:场景实战、查询层。

最佳实践:回答 JD 相关问题时用统一句式——「我们当时的约束是…,我权衡了 A 和 B,选择了 A,代价是…,结果是…(量化数据)」。架构师面试拼的是决策叙事的完整性,不是名词量。

信创国产化适配

信创(信息技术应用创新)环境下,大量政企项目的数据库要求替换为国产产品。好消息是:湖仓架构师手里的底座本来就是开放的——只要在 DB 与应用之间保留一层适配抽象,PostgreSQL 系国产数据库就可以平滑换入。先认识三个主流 PG 系国产库:

产品 出品方 技术路线 架构师关注点
openGauss 华为开源 源自 PostgreSQL 内核深度增强:MOT 内存引擎、Ustore 存储引擎、AI 自调优等 金融政企落地多;内核与社区 PG 存在代际差异,扩展兼容需逐项验证
KingbaseES 人大金仓 PG 内核 + Oracle 兼容模式,面向政企迁移场景 从 Oracle 迁移项目的常客;兼容模式≠100%,SQL 改写量要提前评估
PolarDB 阿里云 云原生:计算存储分离、一写多读,提供 PG 兼容形态 适合云上湖仓的元数据与业务库;弹性与成本模型与传统部署不同

PG 在湖仓中的三类角色

  1. 元数据库:Hive Metastore 后端库、Iceberg JDBC Catalog、调度 / 质量 / 血缘组件的元存储。天然要求高可用(主备)与定期备份——它挂了整个湖仓的元数据入口就挂了。
  2. 业务库:中小型事务业务与报表出口,同时是湖仓 CDC 的源头库之一(Flink CDC 从 PG 直达 Iceberg,见 数据集成)。
  3. PostGIS 时空库:空间数据在线服务层(围栏判定、周边查询,见 场景实战 的 GIS 章节);叠加 pgvector 后还能承担 RAG 检索投影——一库三用,是中小团队成本最优雅的 PG 用法。

适配层设计

应用与 SQL 层:遵循 ANSI SQL 兼容规范,禁用数据库私有方言,从源头降低替换成本
Catalog 抽象层:逻辑名与物理实现解耦,JDBC 配置注入,业务代码零改动
数据库层:PostgreSQL → openGauss / KingbaseES / PolarDB 按需替换
# catalog 抽象(配置示意):业务与作业只引用逻辑名,底层实现通过配置注入、可整体替换
catalogs:
  lakehouse-meta:                       # 逻辑名 1:湖仓元数据库
    driver: org.postgresql.Driver       # 切换 openGauss 时改为 org.opengauss.Driver
    url: jdbc:postgresql://meta-node:5432/metastore
    validation: SELECT 1
  business-erp:                         # 逻辑名 2:业务库(CDC 源 / 报表出口)
    driver: org.postgresql.Driver       # 切换 KingbaseES 时改为 com.kingbase8.Driver
    url: jdbc:postgresql://biz-node:5432/erp
// 驱动替换:业务代码只面向 java.sql.* 标准接口与逻辑 catalog
String driver = cfg.get("catalogs.business-erp.driver");  // org.postgresql.Driver -> com.kingbase8.Driver
String url    = cfg.get("catalogs.business-erp.url");     // jdbc:postgresql://... -> jdbc:kingbase8://...
Class.forName(driver);
try (Connection conn = DriverManager.getConnection(url, user, pwd)) {
    // 业务逻辑不感知底层数据库品牌
}
-- 方言改写示例 1:upsert —— MySQL 私有语法改写为 PG 系通用写法
-- 迁移前(MySQL)
INSERT INTO biz.customer_rank(customer_id, rank_level)
VALUES (1001, 'VIP')
ON DUPLICATE KEY UPDATE rank_level = 'VIP';

-- 迁移后(PG 系通用)
INSERT INTO biz.customer_rank(customer_id, rank_level)
VALUES (1001, 'VIP')
ON CONFLICT (customer_id) DO UPDATE SET rank_level = EXCLUDED.rank_level;

-- 方言改写示例 2:标识符 —— 反引号统一为“小写 + 不加引号”,规避大小写敏感差异
SELECT `user_id`, `order_amount` FROM `biz`.`orders`;   -- 迁移前
SELECT user_id, order_amount FROM biz.orders;           -- 迁移后:写入平台 SQL 规范并纳入评审
注意:① 内核代际差异——openGauss 基于早期 PG 内核重构,社区 PG 的新语法、新函数、新扩展不可想当然可用,逐项验证再承诺;② 扩展生态——PostGIS / pgvector 在各国产库的版本支持情况不同,时空与 RAG 场景务必先行实测;③ 性能基线——信创整机(ARM/x86 + 国产 OS)上的 TPC 类压测结果与通用环境差异大,容量规划须重新测量;④ 连接与驱动——超时参数、预编译语义、连接池行为(如 prepareThreshold)迁移时逐项核对;⑤ 切换策略——灰度双写或影子库过渡,保留回滚窗口,不做一次性硬切。

AI+湖仓融合

AI 是湖仓架构的下一跳,也是架构师简历差异化的最大机会。融合底座正在沿三个方向演进:

向量原生底座

存储与查询引擎内建向量类型与 ANN 索引(pgvector 成熟、Doris 等分析引擎快速跟进):原文、向量、标量在同一引擎内完成混合检索,不再强依赖独立向量服务。

场景实战 →

统一元数据

表、指标、模型、向量索引、血缘在同一个 Catalog 登记:数据资产与 AI 资产一体治理——「这张知识表被哪个 RAG 应用消费」与「哪张表被哪个报表消费」用同一套血缘回答。

数据治理 →

语义层

指标口径统一(Headless BI / 语义建模):ChatBI 与自然语言取数建立在语义层之上,而不是让大模型直接「猜表」——AI 可信的前提是口径先可信。

查询层 →

学习路径建议

  1. 先掌握场景:把 场景实战 五类场景过一遍——先知道底座「怎么被 AI 消费」,再谈融合;
  2. 再学向量索引原理:HNSW 的图构建与搜索、IVF 系列的聚簇与重排、召回率-延迟-内存三角的量化评测方法;
  3. 动手搭 RAG over Lakehouse:pgvector 检索投影 + Iceberg 原文表 + 权限过滤 + 引用溯源,端到端跑通并建立评测集;
  4. 再看语义层与 ChatBI:把指标口径治理与 AI 消费连起来,理解「语义层是 AI 取数的防幻觉地基」。
提醒:先别急着上「AI 平台」。RAG 的下限是检索、上限是治理:分块策略、嵌入模型评测集、TopK 与重排消融这三件事做扎实,比任何平台采购都先产生价值。

高频面试题

8 道湖仓架构师岗位的高频题。每题给的是答题思路——面试官要的是结构化思维与场景绑定的结论,不是背诵的标准答案。

问题一:为什么选 Iceberg,而不是 Hudi / Delta Lake?

问题二:小文件问题如何治理?

问题三:批流一体怎么落地?

问题四:Exactly-Once 端到端如何保证?

问题五:Trino / Doris / ClickHouse 怎么选?

问题六:Compaction 调度策略怎么设计?

问题七:容量规划怎么做?

问题八:灾备方案怎么设计?

最佳实践:每道题都按「框架 → 场景绑定结论 → 量化结果 → 踩过的坑」四段展开。面试官听到结构化叙事会判定你「真做过」,听到名词堆砌会判定你「背过」。

90 天学习计划

三阶段 12 周:第 1 月夯底座(存储 + 计算),第 2 月通链路(查询 + 集成 + 调度 + 可观测),第 3 月上价值(治理 + 调优 + 场景实战)。每周主题对应本站章节,每周产出物是一个可运行、可复现的实践项目。

第 1 月 存储底座 + 计算引擎 第 2 月 查询 · 集成 · 调度 · 可观测 第 3 月 治理 · 调优 · 场景实战 每周一个可运行实践项目 · 周末复盘输出笔记与代码
阶段 周次 主题与要点 对应章节 实践项目建议
第 1 月
底座
W1 总体架构与六层参考架构,建立全局地图 总体架构 画出自家系统的六层映射图,标注每层组件与最短板
W2 对象存储与 Parquet:行组、列裁剪、压缩与编码 存储层 MinIO 搭 S3 兼容存储;对比 Parquet 行组大小对扫描量的影响
W3 Iceberg 深潜:分区/快照/回滚/MERGE INTO 与演进 存储层 建表并完整演练一次分区演进 + 快照回滚 + 过期清理
W4 计算引擎:Spark 批与 Flink 流写同一张表 计算层 Spark 批写 + Flink 流式 upsert 同一张 Iceberg 表,验证快照隔离并发
第 2 月
链路
W5 Trino 联邦查询:catalog 配置、执行计划与缓存 查询层 Trino 挂 Iceberg catalog,跑跨源 Join 并 EXPLAIN 分析裁剪效果
W6 Doris 与 ClickHouse:建模、索引与物化视图 查询层 两种引擎对同一份数据分别建模,压测并发与扫描对比
W7 数据集成:Flink CDC、Schema 演进、Exactly-Once 数据集成 PG → Iceberg 的 CDC 链路,演练断点续传与表结构变更
W8 调度与可观测:DAG 编排、队列配额、监控大盘 调度资源 · 可观测 DolphinScheduler 编排全链路 DAG + Grafana 搭平台监控大盘
第 3 月
价值
W9 数据治理:入湖规范、质量规则、权限与生命周期 数据治理 为 W7 链路补齐质量校验任务、Ranger 权限矩阵与 TTL 策略
W10 性能调优:小文件、Compaction、查询加速、资源隔离 性能调优 故意制造小文件与读放大,完整治理一遍并记录前后指标
W11 场景实战:本体 / RAG / 时序 / 时空 / 图任选其一 场景实战 推荐 RAG:pgvector + Iceberg 原文 + 权限过滤端到端跑通
W12 综合复盘:作品集整理 + 面试题闭环 岗位进阶 复盘 12 周产出物,整理作品集并写下 8 道高频题的个人答案
最佳实践:产出物导向——每周固定产出「一篇复盘笔记 + 一段可复现代码/配置」,12 周后这些就是你的面试作品集与「真做过」的证据链。宁可少读两章文档,不可缺一周产出。

至此全站闭环:总体架构 给地图,中间九章给武器,场景实战 给战场,本页给战场之外的职业路线。祝你成为真正的湖仓架构师。