-
公开(公告)号:CN111625216A
公开(公告)日:2020-09-04
申请号:CN202010352982.6
申请日:2020-04-29
申请人: 江苏瑞中数据股份有限公司 , 国网电力科学研究院有限公司
摘要: 本发明公开了一种基于数据转换整合系统的插件实现方法。本发明属于分布式数据转换整合系统任务插件的优化技术领域。本发明实现了可在广域复杂网络和数据环境下,满足多源异构数据高效集成需求,提供弹性伸缩、高性能、高可靠的数据运行处理机制;作为上层系统的数据转换整合系统在统一数据中心及大数据平台的重要底层支撑部件起到重要作用,还可以实现对数据的联机分析处理、数据挖掘功能。
-
公开(公告)号:CN114385728B
公开(公告)日:2024-07-19
申请号:CN202111532519.0
申请日:2021-12-15
申请人: 江苏瑞中数据股份有限公司 , 南瑞集团有限公司
IPC分类号: G06F16/25
摘要: 本发明公开了一种基于数据转换整合的实时数据处理方法,包括以下步骤:首先确定熟悉所需对接消息中间件的软件特性,制定数据转换整合系统集成此中间件的方案;适配抽取插件和加载插件并且使插件适应流式实时传输处理数据;定制消息确认插件,增加容错能力。本发明为数据转换整合系统提供了一种可行有效的实时数据处理方法;本发明可适配市场上多种不同的消息中间件;本发明提供了消息确认机制,由于异常未被确认的消息可重新消费处理,使用此方法保证了数据的完整性、可靠性。
-
公开(公告)号:CN114493088A
公开(公告)日:2022-05-13
申请号:CN202111516537.X
申请日:2021-12-13
申请人: 江苏瑞中数据股份有限公司 , 南瑞集团有限公司
摘要: 本发明公开一种面向电力物联终端设备信息模型构建方法,包括将电力物联终端设备按照类型在广度维度划分;将电力物联终端设备的采集量测数据按照时间在深度维度划分;将电力物联终端设备的标签信息在静态信息维度划分;将电力物联终端设备的采集单元按照采样类别在动态信息维度划分;所述广度维度与静态信息维度和动态信息维度之间关联;所述动态信息维度与时间深度维度之间关联。本发明采用广度、深度、静态和动态信息的四维模型构建方式,将电力物联终端设备的数据范围、数据时间、设备标签和设备采集单元统一管理;通过树型结构、标签结构信息关联,避免传统关系模型导致的巨大资源开销问题;为电力物联终端设备的能源数字化转型提供支撑。
-
公开(公告)号:CN113918570A
公开(公告)日:2022-01-11
申请号:CN202111253190.4
申请日:2021-10-27
申请人: 江苏瑞中数据股份有限公司 , 南瑞集团有限公司
IPC分类号: G06F16/22 , G06F16/23 , G06F16/2453 , G06F16/2455 , G06F16/25 , G06Q50/06
摘要: 本发明公开一种面向电力二次设备的嵌入式实时数据库,从下而上依次包括存储层、模型层和应用层;所述存储层存储测点模型以及测点对应的量测数据,包括存储接口模块、轻量缓存模块、数据压缩模块、数据存储模块和资源优化模块;所述模型层存储设备物模型,并将物模型与存储层的测点模型关联,包括模型接口模块、模型算法模块和模型存储模块;所述应用层实现数据查询分析和通过对外接口实现模型的构建和数据接入。本发明实现轻量化的电力模型高度匹配,降低实时数据库在电力二次嵌入式设备环境下的内存及存储资源消耗;实现了测点数据的高效访问,避免了频繁的内存及CPU操作;极大地提升了系统安全性。
-
公开(公告)号:CN114385728A
公开(公告)日:2022-04-22
申请号:CN202111532519.0
申请日:2021-12-15
申请人: 江苏瑞中数据股份有限公司 , 南瑞集团有限公司
IPC分类号: G06F16/25
摘要: 本发明公开了一种基于数据转换整合的实时数据处理方法,包括以下步骤:首先确定熟悉所需对接消息中间件的软件特性,制定数据转换整合系统集成此中间件的方案;适配抽取插件和加载插件并且使插件适应流式实时传输处理数据;定制消息确认插件,增加容错能力。本发明为数据转换整合系统提供了一种可行有效的实时数据处理方法;本发明可适配市场上多种不同的消息中间件;本发明提供了消息确认机制,由于异常未被确认的消息可重新消费处理,使用此方法保证了数据的完整性、可靠性。
-
公开(公告)号:CN114422165A
公开(公告)日:2022-04-29
申请号:CN202111440386.4
申请日:2021-11-30
申请人: 江苏瑞中数据股份有限公司 , 南瑞集团有限公司
IPC分类号: H04L9/40
摘要: 本发明公开了一种过SQL代理安全隔离装置的服务穿透方法及系统,包括1、外网系统发起请求,数据写入请求队列;2、请求队列屏蔽并发,将结构化数据写入网闸支持的中间库;3、后置代理服务批量读取请求数据;4、线程池解析请求数据,创建请求线程,并发对内网数据中台目标服务发起请求;5、请求结果放入响应队列,屏蔽并发,将数据写入中间库;6、前置代理服务单线程高频轮询中间库,批量读取响应数据到MAP;7、请求队列从MAP获取响应数据反馈给外网业务系统。本发明支撑内外网多种服务类型的快捷交互,解决应用间内外网业务服务安全交互问题,实现内外网业务实时交互更好地支撑基于数据中台的内外网服务贯通。
-
-
-
-
-