带你读《Apache Doris 案例集》——05 当 Apache Doris 遇上大模型:探秘腾讯音乐如何 基于大模型+ OLAP 构建智能数据服务平台(2)

本文涉及的产品
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS PostgreSQL,高可用系列 2核4GB
简介: 带你读《Apache Doris 案例集》——05 当 Apache Doris 遇上大模型:探秘腾讯音乐如何 基于大模型+ OLAP 构建智能数据服务平台(2)

更多精彩内容,欢迎观看:

带你读《Apache Doris 案例集》——05 当 Apache   Doris 遇上大模型:探秘腾讯音乐如何 基于大模型+ OLAP  构建智能数据服务平台(1):https://developer.aliyun.com/article/1405740


超音数平台框架构思 

 

根据上述大模型+OLAP  的四大解决方案进行了方案整合,以此进行框架设计并将其命名为超音数平台。大模型主要作用于自然语言与SQL  分析语句的连接与转化,OLAP引擎则作为数据存储与查询分析的核心基建。

 image.png

 

超音数平台对于业务流程如图所示,模型运转具体过程如下: 

 

用户输入问题通过 Schema  Mapper检索,判定字段是否匹配与业务知识库。

 

如若匹配则跳过大模型解析步骤,直接利用知识库中的指标计算公式触发OLAP  进行查询分析;如若不匹配则进入大模型,开启下一步判定。


 大模型首先通过人工经验判定问题复杂度,简单查询将指定OLAP引擎直接分析,复杂查询则开启语义解析形成 DSL 语句。

 

DSL 语句通过语义层进步过滤、拆解关联查询场景,生成简易单表 SQL  语句以触发OLAP 数据处理与查询加速。

 

针对需要与外部信息结合的查询场景,大模型会判断是否调用第三方插件来辅助完成查询。

image.png 某首歌曲能否在综艺节目播出为例,在经过检索匹配、语义解析后,大模型选择利用OLAP 数据查询与第三方版权行业插件结合的方式进行回答,最终呈现结果由数仓中的歌曲信息与插件判定结果构成。

 

如今,业务分析师只需要在超音数平台中定义指标含义、维度类型即可直接开展自然语言的问答交互服务。同时还可以在平台中内置插件、丰富指标市场来拓展语义解析能力,完全覆盖了业务在常规与定制化场景下的查询需求。平台基于大模型+OLAP  的模式加速业务分析效率,减少技术开发成本,向智能化、个性化、实时化的全新业务服务模式更近一步。

 

 在这里希望可以与大家分享该开源项目,让更多人体验和学习大模型构建,也欢迎感兴趣的读者们共同参与大模型开发与建设。

 

超音数开源框架: https://github.com/tencentmusic/supersonic

 

超音数平台框架演进

 

在平台构建的过程中,OLAP  引擎作为整体架构的基建对 SQL  语句处理、数据存储分析、上游应用层的查询响应等有着至关重要的作用,我们希望通过架构升级以加强大模型到OLAP  引擎的转化效率与结果输出准确性。  

 

接下来我们将对比介绍OLAP  早期架构与新一代架构在数据写入与查询两方面的差异,分享在架构演进过程中大模型+OLAP  模型优化历程,最终助力超音数平台的构建,开启新一代的数据服务模式。


 数据架构1.0

 image.png 


我们初期的业务架构如上图所示,分为处理层、分析层、应用层三部份,用户文本在进入大模型

之后解析为 SQL 语句使OLAP 开始执行任务,具体的工作原理如下: 

 

处理层:在ODS-DWD-DWS       三层中将数据整合为不同主题的标签和指标体系之后,通过DWS 调度与采集所需字段,在DWM   层将维度与指标数据加工成大宽表。

 

分析层:通过大宽表进入分析层,将数据导入Clickhouse Elasticsearch,其中Clickhosue    主要负责维度与指标两类数据的查询加速,作为分析引擎为后续提供报表开发服务; Elasticsearch     主要负责维度数据处理,作为搜索/圈选引擎。 

 

应用层:业务人员基于场景选取所需要的标签与指标,在应用层中创建数据集作为逻辑视图,同时可以二次定义衍生的标签与指标。

 

在实际业务使用中,早期架构的数据处理方式存在大宽表带来的数据延迟与存储浪费、多套组件导致架构冗余带来指标维度重复定义、学习与运维成本高等问题,具体如下: 

 

数据延迟:处理层不支持部分列表更新,DWS  层数据写入产生延迟后会造成大宽表的延迟,进而导致数据时效性下降。

 

  运维成本高: 在处理层大宽表中维度数据量平均占一张大宽表的50%,且在大部份情况下变化缓慢,这意味着每一张宽表的开发会将维度数据叠加,造成存储资源浪费、维护成本增加在分析层中存在多引擎使用问题,查询SQL 语句需要同时适配 Clickhouse Elasticsearch两个组件,增加人力成本,且两套组件也会加大运维难度,运维成本进一步升高。 

 

架构冗余:在应用层进行指标与维度定义时,导致相同数据会进行多次定义使各种指标、维度定义口径不一致,造成权限不可控,例如上图所示的T1  (标签)M1  (维度)在应用层中,被不同数据集多次定义。

 

数据架构2.0 

 

基于以上问题,我们开始对架构进行改造升级,并在众多 OLAP  引擎中选择了Apache  Doris

替换原有组件,主要因为Apache Doris 具备以下核心优势

 

实时导入:  Apache  Doris 能够支持海量业务数据的高吞吐实时写入,时效性可以做到秒级

完成导入。

 

引擎统一:支持 Multi-Catalog 功能,能够通过 Elasticsearch Catalog 外表查询,实现查询出口统一,查询层架构实现链路极简,维护成本也大幅降低。 

 

查询分析性能:Apache Doris MPP  架构,支持大表分布式 Join, 其倒排索引、物化视图、行列混存等功能使查询分析性能更加高效极速。 image.png 

在数据架构2.0版本中,数据架构保留处理层部份,主要升级分析层架构,并进行语义层叠加: 


分析层:引入Apache  Doris  替换 Clickhouse  组件,利用 Doris  Elasticsearch    Catalog

功能对 Elasticsearch    外表进行查询,实现查询出口统一; 

 

语义层:应用层不再需要创建数据集视图,直接通过语义层获取指标与标签内容执行查询任务,有效解决标签与指标口径问题。

 

数据架构3.0

 

由于宽表开发过程中,维度数据一般变化较小、字符存储空间较大,且分析查询一般只需要查询最新的维度数据。在这种情况下,如果不断叠加维度数据制作宽表,会造成存储空间浪费的问题,同时查询响应速度也受到影响。

 image.png

 

 为了进一步提升架构性能,数据架构3.0主要将处理层中大宽表进行拆分,同时将分析层统一使

Apache  Doris 作为查询分析引擎:

 

 处理层:按照业务分类在 DWM  中将大宽表拆分成缓慢维度表与指标表,使两类表在本地

Hive  中进行关联,通过Hive  导入Apache    Doris 分析层中加速任务;

 

 分析层:将关联数据表直接导入 Apache Doris 中,结合语义层暴露指标与维度以实现语义

统一,用户只需要通过过滤条件就能够直接查询数据,得到所需要的结果。

 

数据架构4.0 

 image.png

 

 我们延续了3.0架构中分析层统一的优势,对处理层、分析层、语义层架构进一步优化,使查询

性能显著提升:

 

分析层+处理层:数仓 DWD 层数据采用 Rollup 功能使事实表与维度表实时关联并创建多个视图进入 DWS 中。通过这种方式,分析层与处理层中的各类指标数据无需再重复定义,能够基于Apache Doris 全部写入新建的 Rollup 视图中并利用 GROUP   BY 将维度传入视图进行查询加速,直接对外暴露所需数据。

 

语义层:利用 Apache  Doris 物化视图对指标与维度自定义口径,通过语义物化层进行查询加速,并将指标与维度通过SUM  加工开发衍生标签与维度数据。

 

应用层:利用Apache  Doris  2.0 版本的倒排索引功能,对现有的索引结构进行丰富,满足了对知识库进行模糊查询、等值查询和范围查询等场景中的能力,进一步加速指标、维度查询响应速度。 

 

数仓架构基于Apache Doris迭代升级,最终实现导入实时、引擎统一、查询高效的现代化湖仓 OLAP  引擎,简化架构链路的同时,有效解决大宽表中指标重复定义所带来的问题。在架构演进的过程,我们也积累许多关于Apache Doris 性能优化经验,希望分享给读者们带来一些参考。


更多精彩内容,欢迎观看:

带你读《Apache Doris 案例集》——05 当 Apache   Doris 遇上大模型:探秘腾讯音乐如何 基于大模型+ OLAP  构建智能数据服务平台(3):https://developer.aliyun.com/article/1405738

相关实践学习
阿里云云原生数据仓库AnalyticDB MySQL版 使用教程
云原生数据仓库AnalyticDB MySQL版是一种支持高并发低延时查询的新一代云原生数据仓库,高度兼容MySQL协议以及SQL:92、SQL:99、SQL:2003标准,可以对海量数据进行即时的多维分析透视和业务探索,快速构建企业云上数据仓库。 了解产品 https://www.aliyun.com/product/ApsaraDB/ads
相关文章
|
2月前
|
人工智能 缓存 监控
使用LangChain4j构建Java AI智能体:让大模型学会使用工具
AI智能体是大模型技术的重要演进方向,它使模型能够主动使用工具、与环境交互,以完成复杂任务。本文详细介绍如何在Java应用中,借助LangChain4j框架构建一个具备工具使用能力的AI智能体。我们将创建一个能够进行数学计算和实时信息查询的智能体,涵盖工具定义、智能体组装、记忆管理以及Spring Boot集成等关键步骤,并展示如何通过简单的对话界面与智能体交互。
876 1
|
2月前
|
机器学习/深度学习 人工智能 计算机视觉
让AI真正"看懂"世界:多模态表征空间构建秘籍
本文深入解析多模态学习的两大核心难题:多模态对齐与多模态融合,探讨如何让AI理解并关联图像、文字、声音等异构数据,实现类似人类的综合认知能力。
423 6
|
1月前
|
人工智能 API 开发工具
构建AI智能体:一、初识AI大模型与API调用
本文介绍大模型基础知识及API调用方法,涵盖阿里云百炼平台密钥申请、DashScope SDK使用、Python调用示例(如文本情感分析、图像文字识别),助力开发者快速上手大模型应用开发。
909 16
构建AI智能体:一、初识AI大模型与API调用
|
1月前
|
人工智能 缓存 自然语言处理
Java与多模态AI:构建支持文本、图像和音频的智能应用
随着大模型从单一文本处理向多模态能力演进,现代AI应用需要同时处理文本、图像、音频等多种信息形式。本文深入探讨如何在Java生态中构建支持多模态AI能力的智能应用。我们将完整展示集成视觉模型、语音模型和语言模型的实践方案,涵盖从文件预处理、多模态推理到结果融合的全流程,为Java开发者打开通往下一代多模态AI应用的大门。
305 41
|
2月前
|
存储 人工智能 数据可视化
从零构建能自我优化的AI Agent:Reflection和Reflexion机制对比详解与实现
AI能否从错误中学习?Reflection与Reflexion Agent通过生成-反思-改进循环,实现自我优化。前者侧重内容精炼,后者结合外部研究提升准确性,二者分别适用于创意优化与知识密集型任务。
460 9
从零构建能自我优化的AI Agent:Reflection和Reflexion机制对比详解与实现
|
1月前
|
缓存 物联网 PyTorch
使用TensorRT LLM构建和运行Qwen模型
本文档介绍如何在单GPU和单节点多GPU上使用TensorRT LLM构建和运行Qwen模型,涵盖模型转换、引擎构建、量化推理及LoRA微调等操作,并提供详细的代码示例与支持矩阵。
364 2
|
2月前
|
存储 自然语言处理 分布式计算
Apache Doris 3.1 正式发布:半结构化分析全面升级,湖仓一体能力再跃新高
Apache Doris 3.1 正式发布!全面升级半结构化分析,支持 VARIANT 稀疏列与模板化 Schema,提升湖仓一体能力,增强 Iceberg/Paimon 集成,优化存储引擎与查询性能,助力高效数据分析。
463 4
Apache Doris 3.1 正式发布:半结构化分析全面升级,湖仓一体能力再跃新高
|
2月前
|
人工智能 Java API
Java与大模型集成实战:构建智能Java应用的新范式
随着大型语言模型(LLM)的API化,将其强大的自然语言处理能力集成到现有Java应用中已成为提升应用智能水平的关键路径。本文旨在为Java开发者提供一份实用的集成指南。我们将深入探讨如何使用Spring Boot 3框架,通过HTTP客户端与OpenAI GPT(或兼容API)进行高效、安全的交互。内容涵盖项目依赖配置、异步非阻塞的API调用、请求与响应的结构化处理、异常管理以及一些面向生产环境的最佳实践,并附带完整的代码示例,助您快速将AI能力融入Java生态。
438 12

推荐镜像

更多