从数据到洞察:DataOps加速AI模型开发的秘密实践大公开!

作者 | 代立冬,白鲸开源科技联合创始人&CTO

引言

在AI驱动的商业世界中,DataOps作为连接数据与洞察的桥梁,正迅速成为企业数据战略的核心。

在WOT全球技术创新大会2024·北京站白鲸开源联合创始人&CTO 代立冬 在「大数据技术与基础设施」专场深入分析DataOps的核心理念、AI大模型开发流程,并通过白鲸开源科技的实践案例,展望了DataOps的未来。

DataOps核心理念

DataOps是一种新兴的数据管理和开发方法论,旨在通过自动化和协作,提高数据管道的效率和质量。

DataOps 在大模型开发中的作用

大模型训练关键要素:

  • 数据集:大量、多样化、高质量的数据是训练和微调大模型的基础
  • 模型架构:包括网络层数、隐藏层的大小、参数的类型等
  • 算力:大模型训练需要极其强大计算资源,包括高性能的GPU,如 A100 等

DataOps与AI模型开发的融合,将加速AI模型的开发周期,提升模型的准确性和效率。

大模型训练流程

大模型训练是一个多阶段过程,涉及数据工程、算法工程和运维。

数据工程阶段包括:

  • 数据源:确定数据起点,包括云、SaaS、本地等混合数据源。
  • 数据准备与数据流管理:涉及数据抽取、转换、加载(ETL)和数据质量管理。
  • 大模型训练:利用高质量数据训练模型,包括模型评估与测试。
  • 数据质量管理:包括数据版本管理、数据质量管控、数据影响分析

算法工程阶段包括大模型训练、模型评估预测试,其中,经过预训练、指令微调、增强学习的步骤,并完成性能评估、模型验证和模型优化,训练编排的pipeline才算完成,最终将训练完成的模型应用于实际业务场景。

企业面临的数据挑战

企业在新技术环境下,面临数据源多样化、数据处理流程复杂化等挑战,具体包括:

  • 企业内拥有多组 “数据平台”,数据资源和流程分散在各部门,难以掌控;
  • 企业大数据开发处于“野蛮生长状态”,整体研发管理距离应用开发DevOps流程相差甚远;
  • 大数据、流数据、AI数据加工缺乏工具管控形成了企业新的“蜘蛛网”;
  • 多种新兴数据引擎、云原生、新数据架构的变化缺乏管控,数据血缘、同步、调度与数据发展严重落后。

新技术环境下EtLT架构出现

云、SaaS、本地混合数据源让传统的数据处理流程从ETL、ELT变为能更加快速满足业务需求的EtLT架构,EtLT能更加敏捷地应对离线/实时数据湖、数据仓库、AI模型训练当中的复杂多变的数据需求场景,从而解决以上企业面临的诸多数据挑战。

白鲸开源是一家开源原生的DataOps商业公司,由多个Apache Member成立,80%员工都是Apache Committer,主导2个 Apache顶级开源项目(Apache DolphinScheduler, Apache SeaTunnel),同时根据全球最佳实践发布商业版本 --WhaleStudio,帮助企业在大数据和AI时代智能化地完成多数据源、多云及信创环境的数据集成,数据开发、工作流编排运维及部署、数据质量管控、团队敏捷协作等一系列问题,已在 6000多家企业中得到实践和使用。

DataOps关键实践之任务调度平台

  • Apache DolphinScheduler:云原生调度引擎

作为云原生的调度引擎,DolphinScheduler支持大数据工作流,解决企业级场景中的多个任务单元、高执行频率、数据量大等痛点。

DataOps关键实践之数据集成工具

  • Apache SeaTunnel:新一代实时多源数据同步工具

在数据集成领域,企业面临的技术和业务挑战同样严峻:

  • 数据源多达几百种,版本间不兼容,而且不断有新的出现;
  • 数据丢失与重复,无法一致性
  • 出现问题无法回滚或者断点继续执行
  • 同步过程不透明,缺少监控
  • 频繁读取 binlog 对数据源端影响大
  • 大事务、Schema 变更影响下游
  • 低吞吐高时延导致数据无法及时到达
  • 离线同步和实时同步常被分开管理,维护困难
  • 数据割接人工进行

Apache SeaTunnel是新一代实时多源数据同步工具,支持130+种数据源,提供批量和实时数据集成。可以有效地解决以上企业面临的困境。

  • Apache SeaTunnel特点

同时,为了实现更高效的数据集成,Apache SeaTunnel社区还“重复造轮子”,自研了专门为数据引擎而设计的SeaTunnel Zeta Engine。

与Spark、Flink等流行引擎相比,Apache SeaTunnel在数据同步上的优势显而易见:

  • 典型案例

同样地,Apache SeaTunnel以其强大的数据同步和集成性能在数千家企业的大数据处理中作为重要的一环,发挥着不可替代的作用。典型的用户包括美国醉的商业银行摩根大通银行和哔哩哔哩,两者分别利用Apache SeaTunnel高效解决了跨云数据准备和异构数据实时数据同步的巨大挑战。

白鲸开源DataOps实践

白鲸开源科技是DataOps领域的领先实践者,提供开源解决方案和商业产品,为企业数据打造全流程DataOps闭环。

稳定高效的企业级dDataOps平台——WhaleStudio

WhaleStudio基于Apache DolphinScheduler和Apache SeaTunnel,是一个分布式、云原生并带有强大可视化界面的 DataOps系统,增加了商业客户所需的企业级特性:

  • 完全自主研发,上下游生态圈广阔,支持 160+ 种数据源
  • 全面支持云原生—云、仓、湖 实时/离线批流一体化任务管控
  • 低代码实现企业大数据的操作系统和高速公路
  • 完善的DataOps流程可无缝集成代码工具
  • 丰富的数据源对接和传统ETL数据组件支持
  • 一站式完成从开发-》测试-》上线-》的运维闭环


WhaleStudio技术架构

工作流编排能力

WhaleStudio具有强大的工作流编排能力:

  1. 支持各类计算任务组件:Amazon DMS、Azure Datafactory,Amazon Datasync、Apache Linkis,DataX,Sqoop,SeaTunnel等
  2. 支持各类云数据库和计算架构,支持 K8S、MLDB。
  3. 平台采用插件式设计,支持自由扩展数据源支持。
  4. 可视化的数据源管理,数据源统一集中管理,一次配置,到处使用,大大减少配置修改带来的工作量。
  • 支持160种数据源接口,多种数据集成方式

支持160+种数据源

WhaleTunnel支持160+种数据源,例如MySQL,SAP Hana,Oracle,DB2,SQLServer,Gbase,Kafka,ClickHouse,RedShift、达梦等。平台采用插件式设计,支持自由扩展数据源。

  • 支持多种数据同步方式:

    • 批量数据全量、增量集成
    • 实时数据集成
    • 批量无主键增量集成等
  • 支持商业数据库实时CDC

  • Mysql
  • PostGreSQL
  • SQLServer
  • Oracle
  • DB2
  • AWS Aurora
  • 翰高
  • StarRocks
  • 达梦
  • 人大金仓
  • PolarDB

实时数据同步支持DDL变更触发暂停、报警以及延迟告警

实时数据处理支持多种实时数据监测处理:

  • DDL变更暂停
  • DDL变更告警
  • DDL暂停加表
  • DDL手工处理

支持多种方式控制&监测速率:

  • 数据采集速率控制
  • 并发控制
  • 数据延迟告警
  • 数据全量完成告警
  • 数据CDC增量启动告警

数据开发能力-在线IDE&集成,实现DataOps

数据质量把控–数据工作流血缘关系

  • 全局跨工作流的任务和及实例间的依赖关系
  • 结合任务与表定义,实现表及血缘分析以及任务操作
  • 支持实例级别的依赖链路展示
  • 支持全局视图进行停止、暂停、重跑、依赖链重跑等操作

智能基线–提前预知任务延迟从而提前采取行动

配置智能基线帮助“智能”告警:
✅定义核心任务基线,多一双“智能”的眼镜
✅根据任务的执行历史只能推算时长
✅设置安全预警时间,智能告警

多种运维管理手段帮助运维人员快速处理故障

任务上线之后,面对各种突发情况,有多种手段来确保在任务发生异常时可以协助运维人员快速处理异常。


实践案例分析

中信建投DataOps布局

在经过对比调研后,中信建投采用了WhaleStudio平台来解决当时在谁开发中存在的挑战。

通过WhaleStudio平台,中信建投实现了数据一体化编辑、上线和管控,极大提升了数据研发效率。



  • 工作流编排:定义超过3000个工作流,上线任务数量接近16000个。
  • 核心应用:应用于反洗钱、实时盈亏计算、监管报送、数据精算等核心业务。
  • 效率提升:日均运行工作流实例超过5000个,日均任务执行数量超过20000个。

目前公司各业务线数据处理任务还在持续上线DataOps平台,整个平台规模还在持续增长中。

DataOps未来

DataOps的未来将由AI技术进一步推动,实现更智能化的数据处理、数据安全保护和跨平台/云数据治理。

大模型在数据处理流程中可以扮演多种角色,提高整个数据处理流程的效率和智能化水平。大模型将应用于以下方面:

智能调度策略

数据处理涉及复杂的任务调度,大模型可以分析历史作业执行情况、资源使用状况,从而预测未来的工作流需求,智能地调度任务和分配资源。减少延迟,提高整体处理速度,并优化资源利用率。

数据质量检测与清洗

在数据同步过程中,大模型可以辅助自动检测数据质量问题,比如识别异常值、缺失数据或不一致性。通过机器学习算法,模型可以学习数据特征,自动清洗和修正数据,确保数据同步后的质量。

智能数据分类与标签

对于需要分类或标签化的数据,大模型可以自动分析数据内容,对其进行分类或附加有意义的标签,特别是在多模态数据处理场景下,这对于后续的数据分析和应用至关重要。

自适应数据同步策略

根据网络状况、数据变化频率和业务需求,大模型可以帮助动态调整数据同步策略,比如选择最合适的同步频率、确定优先级高的数据流,以优化同步效率和减少带宽消耗。

自动化异常处理

在数据传输或处理过程中遇到异常时,大模型可以基于历史数据和模式识别,自动识别异常原因并触发相应的处理机制,减少人工干预,提高处理效率。

结语

DataOps不仅是一种技术实践,更是一种文化和思维方式。随着AI技术的不断进步,DataOps将继续推动企业数据管理和AI模型开发的创新和发展。

相关资源

白鲸开源官网:https://www.whaleops.com
Apache Dolphin Scheduler官网:https://dolphinscheduler.apache.org
Apache SeaTunnel官网:https://seatunnel.apache.org

作者介绍

代立冬

  • 白鲸开源科技联合创始人
  • Apache 孵化器导师
  • Apache DolphinScheduler PMC Chair
  • Apache SeaTunnel PMC
  • ApacheCon 亚洲大数据湖仓论坛出品人
  • 中国科协 “2023开源创新榜” 优秀人物

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/740678.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

powerquery刷新后固定列宽度

依次打开“表格工具”->“设计”->“属性”->“调整列宽”, 取消“调整列宽”选项

camunda快速入门(三):设计表单和审批流程

在本节中,您将学习如何使用camunda表单设计器设计一个在线表单,用流程建模工具设计一个审批流, 即BPMN 2.0 用户任务让人类参与到您的流程中。三、设计一个人工任务流程并配置表单 在本节中,您将学习如何使用 BPMN 2.0 用户任务让人类参与到您的流程中。 1、添加用户任务活…

微信电脑版v3.9.11.17防撤回插件

下载链接:https://download.csdn.net/download/hello_hlqk/89525196?spm=1001.2101.3001.9500 通过该插件,可以看到对方撤回的消息。 修改原理,如下图:使用说明: 解压后,双击start.bat来运行软件

大厂面试高频题——二分查找

35. 搜索插入位置 给定一个排序数组和一个目标值,在数组中找到目标值,并返回其索引。如果目标值不存在于数组中,返回它将会被按顺序插入的位置。 请必须使用时间复杂度为 O(log n) 的算法。 思考 二分模板题 class Solution:def searchInsert(self, nums: List[int], target…

如何解决网页打开加载缓慢问题

以我为例 今天打开B站发现很多视频打开之后一直是加载状态,加载半天也打不开,还有知乎跳转到csdn也无法正常打自己捣鼓的许久发现可以通过修改DNS来解决 首先打开此电脑→找到网络→右键点击属性→左上角更改适配器设置→选择你的网络双击→点击属性→找到Internet 协议版本4…

服务器开发——setsockopt函数

setsockopt() setsockopt() 是一个用于设置套接字选项的 Unix 系统调用。它允许程序员修改套接字的行为,以适应不同的网络环境和应用程序需求。 1. 函数介绍 函数原型: #include <sys/socket.h> /*** level:选项所在的协议层。例如,SOL_SOCKET 表示套接字层,IPPRO…

Python OpenCv对规则物体进行实时检测

很多情况需要对物体进行检测,常规的方法也有很多种。但是检测出来的边缘一般都是非常多,结果也是非常杂乱的,显然这种结果不是我们想要的。如果颜色相较于背景非常鲜艳的可以调节hsv阈值再进行检测,如果是一直在运动的物体可以通过帧差法进行物体检测,还有很多高深的算法也…

学习canvas(一些常用api)

当然,以下是这些常用Canvas API的总结,按照Markdown格式编写: 常用Canvas API总结 1. 获取绘图上下文 const canvas = document.getElementById(myCanvas); const ctx = canvas.getContext(2d); // 或 webgl2. 绘制矩形 ctx.fillStyle = blue; ctx.fillRect(10, 10, 150, 10…

uniapp 解决本地跨域问题

让每一滴智慧绘制成一条不归路!

UniVAE:基于Transformer的单模型、多尺度的VAE模型

大家都知道,Transformer的$\mathscr{O}(n^2)$复杂度是它的“硬伤”之一。不过凡事有弊亦有利,$\mathscr{O}(n^2)$的复杂度也为Transformer带来很大的折腾空间,我们可以灵活地定制不同的attention mask,来设计出不同用途的Transformer模型来,比如UniLM、K-BERT等。 本文介绍…

从变分编码、信息瓶颈到正态分布:论遗忘的重要性

这是一篇“散文”,我们来谈一下有着千丝万缕联系的三个东西:变分自编码器、信息瓶颈、正态分布。 众所周知,变分自编码器是一个很经典的生成模型,但实际上它有着超越生成模型的含义;而对于信息瓶颈,大家也许相对陌生一些,然而事实上信息瓶颈在去年也热闹了一阵子;至于正…

应用升级

本文是在你已经安装三个软件的基础上进行优化 一、卸载NFG Multi Crack软件(没有就不用管) 二、进入Lsposed软件 点击模块,可以看到已安装的两个模块1. 点击FL-Xposed,勾选以下应用,然后返回2. 点击HookVip,勾选Fakelocation,然后返回三、进入隐藏应用列表软件 1. 点击模…