数据处理方法、装置、设备及存储介质
摘要文本
本申请适用于信息处理技术领域，尤其涉及数据处理方法、装置、设备及存储介质，数据处理方法包括：通过显示第一输入窗口，接收用户在第一输入窗口上的第一输入操作；并且，根据接收的用户第一输入操作输入的信息，响应第一输入操作，发起请求连接数据库，在成功连接数据库后显示第一监管界面，有利于更直观高效地展示数据信息。通过对连接的数据库的事务日志进行实时监测和分析，能够完整地连接数据库数据的变化并且实时高效的进行数据处理。在捕获到数据库中发生数据变更的情况下，实时将数据库中数据的变更信息同步分发到下游并展示在所述第一监管界面上，做到快速高效地响应和处理数据，有效提升数据处理效率。
申请人信息
- 申请人:江西云擎科技有限公司
- 申请人地址:330000 江西省南昌市南昌高新技术产业开发区火炬大街161号嘉德商业广场705、706、707室
- 发明人: 江西云擎科技有限公司
专利详细信息
| 项目 | 内容 |
|---|---|
| 专利名称 | 数据处理方法、装置、设备及存储介质 |
| 专利类型 | 发明申请 |
| 申请号 | CN202311841099.3 |
| 申请日 | 2023/12/29 |
| 公告号 | CN117493385A |
| 公开日 | 2024/2/2 |
| IPC主分类号 | G06F16/2453 |
| 权利人 | 江西云擎科技有限公司 |
| 发明人 | 陈斌; 吴志伟; 夏明; 陈焕雪; 邵明礼; 梁长征; 邵志林; 王昱骐 |
| 地址 | 江西省南昌市南昌高新技术产业开发区火炬大街161号嘉德商业广场705、706、707室 |
专利主权项内容
（来自 马克数据网） 1.一种数据处理方法，其特征在于，包括：显示第一输入窗口；接收在所述第一输入窗口上的第一输入操作；响应于所述第一输入操作，连接到数据库并显示第一监管界面；对连接的所述数据库的事务日志进行实时监测和分析；在捕获到所述数据库中发生数据变更的情况下，将所述数据库中数据的变更信息同步分发到下游并展示在所述第一监管界面上；其中，所述对连接的所述数据库的事务日志进行实时监测和分析，包括：调用Flink依赖，并提交Flink流式数据处理创建作业；JobManager接收所述Flink流式数据处理创建作业，并将创建的Flink流式数据处理作业进行调度分配给可用的TaskManager；所述TaskManager执行所述Flink流式数据处理作业；启用Flink原生CDC连接器开始对所述数据库的事务日志进行实时监测和分析；所述在捕获到所述数据库中发生数据变更的情况下，将所述数据库中数据的变更信息同步分发到下游并展示在所述第一监管界面上，包括：捕获到数据库的数据变更时，将所述数据变更的变更内容和变更类型记录；Flink将记录的所述变更内容和变更类型转化为事件流；通过Flink将记录的事件流以JSON格式输出到Kafaka；Kafaka接收到Flink输出的JSON文件，并解析所述JSON文件还原变更内容和变更类型；将解析的所述JSON文件中还原变更的所述变更内容和所述变更类型发布到Kafaka消息队列；将所述JSON文件中解析后的数据绑定到所述第一监管界面相应部分并展示在所述第一监管界面。