一种基于流式计算的大数据平台动态指标评价方法和系统

    公开(公告)号:CN117312391B

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

    申请号:CN202311372877.9

    申请日:2023-10-23

    Abstract: 本发明公开了一种基于流式计算的大数据平台动态指标评价方法,其首先获取待评价的多个指标数据,并将其存入消息队列,接着对消息队列中的指标数据进行读取,再使用转换函数得到格式化的指标数据;随后使用聚合函数作为评价分析算子对格式化的指标数据进行聚合窗口处理和阈值处理分析,以获取多个处理后的指标数据;然后针对多个处理后的指标数据中的各项指标生成对应的规则文件,由此所有规则文件共同构成预警规则文本数据;再将预警规则文本数据存入消息队列;接着再使用流式处理引擎的广播处理函数对获取的指标数据以及规则数据处理。本发明能够解决现有大数据平台动态指标评价方法存在的代码的冗余且复杂,复用性差,代码修改繁琐的技术问题。

    一种基于流式计算的大数据平台动态指标评价方法和系统

    公开(公告)号:CN117312391A

    公开(公告)日:2023-12-29

    申请号:CN202311372877.9

    申请日:2023-10-23

    Abstract: 本发明公开了一种基于流式计算的大数据平台动态指标评价方法,其首先获取待评价的多个指标数据,并将其存入消息队列,接着对消息队列中的指标数据进行读取,再使用转换函数得到格式化的指标数据;随后使用聚合函数作为评价分析算子对格式化的指标数据进行聚合窗口处理和阈值处理分析,以获取多个处理后的指标数据;然后针对多个处理后的指标数据中的各项指标生成对应的规则文件,由此所有规则文件共同构成预警规则文本数据;再将预警规则文本数据存入消息队列;接着再使用流式处理引擎的广播处理函数对获取的指标数据以及规则数据处理。本发明能够解决现有大数据平台动态指标评价方法存在的代码的冗余且复杂,复用性差,代码修改繁琐的技术问题。

Patent Agency Ranking