← 返回列表
一种数据处理方法、装置、设备及可读存储介质
摘要文本
本申请实施例提供了一种数据处理方法、装置、设备及可读存储介质,基于目标数据源的类型和状态,从目标数据源获取目标数据和目标业务的信息,将目标数据以实时流数据形式存储至消息队列,采用流处理框架将目标数据持久化至数据湖。从目标源提取目标数据,并采用流处理框架对目标数据进行解析处理,得到标准化数据,目标源包括消息队列和数据湖中的一项。将标准化数据以实时流数据形式存储至消息队列,采用流处理框架将标准化数据持久化至数据湖。从目标源提取标准化数据,基于业务需求,采用流处理框架对标准化数据进行业务处理。本申请基于流式框架对数据进行处理,得到处理结果,实现数据流批一体化处理,提高数据处理的实时性。
申请人信息
- 申请人:中债金融估值中心有限公司
- 申请人地址:200120 上海市浦东新区世纪大道1788号7层
- 发明人: 中债金融估值中心有限公司
专利详细信息
| 项目 | 内容 |
|---|---|
| 专利名称 | 一种数据处理方法、装置、设备及可读存储介质 |
| 专利类型 | 发明申请 |
| 申请号 | CN202410087040.8 |
| 申请日 | 2024/1/22 |
| 公告号 | CN117609315A |
| 公开日 | 2024/2/27 |
| IPC主分类号 | G06F16/2455 |
| 权利人 | 中债金融估值中心有限公司 |
| 发明人 | 王守任; 薛茜; 吕琦; 叶佳蕊 |
| 地址 | 上海市浦东新区世纪大道1788号7层 |
专利主权项内容
1.一种数据处理方法,其特征在于,包括:基于目标数据源的类型感知所述目标数据源的状态,基于所述目标数据源的类型和状态,从所述目标数据源获取目标数据和目标业务的信息,所述类型包括文件类数据源、数据流类数据源以及数据库类数据源;所述目标业务的信息包括所述目标数据的业务需求;将所述目标数据以实时流数据形式存储至消息队列,采用流处理框架将所述目标数据持久化至数据湖;从目标源提取所述目标数据,并采用流处理框架对所述目标数据进行解析处理,得到标准化数据,所述解析处理包括数据标准化转换,所述目标源包括消息队列和数据湖中的一项;将所述标准化数据以实时流数据形式存储至消息队列,采用流处理框架将所述标准化数据持久化至数据湖;从所述目标源提取所述标准化数据,基于所述业务需求,采用流处理框架对所述标准化数据进行业务处理,得到所述目标业务对应的数据处理结果。