主动元数据平台详解(上):算子级血缘,创新数据管理新范式

2024-06-13 21:52

本文主要是介绍主动元数据平台详解(上):算子级血缘,创新数据管理新范式,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

01、数据血缘成为数据管理的“关键基建”

随着企业从传统的数字化管理迈向更为先进的数智化运营,数据已成为企业决策和运营的核心驱动力。在这个过程中,找数、用数已经成为企业实现精细化运营、智能化决策的重要环节。因此,实现更高效、全面、精准地管理数据,确保数据的完整性、可用性和准确性,对于推动企业数智化运营、提升整体业务效率、提升商业竞争力具有至关重要的意义。

然而,数据规模快速增长、数据资产日益增多、加工链路愈发复杂,导致企业数据管理面临前所未有的压力。这些压力包括复杂数据链路难以梳理、上下游数据变化难以高效同步、数据口径难以理解等,给企业数智化运营的推进构成了严重阻碍。

  • 数据链路的高效盘点与理解:数据链路层级不断增长,数据交叉依赖日益加深,导致数据加工链路变得如蛛网般错综复杂,使得数据盘点和加工逻辑的理解越来越难。对于用数人员而言,需要解析字段的上游加工逻辑或追溯、梳理字段来源时,不得不投入大量人力进行链路盘点。然而,这种依赖人工的盘点方式不仅效率低下,而且难以保证数据口径梳理结果准确性。特别在数仓迁移、监管指标梳理等场景中,对数据链路的精准分析并快速理解加工逻辑的需求愈发迫切,这不仅关乎数据使用的效率和准确性,更直接影响到业务决策的质量和速度。
  • 风险影响的及时全面分析:当上游数据发生变化时,必须确保这些变化能够及时、准确地同步到下游,以避免数据不一致和错误决策。这就要求开发团队具备高效的数据监控和预警机制,能够实时追踪数据变化,并自动触发相应的通知。企业对与从业务数据生产、到数据平台加工、再到业务应用的全链路影响分析也有强烈述求,上游的变化可以穿透到最下游的应用场景中,实现对重点应用的差异化保障和预警。
  • 数仓模型的长效优化机制:随着业务的不断发展和数据量的不断增长,数据链路越来越长、产出时间越来越晚,同时不断增加的冗余资产造成了资源浪费。上述问题已经成为企业数据架构治理的首要目标,而传统运动式治理普遍存在“治了又治”的情况,不仅投入大成本高、效果还难持续,亟需建立完善的数仓模型的长效优化机制。
  • 重复指标的发现和持续治理:数据口径的一致性是确保分析结果准确性的基础,但由于不同部门或团队对数据口径的理解存在差异,或者由于技术口径的不一致,导致数据分析结果难以对齐,增加了数据分析的成本和难度,影响决策的准确性。对“同名不同义、同义不同名”的重复指标能够快速甄别和持续治理,这也是对数据管理工作的巨大挑战。

目前看来,传统模式解决这些难题的专业门槛、人力投入要求很高,效果还难以保障,不持续、难复制、不经济,最终不能满足治理需求和业务需要。在此背景下,基于新一代数据血缘技术的“自治理”数据管理模式受到越来越多关注。

顾名思义,数据血缘如“家族图谱”一样,描绘了数据的起源、流经路径及其转换过程的详尽记录,可以精确追溯数据的初始来源,明晰其历经的各类处理流程,以及最终的应用方式,从而帮助企业分析并监控数据在业务链条中的上下游依赖关系,为企业提升数据管理效率和质量提供“洞察能力”

数据血缘技术发展历经“表级”、“列级”血缘,到具备精细化、自动化和智能化能力的“算子级”数据血缘,逐步实现了数据管理的“自治理”,开始成为企业数据管理的“关键基建”。

02、从表级血缘到列级血缘,再到算子级血缘

提到数据血缘技术,我们不得不谈一下其演进历程:

  • 第一代:表级血缘。过去提到血缘,很多时候讲的是“表级血缘”,即关注表与表之间的依赖关系。然而,即便实现了 100% 准确的“表级血缘”追踪,其在实际业务场景中的应用仍显局限。这是因为表与表之间的关系往往具有高度的泛化性,在下探或上溯多层后扩散出百倍甚至千倍的上下游,使用难度极大。比如,表级血缘下探 3 层后,可能会搜索出超过数千的下游表,导致用户在需要执行精细化的影响分析时,不得不深入到代码层面,逐一审查逻辑,并理解为何某张表的变化会影响另一张表,这种低效的分析方式让表级血缘聊胜于无。这也是在过去很长一段时间内,表级血缘作为资产管理平台等产品必备组件,但是存在感和应用范围极度有限的原因。
  • 第二代:列级血缘。在“表级血缘”的局限下,业务需求得不到有效满足,业界开始推动血缘精度进一步细化至字段级别,“列级血缘”技术应运而生。诸多厂商,包括开源界的 Atlas 项目等,都在尝试通过关系推断和正则匹配方式构建上下游字段之间的依赖关系。然而,由于技术解析的复杂性和局限性,绝大多数厂商对于列级血缘的解析准确率持谨慎态度,不敢轻易承诺。根据人工抽检统计,多数厂商的列级血缘准确率普遍低于 80%,这一现状使得众多企业在实际应用中对此技术持保留态度,担忧其稳定性和可靠性。所以“列级血缘”仅作为“表级血缘”的应用场景补充,无法独挡一面,用户在数据管理的“深水区”开展工作仍缺少关键支撑。

  • 第三代:算子级血缘“算子级血缘”是 Aloudata 独创的技术。借助 Aloduata 自研的多平台 SQL 方言解析器,能够深入剖析复杂的代码计算逻辑,从而准确、精细地刻画字段间的精细加工关系,并提供代码的改写能力,实现字段加工口径的提取和转换。如下图所示,“算子级血缘”可以清晰地展现数据上下游的列级加工关系和行级影响关系。例如,当上游表通过 Join 操作并应用特定的过滤条件时,会直接影响下游产出的记录行数量。通过“算子级血缘”技术,系统能够智能地分析 SQL 代码的 Where 条件,准确判断哪些下游表的行数受到了影响。整个过程如同一位经验丰富的数据专家在分析数据仓库的代码,全天候、不间断地执行这一任务,无需休息,确保数据加工关系的准确性和完整性。

03、Aloudata BIG:全球首个算子级血缘的主动元数据平台

Aloudata 凭借在数据管理和技术研发领域的深厚积累,通过独创的“算子级血缘”技术,打造了 Aloudata BIG 主动元数据平台,能够助力企业自动构建端到端、跨平台、可扩展的血缘图谱,为数据管理提供自动化、智能化的强大支持,实现数据管理模式的转变,推动数据管理走向自治化的新阶段。

作为全球首个算子级血缘的主动元数据平台,Aloudata BIG 平台具备强大的多源采集解析能力,已经成功支持了市场上主流的数据库的血缘解析,包括 Hive、Gauss、Oracle、MySQL 、PostgreSQL、Greeplum、Analytic Database 等,支持 Presto、Spark、Impala 等计算平台的血缘解析,支持 Oracle 等 PLSQL 存储过程血缘解析。未来还会支持市面上主流报表工具、调度平台或者 ETL 工具的血缘解析。

Aloudata BIG 平台支持配置式、扩展式的采集器结构,可以在算子级血缘图谱中快速接入企业自定义资产,助力企业形成数据资产“一张图”,全面整合和分析公司所有数据资产元数据。该图谱支持属性扩展,以支持各种数据推理任务,如识别管理驾驶舱中的 KPI 数据是否来源于特定数据表。通过将技术元数据、管理元数据、业务元数据与该图谱紧密绑定,Aloudata BIG 平台还能够为企业提供了从数据源到应用端的全连通能力,为数据管理场景提供端到端的自动化解决方案。

此外,Aloudata BIG 平台还具备反向元数据集成能力,提供标准化的元数据 API 和场景 API,可轻松融入企业的 DataOps 体系。通过该平台,企业能够将算子级血缘能力无缝集成到数据研发、数据资产管理和数据质量管控等平台中,为企业数据基础设施技术底座的升级提供强大支持。

04、算子级血缘图谱可视化,提升数据盘点和理解效率

通过 Aloudata BIG 平台,企业可以生成一张高精准、全链路可视化的算子级血缘图谱(如下图所示)。该图谱上游连接各种业务数据源,中间可以精准刻画数据加工链路,下游的应用系统血缘也可以通过标准化接口导入图谱,将各类自定义资产无缝连接到血缘图谱中,构建一个端到端连通、全链路覆盖的血缘图谱体系。

例如,可以通过解析BI报表的“数据源->数据集->指标->报表->看板”等元数据配置或者报表定义文件,将“报表内血缘”轻松集成到算子级血缘图谱中。凭借此图谱,企业可以全面打通数据生产、加工到消费的完整链路,实现穿透式的影响分析和精准溯源,让业务人员可以自助分析数据指标或报表的来源和加工口径,让数据集市管理人员可以主动评估数据变更和质量影响,实现上下游高效的数据协同,大幅提升数据盘点和理解效率。

在图谱可视化设计方面,我们巧妙地运用实线和虚线来区分各表中不同字段之间的血缘关系:实线血缘代表了“直接血缘”,表达了字段间的计算关系;虚线代表了“间接血缘”,用于刻画 Join 关系、Where 过滤条件和汇总维度。此外,算子级血缘解析技术还能精准裁剪和提取字段口径,以 SQL 代码形式展示,并支持字段多层链路的数据口径压缩,实现口径归一化溯源,帮助企业迅速、全面地掌握数据加工完整逻辑。

05、Aloudata BIG 核心特征:更全面、更精细、更准确

Aloudata BIG 平台在血缘解析技术上实现了“全面、精细、准确”的显著突破。

在全面性上,Aloudata BIG 平台能够自动采集并管理库、表、列、报表、模型、指标、标签、脚本等所有数据资产全生命周期的元数据,支持自定义元数据实体及关系数据的上报,可以将分散的元数据统一整合,形成相互关联的元数据图谱。通过 Aloudata BIG 平台,企业可以清晰地洞察所有数据的来龙去脉,构建出真正意义上的端到端、跨平台、可扩展且自动化的企业级主动元数据管理平台。

在精细度上,Aloudata BIG 平台的血缘解析能力达到了国际领先水平,并具备对复杂 SQL 代码的深入解析能力,即便是最复杂的数据链路,也可轻松打开链路加工“黑盒”。BIG 平台的血缘解析能力对 SQL 写法没有约束,支持几乎所有DDL、DML 语法;其次,不受任何函数限制或子查询的嵌套限制,能够穿透临时表解析出正确的数据来源;最后,BIG 的方言解析能力覆盖了市场上主流的数据仓库和计算平台产品,能够理解非常复杂的任务脚本,覆盖了超过 99% 的任务编写场景。这些能力已在招商银行、杭州银行等头部银行的生产环境和 POC 测试环境中得到了充分验证,证明其高效性和实用性。

同时,Aloudata BIG 平台还兼容多种数据逻辑的简化展示,如临时表会被隐藏在任务内血缘。通过其强大的任务解析能力,各种代码逻辑都能被准确地转化为血缘图谱并呈现出来。

为解决血缘泛化问题,Aloudata BIG 平台独创了“行级裁剪”技术。在数据加工链路中,核心公共数据模型或者主数据模型(如会员表、订单表、账户表等)通常汇聚了多个上游系统的数据,并且被多个下游表依赖使用。如果是普通的表列血缘关系,上下游会形成“多对多”的血缘映射关系。通过“行级裁剪”技术,可以精确确定下游表的实际来源,避免血缘多对多关系的干扰,可以显著提升溯源和影响分析的工作效率。在头部银行的POC中,该技术的验证结果与人工判定几乎一致,充分证明了 Aloudata BIG 平台“行级裁剪”技术的领先性和可靠性。

在准确率上,Aloudata BIG 平台能够稳定提供和保持 95% 以上的数据血缘准确率。这一卓越性能的达成,首先归功于严格的产品出厂质量门禁,即在产品出厂前,会通过多解析器进行交叉比对验证,确保“血缘解析成功即形成正确的血缘、血缘解析不成功即报错”。然后,我们会深入分析错误日志,针对无法解析或解析失败的案例进行错误分类和归因分析,不断完善和优化血缘解析器能力。经过多年技术沉淀和在头部客户真实环境的验证,Aloudata BIG 平台公开承诺:算子级血缘准确率可稳定在 95% 以上

在实际应用中,我们为招商银行、杭州银行生产环境均交付了超过 99%准确率的算子级血缘图谱。在产品交付给客户后,为长期维持血缘准确率,我们采用双重方案来推进准确率运营:

  • 从技术视角出发:Aloduata BIG 提供血缘准确率的量化评估模型,可以计算出整体血缘准确率的精确结果。针对错误,产品提供白盒化运维能力,对每日解析任务的错误日志进行错误归因,元数据管理员可以针对性推进错误数据的修正运营,确保准确率的稳定提升。
  • 从业务视角出发:赋能客户利用血缘 API开发定制化的业务校验程序,例如从末端节点溯源到 ODS 层,检查中间血缘是否存在断点,从而确保血缘准确率和用户感知的一致性。业务校验规则是 Aloudata 在多年服务头部金融企业中积累并沉淀的,是一套高效的数据血缘准确率保障和衡量机制。客户可以基于这些业务规则或自有数据规范进行创新,适配企业内部对血缘准确的业务要求。

鉴于出色的性能表现,Aloudata BIG 平台已在多个极高复杂度的数据环境中完成实地验证。

其中招商银行构建起全链路算子级血缘图谱,将算子级血缘分析技术应用到模型优化和变更协同的场景中,服务全行的数据开发人员,血源解析成功率提升至 99.9%,全链路协同保障效率提升 10 倍,平均数据链路缩短 50%。该案例已入选中国信通院 2023 大数据“星河”标杆案例和《2024 IDC PeerScape:金融领域数据管理分析服务最佳实践案例》报告。(点击此处查看案例详情)

杭州银行数据资产管理平台以 Aloudata BIG 平台的算子级血缘为底座,实现全域数据资产统一采集和连接,端到端连通从业务源端数据库到应用端报表的算子级血缘图谱,从依赖人工盘点到自动化挖掘元数据知识,丰富了数据治理手段,提升了治理方案落地效果和效率。该案例获选沙丘社区「2024 中国数据资产管理最佳实践案例」。(点击此处查看案例详情)

那么,在具体在实际应用中,该如何集成、应用 Aloudata BIG 主动元数据平台,我们下篇将给出详细回答,期待您的关注与交流。

这篇关于主动元数据平台详解(上):算子级血缘,创新数据管理新范式的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1058529

相关文章

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明(认真看哦) AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证,则会调用 #attemptAuthentica

流媒体平台/视频监控/安防视频汇聚EasyCVR播放暂停后视频画面黑屏是什么原因?

视频智能分析/视频监控/安防监控综合管理系统EasyCVR视频汇聚融合平台,是TSINGSEE青犀视频垂直深耕音视频流媒体技术、AI智能技术领域的杰出成果。该平台以其强大的视频处理、汇聚与融合能力,在构建全栈视频监控系统中展现出了独特的优势。视频监控管理系统EasyCVR平台内置了强大的视频解码、转码、压缩等技术,能够处理多种视频流格式,并以多种格式(RTMP、RTSP、HTTP-FLV、WebS

大模型研发全揭秘:客服工单数据标注的完整攻略

在人工智能(AI)领域,数据标注是模型训练过程中至关重要的一步。无论你是新手还是有经验的从业者,掌握数据标注的技术细节和常见问题的解决方案都能为你的AI项目增添不少价值。在电信运营商的客服系统中,工单数据是客户问题和解决方案的重要记录。通过对这些工单数据进行有效标注,不仅能够帮助提升客服自动化系统的智能化水平,还能优化客户服务流程,提高客户满意度。本文将详细介绍如何在电信运营商客服工单的背景下进行

基于MySQL Binlog的Elasticsearch数据同步实践

一、为什么要做 随着马蜂窝的逐渐发展,我们的业务数据越来越多,单纯使用 MySQL 已经不能满足我们的数据查询需求,例如对于商品、订单等数据的多维度检索。 使用 Elasticsearch 存储业务数据可以很好的解决我们业务中的搜索需求。而数据进行异构存储后,随之而来的就是数据同步的问题。 二、现有方法及问题 对于数据同步,我们目前的解决方案是建立数据中间表。把需要检索的业务数据,统一放到一张M

关于数据埋点,你需要了解这些基本知识

产品汪每天都在和数据打交道,你知道数据来自哪里吗? 移动app端内的用户行为数据大多来自埋点,了解一些埋点知识,能和数据分析师、技术侃大山,参与到前期的数据采集,更重要是让最终的埋点数据能为我所用,否则可怜巴巴等上几个月是常有的事。   埋点类型 根据埋点方式,可以区分为: 手动埋点半自动埋点全自动埋点 秉承“任何事物都有两面性”的道理:自动程度高的,能解决通用统计,便于统一化管理,但个性化定

使用SecondaryNameNode恢复NameNode的数据

1)需求: NameNode进程挂了并且存储的数据也丢失了,如何恢复NameNode 此种方式恢复的数据可能存在小部分数据的丢失。 2)故障模拟 (1)kill -9 NameNode进程 [lytfly@hadoop102 current]$ kill -9 19886 (2)删除NameNode存储的数据(/opt/module/hadoop-3.1.4/data/tmp/dfs/na

异构存储(冷热数据分离)

异构存储主要解决不同的数据,存储在不同类型的硬盘中,达到最佳性能的问题。 异构存储Shell操作 (1)查看当前有哪些存储策略可以用 [lytfly@hadoop102 hadoop-3.1.4]$ hdfs storagepolicies -listPolicies (2)为指定路径(数据存储目录)设置指定的存储策略 hdfs storagepolicies -setStoragePo

Hadoop集群数据均衡之磁盘间数据均衡

生产环境,由于硬盘空间不足,往往需要增加一块硬盘。刚加载的硬盘没有数据时,可以执行磁盘数据均衡命令。(Hadoop3.x新特性) plan后面带的节点的名字必须是已经存在的,并且是需要均衡的节点。 如果节点不存在,会报如下错误: 如果节点只有一个硬盘的话,不会创建均衡计划: (1)生成均衡计划 hdfs diskbalancer -plan hadoop102 (2)执行均衡计划 hd

综合安防管理平台LntonAIServer视频监控汇聚抖动检测算法优势

LntonAIServer视频质量诊断功能中的抖动检测是一个专门针对视频稳定性进行分析的功能。抖动通常是指视频帧之间的不必要运动,这种运动可能是由于摄像机的移动、传输中的错误或编解码问题导致的。抖动检测对于确保视频内容的平滑性和观看体验至关重要。 优势 1. 提高图像质量 - 清晰度提升:减少抖动,提高图像的清晰度和细节表现力,使得监控画面更加真实可信。 - 细节增强:在低光条件下,抖

OpenHarmony鸿蒙开发( Beta5.0)无感配网详解

1、简介 无感配网是指在设备联网过程中无需输入热点相关账号信息,即可快速实现设备配网,是一种兼顾高效性、可靠性和安全性的配网方式。 2、配网原理 2.1 通信原理 手机和智能设备之间的信息传递,利用特有的NAN协议实现。利用手机和智能设备之间的WiFi 感知订阅、发布能力,实现了数字管家应用和设备之间的发现。在完成设备间的认证和响应后,即可发送相关配网数据。同时还支持与常规Sof