公开(公告)号：CN118644966A

公开(公告)日：2024-09-13

申请号：CN202410459706.8

申请日：2024-04-17

申请人： 郑州大学

发明人： 杨海波 ,  梁黄陶钧 ,  盛朋飞 ,  罗子仪 ,  蔡迎春 ,  余波 ,  徐鹏 ,  刘心怡 ,  黎杰

IPC分类号： G08B31/00 ,  G08B21/10 ,  H04L67/1008 ,  G06F16/25 ,  G06N3/0442 ,  G06N3/006 ,  G06N3/08

摘要： 本发明属于防灾减灾技术领域，公开了基于Flink与任务调度优化的滑坡灾害多源监测数据集成方法，包括：从监测区域获取原始监测数据并进行预处理，获取监测数据，将不同数据库不同数据结构的监测数据转换为预设格式的目标数据，搭建Flink集群以流计算的形式将目标数据从各个数据库集成至目标数据库，基于改进PSO的任务调度优化算法收集系统信息，统计Flink集群每个节点的资源性能数据，获取每个节点的负载数据，构建LSTM模型，对Flink集群的负载情况进行预测分析，根据负载分析的结果，使用粒子群优化算法对Flink集群进行任务调度优化，并进行优化前后对比分析。本发明实现对灾害多源异构监测数据实时集成。