服务状态监测方法、装置、电子设备及可读存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN110750426A(43)申请公布日2020.02.04(21)申请号201911048254.X(22)申请日2019.10.30(71)申请人北京明朝万达科技股份有限公司地址100097北京市海淀区蓝靛厂南路25号嘉友国际大厦北区2层(72)发明人王少飞王志海喻波董晓斌安鹏(74)专利代理机构北京润泽恒知识产权代理有限公司11319代理人莎日娜(51)Int.Cl.G06F11/30(2006.01)权利要求书2页说明书8页附图2页(54)发明名称服务状态监测方法、装置、电子设备及可读存储介质(57)摘要本申请实施例提供了一种服务状态监测方法、装置、电子设备及可读存储介质，所述方法包括：所述Filebeat根据监控的服务数量，配置对应数量的日志监听输入源；所述Filebeat通过对每个日志监听输入源分别配置正则表达式，将每个日志监听输入源监控的服务所产生的运行日志进行过滤，以得到错误日志和告警日志；所述Filebeat根据所述异常类型标识，将所述错误日志和所述告警日志发送至对应的Kafka队列；所述Kafka根据不同的Kafka队列，将所述错误日志和所述告警日志分发至相应的处理程序中，以执行相应的操作；以帮助运维人员自动检测各个服务的状态并及时做出相应操作，避免了问题的遗留、堆积。节约了人力成本，提高了系统的运维效率。CN110750426ACN110750426A权利要求书1/2页1.一种服务状态监测方法，应用于服务状态监测系统，所述服务状态检测系统包括：Filebeat和Kafka，其特征在于，所述方法包括：所述Filebeat根据监控的服务数量，配置对应数量的日志监听输入源；所述Filebeat通过对每个日志监听输入源分别配置正则表达式，将每个日志监听输入源监控的服务所产生的运行日志进行过滤，以得到错误日志和告警日志；其中，所述错误日志和所述告警日志均携带异常类型标识；所述Filebeat根据所述异常类型标识，将所述错误日志和所述告警日志发送至对应的Kafka队列；所述Kafka根据不同的Kafka队列，将所述错误日志和所述告警日志分发至相应的处理程序中，以执行相应的操作。2.根据权利要求1所述的方法，其特征在于，在所述Filebeat根据监控的服务数量，配置对应数量的日志监听输入源之后，所述方法还包括：所述Filebeat在目标日志监听输入源配置长时间未上报日志监听策略，以得到长时间未上报的日志；其中，所述目标监听输入源监控目标服务，所述长时间未上报的日志携带所述异常类型标识；所述Filebeat将所述长时间未上报的日志内的无活动行为服务的路径与所述目标服务的日志路径进行匹配；其中，所述目标服务的日志路径预先配置在所述Filebeat中；在所述长时间未上报的日志内的无活动行为服务的路径与所述目标服务的日志路径匹配成功的情况下，所述Filebeat根据所述异常类型标识，将所述长时间未上报的日志发送至对应的Kafka队列；所述Kafka根据不同的Kafka队列，将所述长时间未上报的日志分发至相应的处理程序中，以执行相应的操作。3.根据权利要求2所述的方法，其特征在于，所述Filebeat在目标日志监听输入源配置长时间未上报日志监听策略，包括：所述Filebeat在所述目标日志监听输入源配置对应的所述目标服务的closeinactive数值。4.根据权利要求2所述的方法，其特征在于，所述方法还包括：所述Filebeat将所述错误日志、所述告警日志和所述长时间未上报的日志中的至少一者发送至存储设备中，以便于运维人员的追溯和查看。5.根据权利要求2所述的方法，其特征在于，所述Kafka根据不同的队列，将所述错误日志和所述告警日志分发至相应的处理程序中，以执行相应的操作，包括：所述Kafka根据不同的Kafka队列，将所述错误日志和所述告警日志分发至相应的处理程序中，以对应执行发送异常邮件的操作以及记录相同服务类型的告警日志的告警次数，在所述告警次数超过预设阈值的情况下，发送告警邮件的操作；其中，所述告警日志携带所述服务类型的标识。6.根据权利要求2所述的方法，其特征在于，所述Kafka根据不同的队列，将所述长时间未上报的日志分发至相应的处理程序中，以执行相应的操作，包括：所述Kafka根据不同的Kafka队列，将所述长时间未上报的日志分发至相应的处理程序中，以执行调用重启命令或脚本的操作。2CN110750426A权利要求书2/2页7.一种服务状态监测装置，应用于服务状态监测系统，所述服务状态检测系统包括：Filebeat和Kafka，其特征在于，所述装置包括：第一配置模块，用于所述Filebeat根据监控的服务数量，配置对应数量的日志监听输入源