一种基于Flink流式计算网络的数据处理方法及系统

    公开(公告)号:CN113114499A

    公开(公告)日:2021-07-13

    申请号:CN202110377105.9

    申请日:2021-04-08

    Abstract: 本发明涉及一种基于Flink流式计算网络的数据处理方法及系统,属于数据处理技术领域,解决了现有技术中计算集群对数据的吞吐量低、处理效率低。该方法包括:获取Flink流式计算网络中每一对上游计算节点和下游计算节点之间流入下游计算节点的传输链路的容量、流量以及计算时延;当传输链路的计算时延不在预设范围内时,调整该传输链路的容量;根据Flink流式计算网络中每一对上游计算节点和下游计算节点之间流入下游计算节点的传输链路的流量、容量,获得Flink流式计算网络中每一传输链路的递增容量;进而确定递增容量最小的无环数据传输路径,并进行待处理数据流的传输与处理,该方法能够提高计算集群的数据吞吐量和对数据的处理效率。

    军工领域消息的传递方法
    12.
    发明公开

    公开(公告)号:CN111245777A

    公开(公告)日:2020-06-05

    申请号:CN201911113598.4

    申请日:2019-11-14

    Abstract: 本发明属于计算机技术、安全保密技术领域,具体涉及一种军工领域消息的传递方法。其通过将服务器端和接收终端通过消息中间件建立消息协议数据传输信道,并根据消息协议数据传输信道将SM2加密算法处理产生的消息数据进行传输,在消息服务器端进行消息的SM2加密,实现消息数据的加密实时传输,利用消息中间件的路由模式进行消息的分发,在消息接收端进行SM2解密算法解密,提高了消息推送的安全性和时效性;支持通过消息中间件将消息数据发送至多个接收终端,即通过消息中间件增加多个接收终端,实现了消息数据的负载均衡,减轻服务器端的压力。利用此发明实现数据传输过程中的安全性和一致性,可利用在军工领域的数据传输场景。

    基于细粒度特征语义网络的系统接口时序知识分析方法

    公开(公告)号:CN109460478A

    公开(公告)日:2019-03-12

    申请号:CN201811314413.1

    申请日:2018-11-06

    Abstract: 本发明属于软件工程技术领域,具体涉及一种基于细粒度特征语义网络的系统接口时序知识分析方法,其包括:构建嵌入式系统测试故障集;在嵌入式系统测试故障集中搜索接口关键问题,分析提取与时序相关的故障,初步形成时序相关的接口故障集;在嵌入式系统测试故障集中搜索与时序关键的故障,分析提取与接口相关的故障,形成接口相关的时序故障集;两个故障集合并形成接口时序故障集;根据时序故障库中的故障类型,利用基于细粒度特征语义网络的方法,提取接口时序关键影响因素,形成嵌入式系统接口时序知识集。由此得到的嵌入式系统接口时序知识可实现测试知识的继承,且具有可扩展性,便于测试知识的推送,提升测试效率。

    一种多元网络设备智能接入系统

    公开(公告)号:CN113810160B

    公开(公告)日:2023-07-04

    申请号:CN202111094007.0

    申请日:2021-09-17

    Abstract: 本发明涉及一种多元网络设备智能接入系统,属于网络设备接入技术领域,解决了由于各网络设备的网络数据格式不统一导致的网络安全分析难度大、效率及准确度低的问题。智能接入系统包括:设备接入接口组件,用于接收每一网络设备的网络数据;网络数据包括设备类型、数据格式、编码格式及数据内容;数据解析组件,与设备接入接口组件相连,用于解析来自设备接入接口组件的网络数据,得到相应的解析数据;数据归一化处理组件,与数据解析组件相连,用于基于每一种网络设备的网络数据的数据格式与归一化数据格式之间的映射关系,将生成的解析数据映射至归一化数据格式中,得到归一化的数据集。该系统能够保证得到的归一化的数据集中数据的一致性。

    一种动态调整转发路径的安全传输系统

    公开(公告)号:CN114124799B

    公开(公告)日:2023-04-18

    申请号:CN202111369130.9

    申请日:2021-11-18

    Abstract: 本发明涉及一种动态调整转发路径的安全传输系统,属于数据传输技术领域,解决了现有数据传输路径无法动态调整的问题。包括控制器、源主机、目的主机和交换机;控制器包括路径变更识别模块、路径和权重计算模块;源主机包括权重更新模块和数据发送模块;路径变更识别模块用于根据历史通信记录和网络拓扑识别是否重新选择转发路径;路径和权重计算模块用于在识别是重新选择转发路径后,计算得到多条转发路径和权重;权重更新模块用于在数据包被确认时,通过路径和权重计算模块,更新多条转发路径的权重;数据发送模块用于根据多条转发路径和权重选择转发路径发送数据包,以及重发未收到数据回复的数据包。实现了传输路径的动态调整。

    一种基于Flink流式计算网络的数据处理方法及系统

    公开(公告)号:CN113114499B

    公开(公告)日:2022-06-28

    申请号:CN202110377105.9

    申请日:2021-04-08

    Abstract: 本发明涉及一种基于Flink流式计算网络的数据处理方法及系统,属于数据处理技术领域,解决了现有技术中计算集群对数据的吞吐量低、处理效率低。该方法包括:获取Flink流式计算网络中每一对上游计算节点和下游计算节点之间流入下游计算节点的传输链路的容量、流量以及计算时延;当传输链路的计算时延不在预设范围内时,调整该传输链路的容量;根据Flink流式计算网络中每一对上游计算节点和下游计算节点之间流入下游计算节点的传输链路的流量、容量,获得Flink流式计算网络中每一传输链路的递增容量;进而确定递增容量最小的无环数据传输路径,并进行待处理数据流的传输与处理,该方法能够提高计算集群的数据吞吐量和对数据的处理效率。

    一种SAP ERP系统数据处理方法

    公开(公告)号:CN114356483A

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

    申请号:CN202210008605.X

    申请日:2022-01-05

    Abstract: 本发明涉及一种SAP ERP系统数据处理方法,属于数据处理技术领域,解决了现有无通过参数传递实现SAP ERP客户端的自动打开及对业务数据的自动处理问题。包括接收非SAP系统传递的参数,包括获取模式、用户标识、菜单事务码、业务数据和执行操作按钮代码,作为待获取数据;根据用户标识校验SAP ERP中是否存在该用户,如果存在,获取用户名和密码,加入待获取数据;再依次校验SAP ERP中是否存在对应的菜单,用户是否具有菜单权限,是否存在业务数据中的业务字段和执行操作按钮;校验均通过后,若获取模式是CS模式,将待获取数据组装成bat格式字符串,基于ActiveXObject控件调用bat格式字符串,否则,将待获取数据组装成请求参数,调用SAP ERP系统Web端URL,进入SAP ERP系统进行数据处理。

    基于细粒度特征语义网络的系统接口时序知识分析系统

    公开(公告)号:CN109460362A

    公开(公告)日:2019-03-12

    申请号:CN201811314437.7

    申请日:2018-11-06

    Abstract: 本发明属于软件工程技术领域,具体涉及一种基于细粒度特征语义网络的系统接口时序知识分析系统,其包括:构建嵌入式系统测试故障集;在嵌入式系统测试故障集中搜索接口关键问题,分析提取与时序相关的故障,初步形成时序相关的接口故障集;在嵌入式系统测试故障集中搜索与时序关键的故障,分析提取与接口相关的故障,形成接口相关的时序故障集;两个故障集合并形成接口时序故障集;根据时序故障库中的故障类型,利用基于细粒度特征语义网络的方法,提取接口时序关键影响因素,形成嵌入式系统接口时序知识集。由此得到的嵌入式系统接口时序知识可实现测试知识的继承,且具有可扩展性,便于测试知识的推送,提升测试效率。

Patent Agency Ranking