公开(公告)号：CN116108110B

公开(公告)日：2023-08-15

申请号：CN202310404547.7

申请日：2023-04-17

Applicant: 南方电网数字电网研究院有限公司

Inventor： 曹旭 ,  辛华 ,  赵武清 ,  骆永翰 ,  张琦 ,  关国川 ,  苏杰 ,  侯志青

IPC: G06F16/27 ,  G06F9/54

Abstract: 本申请提供了一种Kafka消息消费补偿方法、系统和介质。属于数据库应用技术领域，该方法包括：通过源端将主数据库中的数据记录发送到Kafka消息流中并传输到管道中，将消费侧与消息流连接并与管道进行消息链接，对管道进行消息拉取生成执行信息并写入内存队列表再生成执行脚本，并写入内存队列表中，后将执行脚本写入副数据库中，通过守护线程监听内存队列表中的信息并对标记的错误信息进行补偿，对补偿后的消息重新拉取并写入副数据库；从而通过流式消息将主数据库中的数据记录发送到管道中，并从消费侧拉取消息生成执行信息和执行脚本写入内存列表，通过补偿将数据写入副数据库中，实现对消息消费的同步补偿技术。

公开(公告)号：CN116108110A

公开(公告)日：2023-05-12

申请号：CN202310404547.7

申请日：2023-04-17

Applicant: 南方电网数字电网研究院有限公司

Inventor： 曹旭 ,  辛华 ,  赵武清 ,  骆永翰 ,  张琦 ,  关国川 ,  苏杰 ,  侯志青

IPC: G06F16/27 ,  G06F9/54

Abstract: 本申请提供了一种Kafka消息消费补偿方法、系统和介质。属于数据库应用技术领域，该方法包括：通过源端将主数据库中的数据记录发送到Kafka消息流中并传输到管道中，将消费侧与消息流连接并与管道进行消息链接，对管道进行消息拉取生成执行信息并写入内存队列表再生成执行脚本，并写入内存队列表中，后将执行脚本写入副数据库中，通过守护线程监听内存队列表中的信息并对标记的错误信息进行补偿，对补偿后的消息重新拉取并写入副数据库；从而通过流式消息将主数据库中的数据记录发送到管道中，并从消费侧拉取消息生成执行信息和执行脚本写入内存列表，通过补偿将数据写入副数据库中，实现对消息消费的同步补偿技术。

公开(公告)号：CN114118045A

公开(公告)日：2022-03-01

申请号：CN202111443062.6

申请日：2021-11-30

Applicant: 南方电网数字电网研究院有限公司 ,  远光软件股份有限公司

Inventor： 孙刚 ,  余芸 ,  萧展辉 ,  甘杉 ,  刘桥波 ,  苏杰 ,  张东沛 ,  肖俊勇

IPC: G06F40/186 ,  G06F40/169 ,  G06F40/174

Abstract: 本申请实施例公开了一种报表取数方法、装置、存储介质及计算机设备，涉及办公自动化领域。本申请在需要输出工程报表时，基于业务场景和报表类型获取报表模板，然后为报表模板添加批注，解析批注得到取数规则，利用取数规则从源数据中获取数据填充到报表模板中，然后导出得到最终报表，本申请采用线下表格批注扩展的方法来定义各种取数规则，即可以提高报表编制的效率，又可以提高报表格式设置的灵活性。