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

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 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,玩转SQL开发等功能!本教程介绍如何在AnalyticDB MySQL中,一键加载内置数据集,并基于自动生成的查询脚本,运行复杂查询语句,秒级生成查询结果。
阿里云云原生数据仓库AnalyticDB MySQL版 使用教程
云原生数据仓库AnalyticDB MySQL版是一种支持高并发低延时查询的新一代云原生数据仓库,高度兼容MySQL协议以及SQL:92、SQL:99、SQL:2003标准,可以对海量数据进行即时的多维分析透视和业务探索,快速构建企业云上数据仓库。 了解产品 https://www.aliyun.com/product/ApsaraDB/ads
相关文章
|
3月前
|
消息中间件 数据挖掘 Kafka
Apache Kafka流处理实战:构建实时数据分析应用
【10月更文挑战第24天】在当今这个数据爆炸的时代,能够快速准确地处理实时数据变得尤为重要。无论是金融交易监控、网络行为分析还是物联网设备的数据收集,实时数据处理技术都是不可或缺的一部分。Apache Kafka作为一款高性能的消息队列系统,不仅支持传统的消息传递模式,还提供了强大的流处理能力,能够帮助开发者构建高效、可扩展的实时数据分析应用。
117 5
|
3月前
|
消息中间件 存储 监控
构建高可用性Apache Kafka集群:从理论到实践
【10月更文挑战第24天】随着大数据时代的到来,数据传输与处理的需求日益增长。Apache Kafka作为一个高性能的消息队列服务,因其出色的吞吐量、可扩展性和容错能力而受到广泛欢迎。然而,在构建大规模生产环境下的Kafka集群时,保证其高可用性是至关重要的。本文将从个人实践经验出发,详细介绍如何构建一个高可用性的Kafka集群,包括集群规划、节点配置以及故障恢复机制等方面。
133 4
|
4月前
|
消息中间件 分布式计算 大数据
大数据-166 Apache Kylin Cube 流式构建 整体流程详细记录
大数据-166 Apache Kylin Cube 流式构建 整体流程详细记录
112 5
|
4月前
|
存储 SQL 分布式计算
大数据-162 Apache Kylin 全量增量Cube的构建 Segment 超详细记录 多图
大数据-162 Apache Kylin 全量增量Cube的构建 Segment 超详细记录 多图
82 3
|
3月前
|
存储 数据挖掘 数据处理
巴别时代使用 Apache Paimon 构建 Streaming Lakehouse 的实践
随着数据湖技术的发展,企业纷纷探索其优化潜力。本文分享了巴别时代使用 Apache Paimon 构建 Streaming Lakehouse 的实践。Paimon 支持流式和批处理,提供高性能、统一的数据访问和流批一体的优势。通过示例代码和实践经验,展示了如何高效处理实时数据,解决了数据一致性和故障恢复等挑战。
143 61
|
3月前
|
消息中间件 Java Kafka
Spring Boot 与 Apache Kafka 集成详解:构建高效消息驱动应用
Spring Boot 与 Apache Kafka 集成详解:构建高效消息驱动应用
76 1
|
3月前
|
监控 Cloud Native BI
8+ 典型分析场景,25+ 标杆案例,Apache Doris 和 SelectDB 精选案例集(2024版)电子版上线
飞轮科技正式推出 Apache Doris 和 SelectDB 精选案例集 ——《走向现代化的数据仓库(2024 版)》,汇聚了来自各行各业的成功案例与实践经验。该书以行业为划分标准,辅以使用场景标签,旨在为读者提供一个高度整合、全面涵盖、分类清晰且易于查阅的学习资源库。
|
4月前
|
Java 大数据 数据库连接
大数据-163 Apache Kylin 全量增量Cube的构建 手动触发合并 JDBC 操作 Scala
大数据-163 Apache Kylin 全量增量Cube的构建 手动触发合并 JDBC 操作 Scala
69 2
大数据-163 Apache Kylin 全量增量Cube的构建 手动触发合并 JDBC 操作 Scala
|
4月前
|
SQL 分布式计算 NoSQL
大数据-164 Apache Kylin Cube优化 案例1 定义衍生维度与对比 超详细
大数据-164 Apache Kylin Cube优化 案例1 定义衍生维度与对比 超详细
53 1
大数据-164 Apache Kylin Cube优化 案例1 定义衍生维度与对比 超详细
|
4月前
|
SQL 分布式计算 大数据
大数据-160 Apache Kylin 构建Cube 按照日期构建Cube 详细记录
大数据-160 Apache Kylin 构建Cube 按照日期构建Cube 详细记录
65 2

推荐镜像

更多