(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210799253.4 (22)申请日 2022.07.08 (65)同一申请的已公布的文献号 申请公布号 CN 114860510 A (43)申请公布日 2022.08.05 (73)专利权人 飞狐信息技 术 （天津） 有限公司 地址 300280 天津市滨 海新区经济开发区 第一大街79号泰达MSD-C区C3座21层 2012单元 (72)发明人 赵路　张益军　王金明　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 李慧引 (51)Int.Cl. G06F 11/14(2006.01)G06F 16/2455(2019.01) (56)对比文件 CN 113254231 A,2021.08.13 CN 113722187 A,2021.1 1.30 CN 109783 538 A,2019.0 5.21 CN 114153688 A,2022.03.08 CN 112511339 A,2021.0 3.16 WO 2020078385 A1,2020.04.23 CN 111078488 A,2020.04.28 审查员 李慧芳 (54)发明名称 微服务系统的数据监控方法和系统 (57)摘要 本申请提供一种微服务系统的数据监控方 法和系统， 应用于含存储节点和多个采集节点的 数据监控系统， 采集节点采集微服务系统的指标 数据； 每一指标数据均被至少两个采集节点采 集； 存储节点存储指标数据； 存储节点响应查询 请求， 在存储的指标数据中查询指标数据。 现有 部分时序数据库 （如Prometheus） 重启后会向内 存加载数据， 导致一段时间不可用。 本方案将指 标数据的采集和存储分给不同节 点， 且采集节点 有多个， 既避免采集节点重启 后加载数据， 使采 集节点重启后立即恢复采集， 又使多个采集节点 的数据互为备份， 任一采集节 点宕机不影响指标 数据的完整， 提高数据监控系统的可用性。 权利要求书2页 说明书10页 附图3页 CN 114860510 B 2022.12.02 CN 114860510 B 1.一种微服务系统 的数据监控方法， 其特征在于， 应用于数据监控系统， 所述数据监控 系统包括采集节点和存 储节点， 所述采集节点的数量 为多个， 所述方法包括： 各个所述采集节点分别采集对应类别的所述微服务系统的指标数据； 其中， 不同类别 的指标数据的名称的开头字符不同； 且每一类别的指标数据均被至少两个所述采集节点采 集； 所述存储节点从采集节点采集的指标数据中筛除重复的指标数据， 并存储去重后的指 标数据； 所述存储节点响应查询请求， 在存储的指标数据中查询满足所述查询请求的指标数 据； 其中， 所述从采集节点采集的指标数据中筛除重复的指标数据， 包括： 对于存储节点每 接收到一条当前指标数据， 识别所述指标数据在前n秒钟内是否存在重复的数据； 若存在， 则将所述当前指标 数据删除； 若未存在， 将之后的n秒钟内收到的重复数据删除。 2.根据权利要求1所述的方法， 其特征在于， 所述存储节点的数量为多个， 多个所述存 储节点中有至少一个主存 储节点和至少一个备存 储节点； 所述存储节点存 储所述采集节点采集的所述指标 数据， 包括： 所述主存 储节点和所述备存 储节点均存 储所述采集节点采集的所述指标 数据； 所述存储节点响应查询请求， 在存储的指标数据中查询满足所述查询请求的指标数 据， 包括： 所述主存储节点可用时， 所述主存储节点响应查询请求， 在存储的指标数据中查询满 足所述查询请求的指标 数据； 所述主存储节点不可用时， 所述备存储节点响应查询请求， 在存储的指标数据中查询 满足所述 查询请求的指标 数据。 3.根据权利要求2所述的方法， 其特 征在于， 多个所述存 储节点均和代理服 务器连接； 所述主存储节点响应查询 请求， 在存储的指标数据中查询满足所述查询 请求的指标数 据之前， 还 包括： 所述代理服 务器确定所述主存 储节点可用； 所述代理服 务器将接收的查询请求发送给 所述主存 储节点； 所述备存储节点响应查询 请求， 在存储的指标数据中查询满足所述查询 请求的指标数 据之前， 还 包括： 所述代理服 务器确定所述主存 储节点不可用； 所述代理服 务器将接收的查询请求发送给 所述备存 储节点。 4.根据权利要求3所述的方法， 其特 征在于， 所述主存 储节点的数量 为多个； 所述代理服 务器将接收的查询请求发送给 所述主存 储节点， 包括： 所述代理服 务器确定每一个所述主存 储节点的负载； 所述代理服 务器将接收的查询请求发送给负载最低的所述主存 储节点。 5.一种微服务系统 的数据监控系统， 其特征在于， 包括采集节点和存储节点， 所述采集 节点的数量 为多个； 各个所述采集节点用于分别采集对应类别的所述微服务系统的指标数据； 其中， 不同 类别的指标数据的名称的开头字符不同； 且每一类别的指标数据均被至少两个所述采集节权　利　要　求　书 1/2 页 2 CN 114860510 B 2点采集； 所述存储节点用于从采集节点采集的指标数据中筛除重复的指标数据， 并存储去重后 的指标数据； 所述存储节点用于响应查询请求， 在存储的指标数据中查询满足所述查询 请求的指标 数据； 其中， 所述从采集节点采集的指标数据中筛除重复的指标数据， 包括： 对于存储节点每 接收到一条当前指标数据， 识别所述指标数据在前n秒钟内是否存在重复的数据； 若存在， 则将所述当前指标 数据删除； 若未存在， 将之后的n秒钟内收到的重复数据删除。 6.根据权利要求5所述的系统， 其特征在于， 所述存储节点的数量为多个， 多个所述存 储节点中有至少一个主存 储节点和至少一个备存 储节点； 所述主存 储节点和所述备存 储节点均用于存 储所述采集节点采集的所述指标 数据； 所述主存储节点可用时， 所述主存储节点用于响应查询请求， 在存储的指标数据中查 询满足所述 查询请求的指标 数据； 所述主存储节点不可用时， 所述备存储节点用于响应查询请求， 在存储的指标数据中 查询满足所述 查询请求的指标 数据。 7.根据权利要求6所述的系统， 其特征在于， 所述系统还包括和多个所述存储节点连接 的代理服 务器； 所述代理服 务器用于： 确定所述主存 储节点可用； 将接收的查询请求发送给 所述主存 储节点； 或者用于： 确定所述主存 储节点不可用； 将接收的查询请求发送给 所述备存 储节点。 8.根据权利要求7 所述的系统， 其特 征在于， 所述主存 储节点的数量 为多个； 所述代理服 务器将接收的查询请求发送给 所述主存 储节点时， 具体用于： 所述代理服 务器确定每一个所述主存 储节点的负载； 所述代理服 务器将接收的查询请求发送给负载最低的所述主存 储节点。权　利　要　求　书 2/2 页 3 CN 114860510 B 3