一种基于数据转换整合的实时数据处理方法

    公开(公告)号:CN114385728B

    公开(公告)日:2024-07-19

    申请号:CN202111532519.0

    申请日:2021-12-15

    IPC分类号: G06F16/25

    摘要: 本发明公开了一种基于数据转换整合的实时数据处理方法,包括以下步骤:首先确定熟悉所需对接消息中间件的软件特性,制定数据转换整合系统集成此中间件的方案;适配抽取插件和加载插件并且使插件适应流式实时传输处理数据;定制消息确认插件,增加容错能力。本发明为数据转换整合系统提供了一种可行有效的实时数据处理方法;本发明可适配市场上多种不同的消息中间件;本发明提供了消息确认机制,由于异常未被确认的消息可重新消费处理,使用此方法保证了数据的完整性、可靠性。

    一种面向电力物联终端设备的信息模型构建方法

    公开(公告)号:CN114493088A

    公开(公告)日:2022-05-13

    申请号:CN202111516537.X

    申请日:2021-12-13

    IPC分类号: G06Q10/06 G06Q50/06

    摘要: 本发明公开一种面向电力物联终端设备信息模型构建方法,包括将电力物联终端设备按照类型在广度维度划分;将电力物联终端设备的采集量测数据按照时间在深度维度划分;将电力物联终端设备的标签信息在静态信息维度划分;将电力物联终端设备的采集单元按照采样类别在动态信息维度划分;所述广度维度与静态信息维度和动态信息维度之间关联;所述动态信息维度与时间深度维度之间关联。本发明采用广度、深度、静态和动态信息的四维模型构建方式,将电力物联终端设备的数据范围、数据时间、设备标签和设备采集单元统一管理;通过树型结构、标签结构信息关联,避免传统关系模型导致的巨大资源开销问题;为电力物联终端设备的能源数字化转型提供支撑。

    一种基于数据转换整合的实时数据处理方法

    公开(公告)号:CN114385728A

    公开(公告)日:2022-04-22

    申请号:CN202111532519.0

    申请日:2021-12-15

    IPC分类号: G06F16/25

    摘要: 本发明公开了一种基于数据转换整合的实时数据处理方法,包括以下步骤:首先确定熟悉所需对接消息中间件的软件特性,制定数据转换整合系统集成此中间件的方案;适配抽取插件和加载插件并且使插件适应流式实时传输处理数据;定制消息确认插件,增加容错能力。本发明为数据转换整合系统提供了一种可行有效的实时数据处理方法;本发明可适配市场上多种不同的消息中间件;本发明提供了消息确认机制,由于异常未被确认的消息可重新消费处理,使用此方法保证了数据的完整性、可靠性。

    一种过SQL代理安全隔离装置的服务穿透方法及系统

    公开(公告)号:CN114422165A

    公开(公告)日:2022-04-29

    申请号:CN202111440386.4

    申请日:2021-11-30

    IPC分类号: H04L9/40

    摘要: 本发明公开了一种过SQL代理安全隔离装置的服务穿透方法及系统,包括1、外网系统发起请求,数据写入请求队列;2、请求队列屏蔽并发,将结构化数据写入网闸支持的中间库;3、后置代理服务批量读取请求数据;4、线程池解析请求数据,创建请求线程,并发对内网数据中台目标服务发起请求;5、请求结果放入响应队列,屏蔽并发,将数据写入中间库;6、前置代理服务单线程高频轮询中间库,批量读取响应数据到MAP;7、请求队列从MAP获取响应数据反馈给外网业务系统。本发明支撑内外网多种服务类型的快捷交互,解决应用间内外网业务服务安全交互问题,实现内外网业务实时交互更好地支撑基于数据中台的内外网服务贯通。