您的当前位置:首页正文

高校数据集成系统的ETL设计与实现

2024-09-07 来源:易榕旅网
第2l卷第7期 2011年7月 计算机技术与发展 COMPUTER TECHNOLOGY AND DEVELOPMENT VoI.21 No.7 July 20II 高校数据集成系统的ETL设计与实现 王晓虹 ,刘 莹2,张艳凤 (1.辽宁石油化工大学计算机与通信工程学院,辽宁抚顺113001; 2.东北大学信息科学与工程学院,辽宁沈阳110819; 3.沈阳农业大学,辽宁沈阳110122) 摘要:高校数字化校园建设是高校教育信息化发展的一项重要任务。由于高校普遍采用不同的数据库系统来管理学校 的一切事务,致使信息存在大量的冗余、不一致,乃至“信息孤岛”的现象,从而严重制约了高校的信息化的建设。基于 ETL的数据集成技术能够很好地解决这个难题。以高校集成数字校园平台建设为背景,提出了高校数据集成系统中基于 ETL平台的建设方案。系统将ETL技术与传统的数据集成技术相结合,采用适配器技术和中间件技术,处理大批量的历 史数据、实时处理小批量的变化的数据,全方位地满足用户对所有数据处理的需求,解决了异构数据集成和共享问题。 关键词:ETL;数据集成;实时抽取 中图分类号:TP393 文献标识码:A 文章编号:1673—629X(2011)07—0186—04 Design and Implementation of ETL Based on University Data Integration System WANG Xiao—hong ,LIU Ying ,ZHANG Yan—feng (I.School of Information Engineering,Liaoning University of Petroleum& Chemical Technology,Fushun 1 13001,China; 2.College of Information Science and Engineering,Northeastern University,Shenyang 110819,China; 3.Shenyang Agricultural University,Shenyang 110112,China) Abstract:Digital campus constructionis allimportanttaskforthe highereductioninformation development.Duetothe diferent data- base commonly used by universities tO manage all matters of he schoolt system.there arc a lot of redundant and inconsistent information or even the information island.These have seriously hampered the university information construction.The data integration technology based onETL can solvethis problem.Takingthe universityintegrateddigital campusplatform asthebackground.the constructionpro- gram ofthe universiy dattaintegration system based onETLisproposed.The systemintegratestheETLtchenologywithtraditionaltch- enology.and Use adaptertchnoleogyandmiddlewaretchnoleogyt0 handlelargequantities ofhistorical dataandto dealwith small quanti— ites of datainreal-time,which Canmeet customer demand ofallthe data processing,andsolvethe problem ofheterogeneous datainte- grationand sh ̄ng. Key words:ETL;data integration;real-time extraction 0 引 言 高校数字化校园建设是目前高校教育信息化发展 的一项重要任务。高校数字化校园建设的目的是将高 字校园框架,从各个应用系统抽取共享数据,并向各业 务部门提供数据订阅,形成支撑其他应用的底层数据 平台。在此基础上详细阐述了集成系统的数据整合的 设计与实现。系统提供了一个适合高校目前状况、且 能够快速实现数据共享的方案 卜 。 校内原有的诸多彼此分离的业务子系统进行整合、集 成,形成一个无缝平台,从而整体提高高校的教学质 量、办公效率,整体提升高校的竞争能力。 本系统利用ETL和中间件技术构建一个高校数 l高校数据集成系统的总体架构 本系统结合ETL和中间件技术,以分层次的组件 方式对需要的数据从各异构数据源进行集成并向上提 供统一的接口。系统架构图见图1。 高校数据集成系统分为三个模块:管理模块、代理 收稿日期:2010—12—08;修回日期:2011—03—08 基金项目:国家自然科学基金(青年基金)(6l0030o3) 作者简介:王晓虹(1970一),女,副教授,研究方向为数据库和数据仓 库、网络安全、嵌入式。 模块和ETL模块。管理模块主要完成系统的控制、配 第7期 王晓虹等:高校数据集成系统的ETL设计与实现 ・187・ 图1数据集成系统架构图 置和监控等任务,它基于B/S结构运行在应用服 务器上。代理模块主要完成ETL模块的启动和日志 处理等任务,通过代理模块实现管理模块远程启动 ETL模块的功能。ETL模块主要负责将分布的、异构 数据源中的数据进行清洗、转换、集成,再加载到数据 中心。每个代理模块可启动多个ETL模块,每个ETL 模块可启动多个ETL任务 一。 个ETL模块由六个组件组成,分别是:包含 MBean的JMX组件、Schedule组件、Cache组件、Run. Graph组件、RunAdapter组件和CachelO组件。JMX 组件按照JMX规范实现管理功能,Mbean主要用于控 制Schedule。Schedule组件主要完成任务调度,控制 图2 ETL模块任务结构图 数据抽取组件从异构数据源(如数据库、XML文 件、文本文件等)中定时抽取数据,数据抽取组件执行 结束后,调用Cache API将数据存人Cache组件,Cache 组件将二进制和大文本存人文件,根据数据抽取组件 传人的数据生成OID和序列化数据,并写入在配置时 集成任务的生命周期。Cache组件主要完成从外部存 储中读写数据及进行序列化支持。Cache增加了集成 系统的安全性和可靠性,同时增加部署的灵活性。 Cache未来可以替换成一个带有缓存传输功能的消息 子系统或文件系统等。CachelO组件调用Cache组件 的接口,实现接口的转换。RunGraph组件用于控制运 行一个Graph对象,RunAdapter组件用于运行一个A- dapter对象。 ETL模块是进行ETL功能的子系统,每一个ETL 生成的缓存表中。数据加载组件调用Cache API从 Cache组件中读出数据。 2.2 ETL模块的处理流程 ETL是数据仓库实现过程中,将数据由数据源向 数据仓库加载的主要过程。用户从数据源抽取出所需 的数据,经过数据清洗转换,最终按照预先定义好的数 模块可以包含多个Adapter组件和多个Graph组件完 成一类任务的集成。每个Adapter组件直接访问一个 被抽取或是一个被加载的资源。每个Graph包含一个 据仓库模型,将数据加载到数据仓库中。ETL模块的 处理流程如图3所示。根据不同的抽取策略进行参 数、执行时间的初始化,之后进人后台守护模块实时监 或多个Node,每个Node是一个线程,完成一种相对独 立的功能。Node和Adapter具备扩展能力,可以后期 开发扩充。Graph与Adapter通过Cache组件完成数 据的对接。 控。后台主要完成将业务数据按照抽取策略定时导人 数据到临时数据库,处理后定时调用后台存储过程保 存到数据中心库中。 2.3集成数据抽取组件 2.3.1主要功能 2高校数据集成系统的ETL的关键技术 2.1 ETL模块的任务结构 数据集成的基本需求是增量数据的监听和传输。 根据高校集成系统目前的需求,数据抽取的类型分成 两类:实时数据抽取和批量数据抽取。 (1)实时数据抽取。 实时数据抽取采用基于消息技术的消息中间件方 每个ETL任务可以由数据抽取组件、数据转换组 件和数据加载组件组合构成。执行方式为E、T、L三 部分并发执行。ETL任务的内部结构图如图2所示。 ・l88・ 计算机技术与发展 第2l卷 式及分布式主流数据库之间的数据复制技术。实时数 据特点是数据量不大,从一个字节到几百兆,同步或者 异步传输。对于增量数据的清洗采用实时抽取转换加 载。 抽取参数策略修改 n E1L模块初始化,根据参数 设置各操作执行的时间 后台守护模块实时监控 ‘一一一一一 一一一一一一一一一~一一一一一一一一一一一一~一一…一…一一一一一一一一一一一一一J 图3 ETL模块的处理流程 (2)批量数据抽取。 批量数据抽取没有实时要求,但是量很大,达几百 兆以上。批量数据抽取的实现主要是使用文件系统及 数据处理工具等。批量加载和聚合运算依赖于Adapt— er的实现。 2.3.2体系结构 数据抽取组件的体系结构图如图4所示。 消 息 中 间 件 l文本文件 ;}=== 兰奎至  望望F 监控线程 图4数据抽取组件的体系结构图 由于系统的集成针对不同平台、不同形式的源数 据,本系统采用适配器来屏蔽各个数据源的异构性,向 上提供一种一致的数据表达格式。适配器不但处理不 同数据源的接入问题,同时还要完成从异构数据源抽 取的数据转换成XML格式,形成元数据描述XML文 件的功能。在系统中采用了数据库适配器、XML适配 器、文件适配器等来实现数据的抽取任务 。 2.3.3实时抽取实现模块 高校数据集成系统既要处理历史数据,又要处理 实时变更的业务数据。基于此特点,本系统实时抽取 模块采用CTF(Capture,Transformation,Flow)体系。 该体系将ETL和传统的数据集成方法相结合,它既可 以处理大批量的历史数据,又可以实时处理小批量的 变化的数据,全方位地满足用户对所有数据处理的需 求。 本系统主要采用以下模块实现实时抽取功能。 (1)数据变更触发器。 在数据源的数据库中设立触发器,当数据发生写 入、删除以及修改操作时,启动数据变更触发器,触 发器设置数据变更事务,把发生变化的数据传送到适 配器,适配器把处理好的数据通过消息中间件传送到 数据转换器,由转换器处理完毕之后提交给中心数据 库,若变更的数据已写人中心数据库中,则撤销此事 务,否则继续执行此事务直到此事务提交完毕,最后 关闭数据变更触发器。 (2)文件变化监控线程。 利用专门的监控线程根据预先定义好的时问间隔 轮询文件,对有变化的文件的数据进行抽取转换工作。 (3)消息中间件。 基于消息的中间件技术有两种方式:消息传递方 式和消息队列方式。 消息传递采用广播/预订方式。该通信模型提供 了位置透明性功能。程序只需要简单地将消息以主题 方式发送出去,由中间件来负责将消息传递给所有预 订该主题的程序。消息中间件主要通过agents技术来 实现Publish—Subscribe方式应用。当程序广播消息 时,首先与一个代理进行连接,将消息传递给代理。代 理负责路由消息给相应的程序,实现消息的动态路由 功能。 消息队列方式允许程序无需直接建立起连接即可 发送和接收消息。程序只须简单地将消息发送给消息 队列,由消息队列负责消息的传递,对应用程序完全透 明。消息队列采用异步方式,为信息提供了个安全的 存储方式。 2.4集成数据转换组件 根据集成系统的要求,系统以组件化的方式实现 数据转换和加载。 集成数据转换是首先将一种数据库中定义的模型 转化为另一种数据库中模型,再根据需要将源数据库 中的数据转换到目的数据库中。对于整个转换分成模 式转换和数据转换两部分。模式转换将源数据库中的 数据字典转换成目的数据库中的数据字典;数据转换 则按照模式转换的要求,从源数据库中数据经一系列 转换产生目的数据库。 数据转换组件包括字段映射、数据过滤、数据清 第7期 王晓虹等:高校数据集成系统的ETL设计与实现 ・189・ 洗、数据替换、数据计算、数据验证、数据加解密、数据 合并、数据拆分等。这些组件可插拔,可任意组装,各 组件之间通过数据总线共享数据。 数据清洗主要是针对源数据库中,对出现二义性、 模型和实现方案。该ETL系统基于适配器和中间件 技术、具有多线程并发运行、增量抽取、易扩展、支持跨 平台的功能。该系统可以很好地解决数据集成中多数 据融合、数据不一致和数据同步更新等问题。 参考文献: [1] 张上游,王燕.数字化校园建设中数据分析的研究[J]. 西南民族大学学报,2009,35(4):871-873. 重复、不完整、违反业务或逻辑规则等问题的数据进行 相应的清洗操作。在清洗之前需要进行数据质量分 析,以找出存在问题的数据。数据清洗和纠错处理主 要实现如下:对源数据的数据质量进行分析;建立清洗 [2] 王晓虹,王国仁,于勇前,等.电信闭环决策支持系统的研 规则;根据清洗处理的结果进行纠错处理;差异比对和 修复;比较任意两个数据库的两张表,可以指定比对规 究与实现[J].计算机应用研究,2008,25(4):1247-1249. 则;自动生成差异列表;根据比对的差异结果,自动修 [3] 秦学勇,刘栋.数据仓库的可扩展性研究与设计[J]. 计算机技术与发展,2009,19(5):65—67. 复目标表等 。 [4] 李颖,郝克刚,葛玮.基于电信数据仓库系统的ETL 2.5集成数据加载组件 研究与设计[J].计算机应用与软件,2009,30(1):178— 集成数据加载将从数据源系统中抽取、转换后的 180. 数据加载到数据仓库系统中。数据加载策略要考虑加 [5]许力,牟晓光,马云存.并行ETL过程的研究与实现 载周期及数据追加策略两方面的内容。根据高校教 [J].计算机工程与应用,2009,45(13):170-172. 学、管理业务的实际情况,加载周期要综合考虑业务分 [6]宋杰,王大玲,鲍玉斌,等.一种元数据驱动的ETL方法 析需求和系统加载的代价,对不同的子系统的数据采 的研究[J].小型微型计算机系统,2007,12(12):2167— 2173. 用不同的加载周期,但必须保存同一时间数据的完整 性。 [7]Panos V,Alkis S.Manolis G,et a1.A generic and customiz— able framework for the design ofETL scenariosf J].Informa. 集成数据加载组件主要功能是解析元数据描述 tion Systems,2005,30(7):492-525. XML文件。XML文件解析模块将经数据转换层转换 [8] Alkis S,Dimitrios S,Malu C.Representation of conceptual 完成的元数据描述XML文件,通过对象一关系映射进 ETL desings in natural lnaguage using Semantic Web technol- 行解析,最后将转换结果存人中心数据库中。 ogy[J].Data&Knowledge Engineering,2010,69(1):96一 数据的追加策略根据数据的抽取策略和业务规则 ll5. 确定,本系统采用三种类型:直接追加、全部覆盖、更新 [9] 黄怀毅,杨路明.一种轻量级架构的ETL系统设计与实现 追加。对于流水数据采用直接追加方式;如果抽取数 [J].计算机技术与发展,2008,18(6):202—205. 据本身已包括数据的当前和所有历史状况,则对目标 【10]戴浩,杨波.ETL中的数据增量抽取机制研究[J].计 表采用全部覆盖方式;对于需要连续记录业务的状态 算机工程与设计,2009,30(23):5552—5555. 变化,并用当前的最新状态同历史状态数据进行对比 [1 1]Alkis S,Panos V,Timos S.State—Space Optimization fo ETL Worktlows[J].IEEE Transactions on Knowledge&Data En. 的情况可采用更新追加的方式。 gineefing,2005,17(io):1404-1419. [12]包从剑,李星毅,施化吉.可扩展和可交互的数据清洗系 3结束语 统[J].计算机技术与发展,2007,17(7):84—86. 根据高校数据集成系统的需求,构建了ETL系统 (上接第185页) [7] 梁小虎.高速串行总线RapidlO与PCI Express协议分析比 (11):18-19. 较[J].航空计算技术,2olo(3):164—167. [2]吴英攀,于立新.基于层次化验证平台的存储器控制器功 [8]黄振中,柴小丽.基于Vxworks的PCI—RapidlO桥驱动设计 能验证[J].微电子学与计算机,2009(2):25—28. [J]。计算机工程,2010(3):239—240. [3]王世好,王歆民,刘明业.嵌入式系统软硬件协同验证中软 [9]Serila RapidIO User Guide v5.1 UG503[M].[s.1.]:Xilinx, 件验证方法[J].计算机研究与发展,2005,42:514—519. 20o8. [4]马宁,李玲,田泽,等.ARINC659总线协议芯片的仿 [10]Serial RapidlO User Guide v4.3 UG247[M].[s.I.]:Xilinx, 真验证[J].计算机技术与发展,2010,20(1):205—206. 20o8. [5]杨海波,田泽,蔡叶芳,等.FCIP软核的仿真与验证[J]. [11]郭蒙,田泽,蔡叶芳,等.1553B总线接口SoC验证平 计算机技术与发展,2009,19(9):168—172. 台的实现[J].航空计算技术,2008,38(6):99—101. [6]RapidlO Interconnect Speciifcation Rev2.0,03[s].[s.I.]: [12]田靖,田泽.AFDX—ES SoC虚拟仿真平台的构建与应 Copyright RapidlO Trade Association,2008. 用[J].计算机技术与发展,2010,20(8):192—198. 

因篇幅问题不能全部显示,请点此查看更多更全内容