一种基于实时查询的数据交互方法及装置

    公开(公告)号:CN112650915B

    公开(公告)日:2023-03-10

    申请号:CN202011375913.3

    申请日:2020-11-30

    Abstract: 本发明提供一种基于实时查询的数据交互方法及装置,包括:解析接收的客户端数据查询请求,判断所述客户端数据查询请求为长查询或短查询;若为长查询,则依据生成的查询记录对数据库进行查询,并将长查询结果存储至分布式文件系统中;若为短查询,则通过转换得到的系统sql语句对数据库进行查询,得到短查询结果;将获取的长查询结果或短查询结果返回至客户端。本发明支持短查询和长查询两种不同的请求方式,可以根据业务的紧急程度做不同速度的处理;短查询可以跳过中间系统直接访问数据源并返回结果数据,以达到更快的速度;长查询的结果以较小单位依次返回给请求方达到更高的时效性。

    面向复杂混部扰动的在线运行时环境预测方法及装置

    公开(公告)号:CN116910467A

    公开(公告)日:2023-10-20

    申请号:CN202310691596.3

    申请日:2023-06-12

    Abstract: 本发明公开了一种面向复杂混部扰动的在线运行时环境预测方法及装置,该方法包括:针对训练集中的算子,分别收集每一算子和多个算子在空节点上运行时的环境关键指标Ts和环境关键指标Tm;基于该关键指标Ts和环境关键指标Tm,分别建立算子的算子画像和多个算子的画像;基于算子的算子画像和多个算子的画像,训练环境预测模型;获取待检测的混部算子中每一算子的算子画像,并将每一算子的算子画像输入训练后的环境预测模型,以得到待检测的混部算子在空节点上运行时的环境关键指标。本发明可以实时恶意流量检测,有效缓解、过滤和防御针对恶意流量的攻击。本发明能够准确预测复杂混部算子运行时环境。

    一种基于消费队列的数据交换方法及系统

    公开(公告)号:CN112637130A

    公开(公告)日:2021-04-09

    申请号:CN202011378206.X

    申请日:2020-11-30

    Abstract: 本发明提供一种基于消费队列的数据交换方法及系统,包括:接收外网服务器发送的客户端数据查询请求;解析客户端数据查询请求,将得到的订阅任务发送至元数据库,以得到消费队列;转换接收的内部订阅任务数据,将得到的外部订阅任务数据经外网服务器返回至相应客户端,其中所述内部订阅任务数据是通过消费客户端消费消息队列而得到。本发明客户端与内网订阅服务通过HTTP交互,不直接接触MQ数据;可通过客户端循环请求,获取数据。

    一种数据过滤前置的数据交换方法及系统

    公开(公告)号:CN112650767B

    公开(公告)日:2023-03-10

    申请号:CN202011378190.2

    申请日:2020-11-30

    Abstract: 本发明提供一种数据过滤前置的数据交换方法及系统,包括:接收外网服务器发送的客户端数据查询请求,其中所述客户端数据查询请求根据设定过滤规则生成;解析客户端数据查询请求,将得到的任务发送至元数据库,以得到内部数据;转换接收的内部数据,将得到的外部数据经外网服务器返回至相应客户端。本发明因为数据过滤由数据交换系统内部进行,所以客户端只能接到符合过滤规则的数据,从而保障数据安全,降低了客户端的资源消耗。

    基于算子作用域动态感知的弹性资源分配方法及装置

    公开(公告)号:CN115016928A

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

    申请号:CN202210431141.3

    申请日:2022-04-22

    Abstract: 本发明公开了一种基于算子作用域动态感知的弹性资源分配方法及装置。所述方法包括:构建数据流处理应用的有向无环图,所述有向无环图中的节点表示处理数据流的算子,边表示数据流;根据算子的静态筛选率指标和动态筛选率统计指标来评估上游算子的作用域,自适应地将有向无环图进行分区。预测每个分区未来一段时间的负载;针对每个所述分区中的各算子,基于所述负载生成相应数量的算子实例,以对所述接收数据进行实时处理,满足服务质量要求。本发明以分区为单位规划算子的并行性,从而保证端到端处理延迟,提升资源利用率。

    一种数据过滤前置的数据交换方法及系统

    公开(公告)号:CN112650767A

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

    申请号:CN202011378190.2

    申请日:2020-11-30

    Abstract: 本发明提供一种数据过滤前置的数据交换方法及系统,包括:接收外网服务器发送的客户端数据查询请求,其中所述客户端数据查询请求根据设定过滤规则生成;解析客户端数据查询请求,将得到的任务发送至元数据库,以得到内部数据;转换接收的内部数据,将得到的外部数据经外网服务器返回至相应客户端。本发明因为数据过滤由数据交换系统内部进行,所以客户端只能接到符合过滤规则的数据,从而保障数据安全,降低了客户端的资源消耗。

    一种基于实时查询的数据交互方法及装置

    公开(公告)号:CN112650915A

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

    申请号:CN202011375913.3

    申请日:2020-11-30

    Abstract: 本发明提供一种基于实时查询的数据交互方法及装置,包括:解析接收的客户端数据查询请求,判断所述客户端数据查询请求为长查询或短查询;若为长查询,则依据生成的查询记录对数据库进行查询,并将长查询结果存储至分布式文件系统中;若为短查询,则通过转换得到的系统sql语句对数据库进行查询,得到短查询结果;将获取的长查询结果或短查询结果返回至客户端。本发明支持短查询和长查询两种不同的请求方式,可以根据业务的紧急程度做不同速度的处理;短查询可以跳过中间系统直接访问数据源并返回结果数据,以达到更快的速度;长查询的结果以较小单位依次返回给请求方达到更高的时效性。

Patent Agency Ranking