← 返回列表

一种数据处理方法、装置、设备及可读存储介质

申请号: CN202410087040.8
申请人: 中债金融估值中心有限公司
申请日期: 2024/1/22

摘要文本

本申请实施例提供了一种数据处理方法、装置、设备及可读存储介质,基于目标数据源的类型和状态,从目标数据源获取目标数据和目标业务的信息,将目标数据以实时流数据形式存储至消息队列,采用流处理框架将目标数据持久化至数据湖。从目标源提取目标数据,并采用流处理框架对目标数据进行解析处理,得到标准化数据,目标源包括消息队列和数据湖中的一项。将标准化数据以实时流数据形式存储至消息队列,采用流处理框架将标准化数据持久化至数据湖。从目标源提取标准化数据,基于业务需求,采用流处理框架对标准化数据进行业务处理。本申请基于流式框架对数据进行处理,得到处理结果,实现数据流批一体化处理,提高数据处理的实时性。

专利详细信息

项目 内容
专利名称 一种数据处理方法、装置、设备及可读存储介质
专利类型 发明申请
申请号 CN202410087040.8
申请日 2024/1/22
公告号 CN117609315A
公开日 2024/2/27
IPC主分类号 G06F16/2455
权利人 中债金融估值中心有限公司
发明人 王守任; 薛茜; 吕琦; 叶佳蕊
地址 上海市浦东新区世纪大道1788号7层

专利主权项内容

1.一种数据处理方法,其特征在于,包括:基于目标数据源的类型感知所述目标数据源的状态,基于所述目标数据源的类型和状态,从所述目标数据源获取目标数据和目标业务的信息,所述类型包括文件类数据源、数据流类数据源以及数据库类数据源;所述目标业务的信息包括所述目标数据的业务需求;将所述目标数据以实时流数据形式存储至消息队列,采用流处理框架将所述目标数据持久化至数据湖;从目标源提取所述目标数据,并采用流处理框架对所述目标数据进行解析处理,得到标准化数据,所述解析处理包括数据标准化转换,所述目标源包括消息队列和数据湖中的一项;将所述标准化数据以实时流数据形式存储至消息队列,采用流处理框架将所述标准化数据持久化至数据湖;从所述目标源提取所述标准化数据,基于所述业务需求,采用流处理框架对所述标准化数据进行业务处理,得到所述目标业务对应的数据处理结果。