Post

混合技术应用

工业级AI应用架构涵盖RAG、Agent、多模态、NL2SQL、推荐系统等链路。RAG分离线建库(文档解析→切片→Embedding→向量库)与在线问答(查询重写→多路召回→重排→组装→生成)。Agent记忆闭环融合意图路由、短期(滑动窗口+摘要)与长期(语义召回)记忆,并评估重要性写入长期库。多Agent编排通过总控路由专用子Agent,工具层区分Function Calling与MCP标准化接入。多模态摘要降维以压缩长内容节省上下文窗口。NL2SQL采用RAG检索表结构与示例,结合安全校验和自校正。高并发服务依赖异步链路、批处理、流式、缓存、监控等工程手段。推荐系统三层“召回→精排→重排”与RAG同构,GraphRAG利用知识图谱实现可解释推荐。

AI 应用实践 阅读 8 点赞 0 评论 0

场景 1 · 完整 RAG 生产链路

工业级 RAG 分生产端(离线建库)消费端(在线问答)

生产端:多模态文档加载(PDF/DOCX/图片)→ 解析清洗(MinerU 版面分析/OCR)→ 滑动窗口智能切片(500/100)→ Embedding 向量化(M3E/BGE/豆包 2048 维)→ 向量库持久化(Weaviate/FAISS)。

消费端:用户 Query → 结合历史做查询重写/关键词提取 → 多路召回(BM25 关键词 + 向量语义)Cross-Encoder 重排(BGE-Reranker) → 上下文组装(拼 System Prompt + 召回片段 + 历史)→ 大模型生成(SSE 流式)→ 后处理输出。

flowchart LR
 subgraph 生产端
 A[多模态文档] --> B[解析清洗 MinerU/OCR]
 B --> C[滑动窗口切片 500/100]
 C --> D[Embedding M3E/BGE]
 D --> E[(向量库 Weaviate/FAISS)]
 end
 subgraph 消费端
 Q[用户Query] --> QR[查询重写+关键词]
 QR --> MR[多路召回 BM25+向量]
 E --> MR
 MR --> RR[Rerank BGE-Reranker]
 RR --> CTX[上下文组装]
 CTX --> GEN[LLM生成 SSE流式]
 end

融合的单块技术:RAG + 向量库/Embedding + 大模型调用/流式 + 提示词
对应项目:企业RAG知识库


场景 2 · Agent 记忆闭环(短期+长期+路由)

一个完整的对话 Agent 是"意图路由 + 短期记忆 + 长期记忆 + 模型路由 + 落库"的闭环:
1. 用户输入 → 意图识别分类(走哪个能力)
2. 短期记忆:MySQL 拉近 5 轮 + 每 5 轮摘要
3. 长期记忆:Weaviate 按语义召回 TopK(6 类型带元数据过滤)
4. 组装上下文 → 模型路由(快/强/多模态)生成 → SSE 流式
5. 回复后重要性评估:关键事实写长期库,主题脉络沉淀摘要
6. 会话/token/trace 落库,可观测

核心矛盾:短期连贯 + 长期可检索 + 成本可控 + 可观测。短期用滑动窗口防爆炸,长期只召回强相关避免噪声,冲突偏好用时间衰减不覆盖。

融合的单块技术:Agent与记忆 + 向量库 + 大模型调用/流式
对应项目:小智平板


场景 3 · 多 Agent 编排 + 工具调用

复杂系统不是单 Agent,而是"总控路由 + 专用子 Agent + 工具链":
- 总控 Agent:意图识别,把任务路由分发给专门子 Agent(苏格拉底/写作/判题)。
- 子 Agent:各自专注领域,内部可能是 ReAct(边做边想)或 Plan-and-Execute(谋定后动)。
- 工具层:简单工具用 Function Calling(模型输出参数 JSON 本地执行),跨项目共用服务(TTS/OCR)封装成 MCP Server 解耦调用。
- 编排框架:LangGraph 搭状态机(支持循环、有状态、可回溯、人机协同)。

LangGraph 客服回复实例:用户输入 → 意图与上下文节点 → 条件路由(能否自主处理)→ 简单走工作流处理生成,复杂/敏感转人工审批 → 发送 → 日志记录。

融合的单块技术:Agent与记忆 + FunctionCalling + MCP + Dify
对应项目:小智平板 · 企业RAG


场景 4 · FC vs MCP vs RAG 技术边界(三者串讲)

这三个是构建大模型应用的核心,职责边界不同:
- Function Calling:模型的"手和脚"——理解意图后自主决定调工具、输出参数。是行为路由机制
- MCP:工具与数据无缝连接的标准通信网关——把工具封装成 Server,跨平台复用,解耦。
- RAG:解决幻觉/私有知识的架构模式——回答前"翻私有字典"检索增强,不改变模型行为。

一个查询流转例子(企业客服):用户问"我的工单进度" → RAG 先检索知识库看是否有通用答案 → 需要实时数据则 Function Calling 调工单 API(该 API 可能封装成 MCP Server)→ 拿到结果注入上下文 → 生成回复。三者协同:RAG 管静态知识,FC 管动态动作,MCP 管工具接入标准化。

融合的单块技术:FunctionCalling + MCP + RAG


场景 5 · 多模态摘要降维链路(控上下文爆炸)

处理大量图文视频时,直接喂模型会上下文爆炸。解法是"先摘要降维再生成":
1. 原始多模态(公众号图 + 学员图文视频)→ OCR/清洗/分段
2. 大文件分流:视频 >50MB 走 Files API(≤512MB,7 天),图片 >10MB 过滤
3. 调大模型生成结构化摘要 → 向量化存 Weaviate
4. 需要时向量匹配召回相关摘要(阈值 0.7 Top5)→ 融合生成最终内容
5. 失败降级:只用文本重试

本质是以空间换成本 + 信息提纯:把长内容压成高密度短文本,既不超窗口又保留核心。

融合的单块技术:大模型调用/流式 + 向量库 + 提示词
对应项目:商学咨询AI


场景 6 · NL2SQL 自助取数链路

自然语言转 SQL 是 RAG + 结构化生成 + 安全工程的组合:
1. 训练:DDL + 业务术语文档 + 问题→SQL 示例对,向量化存 ChromaDB(本质是给 SQL 生成做 RAG)
2. 业务术语映射:黑话映射到字段和口径,约束生成
3. 检索生成:召回相关表结构+示例 → LLM 生成 SQL
4. 安全校验:只读账号 + 白名单 + 拦 DML/DDL + 注入检测 + 强制 LIMIT
5. 执行自校正:报错回喂模型重写(最多 3 次)

融合的单块技术:RAG + 向量库 + 提示词 + 数据库
对应项目:NL2SQL取数助手


场景 7 · 高并发 AI 服务工程组合

高并发大模型服务是多个工程手段的叠加:
- 异步全链路:FastAPI async/await,大模型 SDK + 向量库检索非阻塞
- 批处理减压:对话累计 200 条批量异步写 MySQL(BackgroundTasks)
- 流式降延迟:SSE 流式降 TTFT
- 任务异步化:长任务丢 Celery + Redis 队列,返回 task_id
- 缓存:Redis 短期记忆/高频查询,语义缓存相似问答
- 成本控制:滑动窗口 + 长文本摘要 + 长期记忆特征化 + Prompt Caching
- 监控:Graylog 日志 + Token/成本落库 + 微服务拆分/读写分离

融合的单块技术:工程化部署 + 大模型调用/流式 + 数据库并发
对应项目:小智平板 · 商学AI


场景 8 · 数仓 ETL 全链路(大数据背景)

MySQL/Oracle → Shell ETL → XXL 调度 → ClickHouse → MySQL。数仓分层 ODS/CDM/RPT,三层校验(空值/格式/统计),ReplacingMergeTree 增量去重,报送自动压缩传输。这套数据底盘能力是做好 RAG 数据管道和 NL2SQL 的基础。

融合的单块技术:数据库并发 + 工程化部署
对应项目:EAST5数仓


场景 9 · 推荐系统三层链路(与 RAG 同构,学习推荐调研)

推荐系统的"召回 → 精排 → 重排"三层链路,和 RAG/Agent 检索链路高度同构——这是从推荐迁移到大模型应用的关键洞察:
- 召回(粗筛,求全):多路召回融合。协同过滤(UserCF/ItemCF/Swing)、双塔模型 DSSM/YouTubeDNN(user/item 塔解耦 + 内积 + ANN/HNSW 检索,就是 RAG 的向量召回)、序列召回(SASRec 单向注意力预测下一个)、知识图谱召回。
- 精排(细排,求准):特征交叉 FM/DeepFM/DCN、注意力 DIN/DIEN、多目标 ESMM(全空间解决 CVR 样本偏差)/MMOE→PLE(解决多任务负迁移)。对应 RAG 的 Rerank
- 重排(业务调整):MMR(λ 权衡相关性/多样性)、DPP(行列式度量多样性)、PRM(Transformer listwise)。对应 RAG 的多样性/去重后处理

可解释推荐用 GraphRAG 思路:LLM 从教材抽取知识点依赖 → Neo4j 知识图谱 → Cypher 查前置/进阶路径,实现"可解释"的知识点推荐。这正是当前大模型应用热点(GraphRAG),是这个项目最该主打的亮点。

数据管道:埋点 SDK → Kafka → Flink(实时)/ HDFS(离线训练),特征工程构建学习能力/难度/时段/科目偏好等用户标签。

融合的单块技术:向量库(双塔/ANN) + RAG(召回-精排-重排同构) + 向量库(GraphRAG)


继续阅读

全部归档

评论