一种指标数据获取方法、装置、电子设备和存储介质

基本信息

申请号 CN202110705948.7 申请日 -
公开(公告)号 CN113448752A 公开(公告)日 2021-09-28
申请公布号 CN113448752A 申请公布日 2021-09-28
分类号 G06F9/54(2006.01)I;G06F16/2455(2019.01)I 分类 计算;推算;计数;
发明人 鲁友炳;俞舒;吴迪;张镇潮;施建生 申请(专利权)人 亿企赢网络科技有限公司
代理机构 北京集佳知识产权代理有限公司 代理人 豆贝贝
地址 200131上海市浦东新区自由贸易试验区祥科路268号708室
法律状态 -

摘要

摘要 本申请公开了一种指标数据获取方法、装置、电子设备和存储介质,该方法包括:接收业务方发送的指标配置创建请求,并根据指标配置创建请求,生成控制流命令消息;将控制流命令消息发送至kafka消息队列,以使kafka消息队列广播控制流命令消息至flink算子;当接收到事件流消息时,将事件流消息发送至kafka消息队列,以使flink算子消费事件流消息;利用flink算子对事件流消息进行指标计算,确定指标数据。该方法对事件流消息进行指标计算的实时性较高,延迟性低,且能够有效降低对网络带宽和内存带来的压力。