(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211181631.9 (22)申请日 2022.09.27 (71)申请人 杭州安恒信息技 术股份有限公司 地址 310000 浙江省杭州市滨江区西兴街 道联慧街18 8号 (72)发明人 李素丽　范渊　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 任晓婷 (51)Int.Cl. G06F 16/22(2019.01) G06F 16/2455(2019.01) G06F 16/25(2019.01) G06F 16/28(2019.01) (54)发明名称 ES告警数据回填方法、 装置、 设备及 介质 (57)摘要 本申请公开了一种ES告警数据回填方法、 装 置、 设备及介质， 涉及计算机技术领域， 包括： 判 断当前是否存在预设写入失败信息； 若是则将 ETL引擎的当前告警数据写入预设消息发布订阅 系统； 当获取预设告警数据回填命令时， 校验所 述预设消息发布订阅系统是否满足预设连通性 条件； 若满足则从所述预设消息发布 订阅系统中 拉取所述当前告警数据， 将所述 当前告警数据回 填至预设ES的目标MySQL表。 通过上述方案， 当存 在写入失败信息时， 则说明当前没有将当前告警 数据成功写入预设ES中， 先将当前告警数据写入 预设消息发布 订阅系统， 当获取预设告警数据回 填命令时， 将当前告警数据回填至预设ES的目标 MySQL表， 提高告警数据成功写入预设ES的概率， 降低告警数据丢失的概 率。 权利要求书2页 说明书8页 附图3页 CN 115510064 A 2022.12.23 CN 115510064 A 1.一种ES告警数据回填方法， 其特 征在于， 包括： 判断当前 是否存在预设写入失败信息； 若是则将ETL引擎的当前告警数据写入预设消息发布订阅系统； 当获取预设告警数据回填命令时， 校验所述预设消息发布订阅系统是否满足预设连通 性条件； 若满足则从所述预设消息发布订阅系统中拉取所述当前告警数据， 并将所述当前告警 数据回填至预设ES的目标MySQ L表。 2.根据权利要求1所述的ES告警数据回填方法， 其特征在于， 所述判断当前是否存在预 设写入失败信息之前， 还 包括： 将ETL引擎的当前告警数据写入预设ES的目标 数据流中， 并生成对应的日志信息； 判断所述日志信 息是否表征所述当前告警数据已写入所述目标数据流中， 若否则生成 预设写入失败信息 。 3.根据权利要求1所述的ES告警数据回填方法， 其特征在于， 所述将ETL引擎的当前告 警数据写入预设消息发布订阅系统， 包括： 将ETL引擎的当前告警数据写入预设消息发布订阅系统的目标主题中； 相应的， 所述从所述预设消息发布订阅系统中拉取 所述当前告警数据， 包括： 从所述预设消息发布订阅系统的所述目标主题中拉取 所述当前告警数据。 4.根据权利要求1所述的ES告警数据回填方法， 其特征在于， 所述将ETL引擎的当前告 警数据写入预设消息发布订阅系统之后， 还 包括： 利用索引别名、 预设 分隔符和时间戳， 以得到所述当前告警数据的标识信息； 当需要将下一告警数据写入所述预设消息发布订 阅系统时， 则基于历史告警数据的标 识信息确定所述下一告警数据在所述预设消息发布订阅系统的目标位置 。 5.根据权利要求1至4任一项所述的ES告警数据回填方法， 其特征在于， 所述当获取预 设告警数据回填命令时， 校验所述预设消息发布订阅系统是否满足预设连通性条件之前， 还包括： 在预设数据中台中设置定时回填告警数据任务， 以便当执行所述定时回填告警数据任 务时， 生成预设告警数据回填命令 。 6.根据权利要求1所述的ES告警数据回填方法， 其特征在于， 所述从所述预设消息发布 订阅系统中拉取所述当前告警数据， 并将所述当前告警数据回填至预设ES的目标M ySQL表， 包括： 校验预设ES的集群健康状态是否满足预设条件， 若满足则从所述预设消息发布订阅系 统中拉取 所述当前告警数据； 将所述当前告警数据回填至目标MySQL表的数据列， 并在 所述目标MySQL表的时间列中 写入所述当前告警数据的回填时间。 7.根据权利要求6所述的ES告警数据回填方法， 其特征在于， 所述将所述当前告警数据 回填至目标MySQ L表之后， 还 包括： 判断当前是否满足预设定时清理告警数据的条件， 若满足则清理所述目标MySQL表与 预设时间段对应的告警数据。 8.一种ES告警数据回填装置， 其特 征在于， 包括：权　利　要　求　书 1/2 页 2 CN 115510064 A 2判断模块， 用于判断当前 是否存在预设写入失败信息； 写入模块， 用于若是则将ETL引擎的当前告警数据写入预设消息发布订阅系统； 校验模块， 用于当获取预设告警数据回填命令时， 校验所述预设消息发布订阅系统是 否满足预设连通 性条件； 回填模块， 用于若满足则从所述预设消息发布订阅系统中拉取所述当前告警数据， 并 将所述当前告警数据回填至预设ES的目标MySQ L表。 9.一种电子设备， 其特 征在于， 包括： 存储器， 用于保存计算机程序； 处理器， 用于执行所述计算机程序， 以实现如权利要求1至7任一项所述的ES告警数据 回填方法的步骤。 10.一种计算机可读存储介质， 其特征在于， 用于存储计算机程序； 其中， 所述计算机程 序被处理器执行时实现如权利要求1至7任一项所述的ES告警数据回填方法的步骤。权　利　要　求　书 2/2 页 3 CN 115510064 A 3