(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111658242.6 (22)申请日 2021.12.3 0 (71)申请人 亿阳信通股份有限公司 地址 150090 黑龙江省哈尔滨市南岗区嵩 山路高科技 开发区1号楼 (72)发明人 冯胜莉　宋双龙　杨美艳　 (51)Int.Cl. G06F 9/54(2006.01) G06F 21/60(2013.01) (54)发明名称 一种告警传输顺序的控制方法和装置 (57)摘要 本发明公开一种告警传输顺序的控制方法， 所述方法包含： 接收告警消息并进行统一格式转 化， 根据预置的告警样例在所述告警消息中识别 拼接出完整告警消息； 在所述完整告警消息中确 定关联告警组， 对所述关联告警组中告警的关键 字段进行加密获得与告警的关键字段取值； 根据 消息队列分区总数和所述告警的关键字段取值 确定所述告警在所述消息队列的分区值， 进而确 定传输所述告警的分区； 所述消息队列根据接收 告警的先后顺序和所述告警所在的分区传输告 警置。 本发 明还公开一种告警传输顺序的控制装 置。 通过本发 明可实现保证有序告警处理顺序的 同时并发处 理大量告警。 权利要求书2页 说明书6页 附图4页 CN 114296966 A 2022.04.08 CN 114296966 A 1.一种告警传输顺序的控制方法， 其特 征在于， 所述方法包括： 接收告警消息并进行统一格式转化， 根据 预置的告警样例在所述告警消息 中识别拼接 出完整告警消息； 在所述完整告警消息中确定关联告警组， 对所述关联告警组中告警的关键字段进行加 密获得与告警的关键 字段取值； 根据消息队列分区总数和所述告警的关键字段取值确定所述告警在所述消息队列的 分区值， 进 而确定传输所述告警的分区； 所述消息队列根据接收告警的先后顺序和所述告警所在的分区传输告警。 2.根据权利要求1所述的方法， 其特征在于， 所述接收告警数据并进行统一格式转化， 根据预置的告警样例在所述告警消息中识别拼接出完整 告警消息的方法具体为： 接收告警消息， 将不同数据格式的告警消息转 化为字符串格式的告警消息； 根据预置的告警样例中的告警头尾标志对告警消息进行截取； 将截取的告警消息拼接为完整 告警消息 。 3.根据权利要求2所述的方法， 其特征在于， 所述在所述完整告警消息中确定关联告警 组， 对所述关联告警组中告警的关键字段进 行加密获得与告警的关键字段取值的方法具体 为： 确定有序的且告警唯一标识一 致的所述完整 告警消息为所述关联告警组； 根据加密算法获得 所述关联告警组中告警的唯一标识取值。 4.根据权利要求3所述的方法， 其特征在于， 所述根据消息队列分区总数和所述告警的 关键字段取值确定所述告警在所述消息队列的分区值的方法具体为： 将所述告警的唯一标识取值对所述消息队列分区总数取模运算和绝对值运算的值确 定为所述告警在所述消息队列的分区值。 5.根据权利要求1 ‑4中任一所述的方法， 其特 征在于： 所述消息队列为 kafka消息队列。 6.一种告警传输顺序的控制装置， 其特 征在于， 所述装置包括： 完整告警消息获取单元， 用于接收告警消息并进行统一格式转化， 根据预置的告警样 例在所述告警消息中识别拼接出完整 告警消息； 取值计算单元， 用于在所述完整告警消息获取单元获取的完整告警消息 中确定关联告 警组， 对所述关联告警组中告警的关键 字段进行加密获得与告警的关键 字段取值； 分区确定单元， 用于根据消息队列分区总数和所述告警的关键字段取值确定所述告警 在所述消息队列的分区值， 进 而确定传输所述告警的分区； 传输单元， 所述消息队列用于根据接收告警的先后 顺序和所述告警所在的分区传输告 警。 7.根据权利要求6所述的装置， 其特 征在于， 所述完整 告警消息获取 单元进一步包括： 格式转化模块， 用于接收告警消息， 将不同数据格式的告警消息转化为字符串格式的 告警消息； 告警消息截取模块， 用于根据 预置的告警样例中的告警头尾标志对所述格式转换模块 转化的告警消息进行截取； 告警拼接模块， 用于将所述告警消息截取模块截取的告警消息拼接为完整 告警消息 。权　利　要　求　书 1/2 页 2 CN 114296966 A 28.根据权利要求7 所述的装置， 其特 征在于， 所述取值计算单 元进一步包括： 关联告警组确定模块， 用于确定有序的且告警唯一标识一致的所述完整告警消息为所 述关联告警组； 计算模块， 用于根据加密算法获得所述关联告警组确定模块确定的关联告警组中告警 的唯一标识取值。 9.根据权利要求8所述的装置， 其特 征在于： 所述分区确定单元将所述计算模块获得的告警的唯一标识取值对所述消息队列分区 总数取模运算和绝对值 运算的值确定为所述告警在所述消息队列的分区值。 10.根据权利要求6 ‑9所述的装置， 其特 征在于： 所述消息队列为 kafka消息队列。权　利　要　求　书 2/2 页 3 CN 114296966 A 3