数据处理方法、装置及计算机可读存储介质.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115994154A(43)申请公布日2023.04.21(21)申请号202111216659.7(22)申请日2021.10.19(71)申请人中国联合网络通信集团有限公司地址100033北京市西城区金融大街21号(72)发明人程命沆周远阳陈宇光张灿茂陈淇徐吉园王佳成蔡方义白一珂(74)专利代理机构北京同立钧成知识产权代理有限公司11205专利代理师杨泽刘芳(51)Int.Cl.G06F16/2455(2019.01)G06F16/27(2019.01)G06F16/242(2019.01)G06F16/182(2019.01)权利要求书2页说明书12页附图3页(54)发明名称数据处理方法、装置及计算机可读存储介质(57)摘要本申请提供了一种数据处理方法、装置及计算机可读存储介质，可以支持流数据的计算，同时提升了数据处理效率和数据处理的实时性。该方法包括：根据运营商的业务需求，确定至少一个网络设备；根据至少一个网络设备的坐标和泰森多边形算法，构建泰森多边形，得到目标区域；基于Flink流处理架构，获取该目标区域内至少一个网络设备在通信过程中产生的信令数据；基于Flink的功能接口，对上述信令数据进行处理，得到至少一个处理结果，该处理包括过滤、聚合、状态更新、映射、连接或分组中的至少一个；向至少一个处理结果中满足预设条件的处理结果对应的目标网络设备发送指示信息，该指示信息用于指示目标网络设备触发预警。CN115994154ACN115994154A权利要求书1/2页1.一种数据处理方法，其特征在于，包括：根据运营商的业务需求，确定至少一个网络设备；根据所述至少一个网络设备的坐标和泰森多边形算法，构建泰森多边形，得到目标区域；基于Flink流处理架构，获取所述目标区域内所述至少一个网络设备在通信过程中产生的信令数据；基于Flink的功能接口，对所述信令数据进行处理，得到至少一个处理结果，所述处理包括过滤、聚合、状态更新、映射、连接或分组中的至少一个；向所述至少一个处理结果中满足预设条件的处理结果对应的目标网络设备发送指示信息，所述指示信息用于指示所述目标网络设备触发预警。2.根据权利要求1所述的方法，其特征在于，所述预设条件包括下列至少一个：所述目标区域内的用户总数量大于或等于第一预设阈值，所述用户总数量为与所述至少一个网络设备中每个网络设备对应的终端设备的数量之和；存在用户在所述目标区域内的滞留时间大于或等于第二预设阈值；或者，存在用户首次进入所述目标区域。3.根据权利要求1所述的方法，其特征在于，所述基于Flink的功能接口，对所述信令数据进行处理，得到至少一个处理结果，包括：根据预设条件对所述信令数据进行过滤，得到目标信令数据；根据预设方式对所述目标信令数据进行合并，得到所述至少一个处理结果，所述至少一个处理结果对应至少一个固定时间段。4.根据权利要求1所述的方法，其特征在于，所述根据所述至少一个网络设备的坐标和泰森多边形算法，构建所述待监控区域的泰森多边形，得到目标区域，包括：根据所述至少一个网络设备的坐标，构建三角网，所述三角网中包括多个三角形；分别获取与所述至少一个网络设备中每个网络设备相邻的三角形；对与所述每个网络设备相邻的所述三角形进行排序；确定所述多个三角形的外接圆圆心；按照所述至少一个网络设备中每个网络设备相邻的所述三角形的排序，依次连接所述每个网络设备相邻的所述三角形的外接圆圆心，得到所述泰森多边形。5.根据权利要求1所述的方法，其特征在于，所述信令数据包括实时的信令数据和非实时的信令数据；所述基于Flink的功能接口，对所述信令数据进行处理，得到至少一个处理结果，包括：对所述实时的信令数据执行过滤、状态更新或聚合中的至少一个操作；对所述非实时的信令数据执行映射、连接或分组中的至少一个操作。6.根据权利要求1至5中任一项所述的方法，其特征在于，所述Flink的功能接口包括：程序功能接口，用于对一个或者多个数据流进行时间和状态的细粒度控制；数据流或数据集功能接口，用于实现数据流的转换；结构化查询语言SQL功能接口，用于通过SQL进行数据的解析、验证和查询优化。7.一种数据处理装置，其特征在于，包括：处理模块，用于根据运营商的业务需求，确定至少一个网络设备；以及，根据所述至少2CN115994154A权利要求书2/2页一个网络设备的坐标和泰森多边形算法，构建泰森多边形，得到目标区域；获取模块，用于基于Flink流处理架构，获取所述目标区域内所述至少一个网络设备在通信过程中产生的信令数据；所述处理模块还用于：基于Flink的功能接口，对所述信令数据进行处理，得到至少一个处理结果，所述处理包括过滤、聚合、状态更新、映射、连接或分组中的至少一个；发送模