买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉云筑信息科技(成都)有限公司申请的专利一种基于实时流框架的自定义指标生成方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN119862093B 。

龙图腾网通过国家知识产权局官网在2025-08-05发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202510356267.2，技术领域涉及：G06F11/30；该发明授权一种基于实时流框架的自定义指标生成方法是由张科;吴俊雄;张勇设计研发完成，并于2025-03-25向国家知识产权局提交的专利申请。

本一种基于实时流框架的自定义指标生成方法在说明书摘要公布了：本发明公开了一种基于实时流框架的自定义指标生成方法，包括接收指标数据形成指标数据流；接收指标规则形成指标规则流；将指标规则流转换为指标规则广播流；将指标数据流与指标规则广播流合并，匹配出满足不同指标规则的指标数据，判断匹配出的指标数据是单指标数据还是关联指标数据；采用指标规则中的计算表达式对单指标数据关联指标数据进行计算，得到单指标值关联指标值；基于指标规则中的指标计算类型对单指标值关联指标值进行计算，得到指标值；将每个指标值和对应的指标名称、事件关联标识和指标数据的指标时间合并为一个告警指标上报至数据库。本发明以flink框架为基础提供一种新的处理逻辑，实现自定义指标的生成和告警行为。

本发明授权一种基于实时流框架的自定义指标生成方法在权利要求书中公布了：1.一种基于实时流框架的自定义指标生成方法，其特征在于，包括以下步骤： S1、接收接口上报的指标数据，通过flink形成指标数据流；所述指标数据包括指标时间； S2、接收由服务端推送至kafka中的指标规则，形成指标规则流；所述指标规则为自定义，包括指标名称、匹配事件、事件关联标识、计算表达式和指标计算类型； S3、将指标规则流转换为指标规则广播流并定义广播状态； S4、将指标数据流与指标规则广播流合并，通过广播状态对指标数据流中的指标数据与指标规则流中的指标规则进行匹配，匹配出满足不同指标规则的指标数据，判断匹配出的指标数据是单指标数据还是关联指标数据；当指标规则的匹配事件包含一个，满足对应指标规则的指标数据为单指标数据；当指标规则的匹配事件包含多个，满足对应指标规则的指标数据为关联指标数据； S5、采用指标规则中的计算表达式对单指标数据关联指标数据进行计算，得到单指标值关联指标值，将单指标值关联指标值和对应的指标规则合并为单指标事件与规则合并流关联指标事件与规则合并流； 所述S5中，关联指标数据的计算方法包括：S51，对于匹配成功的每一条关联指标数据，按照对应指标规则的事件关联标识进行分组，每个分组用于缓存同一事件关联标识的关联指标数据；S52，计算每个分组中关联指标数据的关联指标值，关联指标值包括第一关联指标值或和第二关联指标值； 第一关联指标值和第二关联指标值的计算方法为：在分组过程中，通过缓存于分组中的第一条关联指标数据得到第一关联指标值，所述第一关联指标值等于-1；当每一组所有的关联指标数据缓存于分组后，将当前分组中的所有关联指标数据按照对应匹配指标规则的计算表达式进行计算，得到第二关联指标值； S6、根据指标规则判断单指标事件与规则合并流关联指标事件与规则合并流的指标计算类型，根据指标计算类型对单指标值关联指标值进行计算，得到上报指标值； S7、将每个上报指标值和对应的指标名称、事件关联标识和指标时间合并为一个告警指标上报至数据库中； 所述S7中，设定一个滚动时间窗口，每个滚动时间窗口内上报告警指标； 优先得到包含第一关联指标值的告警指标并上报到数据库中，再产生包含第二关联指标值的最新告警指标并上报到数据库时：先根据指标名称查询告警指标是否上报过，如果上报过并且指标值为-1，则删除之前上报的告警指标再保存上报的最新告警指标；否则一直保存包含等于-1的第一关联指标值的告警指标。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人云筑信息科技(成都)有限公司，其通讯地址为：610095 四川省成都市高新区天府二街151号1栋1单元36层；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。