CN113468025A - 一种数据告警方法、系统、装置及存储介质 - Google Patents
一种数据告警方法、系统、装置及存储介质 Download PDFInfo
- Publication number
- CN113468025A CN113468025A CN202110858060.7A CN202110858060A CN113468025A CN 113468025 A CN113468025 A CN 113468025A CN 202110858060 A CN202110858060 A CN 202110858060A CN 113468025 A CN113468025 A CN 113468025A
- Authority
- CN
- China
- Prior art keywords
- alarm
- data
- service
- service data
- alarm event
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000000034 method Methods 0.000 title claims abstract description 58
- 238000012545 processing Methods 0.000 claims description 24
- 230000006399 behavior Effects 0.000 claims description 12
- 238000004891 communication Methods 0.000 claims description 8
- 238000004590 computer program Methods 0.000 claims description 6
- 238000010586 diagram Methods 0.000 description 8
- 238000013480 data collection Methods 0.000 description 4
- 238000011161 development Methods 0.000 description 4
- 238000005516 engineering process Methods 0.000 description 3
- 230000005540 biological transmission Effects 0.000 description 2
- 230000003287 optical effect Effects 0.000 description 2
- 239000007787 solid Substances 0.000 description 2
- 230000001960 triggered effect Effects 0.000 description 2
- 230000006870 function Effects 0.000 description 1
- 238000012544 monitoring process Methods 0.000 description 1
- 239000013307 optical fiber Substances 0.000 description 1
- 239000004065 semiconductor Substances 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/3065—Monitoring arrangements determined by the means or processing involved in reporting the monitored data
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/32—Monitoring with visual or acoustical indication of the functioning of the machine
- G06F11/324—Display of status information
- G06F11/327—Alarm or error message display
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/22—Indexing; Data structures therefor; Storage structures
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Software Systems (AREA)
- Quality & Reliability (AREA)
- Data Mining & Analysis (AREA)
- Databases & Information Systems (AREA)
- Alarm Systems (AREA)
Abstract
本申请提供了一种数据告警方法、系统、装置及存储介质,涉及云计算技术领域,获取业务数据,并确定获取的业务数据的目标数据类型,调用与目标数据类型匹配的告警规则,若业务数据满足告警规则,则生成告警事件,按照指定的告警方式,将告警事件发送至对应的业务对象的终端设备。通过本申请中提供的数据告警方法,可以同时处理多种业务数据类型的告警任务。
Description
技术领域
本申请涉及云计算技术领域,更具体地说,涉及一种数据告警方法、系统、装置及存储介质。
背景技术
随着计算机网络技术的发展,企业中各种各样的业务在运行的过程中会产生大量的数据,如何将这些数据信息汇总,如何在海量的信息中选择有效的数据信息为企业业务后续的运行情况做出预估和判断已经成为互联网中关键的问题。
传统技术中只能针对单一场景采集的数据发出告警信息,无法处理复杂场景下采集的各种各样的业务数据,因此不能满足企业中多种业务同时运行等复杂场景的需要。
发明内容
为了解决上述现有技术中的问题,本申请实施例提供了一种数据告警方法,可以处理复杂场景下,多种业务数据类型的告警任务。
第一方面,本申请实施例提供了一种数据告警方法,所述方法包括:
获取所述业务数据,并确定获取的业务数据的目标数据类型;
调用与所述目标数据类型匹配的告警规则;
若所述业务数据满足所述告警规则,则生成告警事件;
按照指定的告警方式,将所述告警事件发送至对应的业务对象的终端设备。
在一种可能的实现方式中,所述获取所述业务数据,包括:
从消息队列中获取所述业务数据;所述业务数据为接收到业务处理设备发送的业务数据后存储在所述消息队列中的数据。
在一种可能的实现方式中,所述调用与所述目标数据类型匹配的告警规则,包括:
若所述业务数据的目标数据类型属于预设的数据类型,且所述目标数据类型对应的告警规则处于开启状态,则调用与所述目标数据类型匹配的告警规则。
在一种可能的实现方式中,所述指定的告警方式包括本地告警方式;所述按照指定的告警方式,将所述告警事件发送至对应的业务对象的终端设备,包括:
将所述告警事件保存至本地告警队列中;
若所述业务对象的账户处于在线状态,则从所述本地告警队列中提取所述告警事件,并通过局域网发送至所述业务对象的终端设备,以使所述终端设备将所述告警事件通过消息页面显示给所述业务对象;
将发送所述告警事件的行为信息保存至数据库中。
在一种可能的实现方式中,所述指定的告警方式包括插件告警方式;所述按照指定的告警方式,将所述告警事件发送至对应的业务对象的终端设备,包括:
将所述告警事件保存至插件告警队列中;
若当前时间未处于免打扰时间段,根据预先选定的通信插件将所述告警事件发送至所述业务对象的终端设备;
将发送所述告警事件的行为信息保存至数据库中。
第二方面,本申请实施例提供了一种数据告警系统,包括存储器和处理器,所述存储器上存储有可在所述处理器上运行的计算机程序,当所述计算机程序被所述处理器执行时,可以实现如下步骤:
所述处理器获取所述业务数据,并确定获取的业务数据的目标数据类型;
调用与所述目标数据类型匹配的告警规则;
若所述业务数据满足所述告警规则,则生成告警事件;
按照指定的告警方式,将所述告警事件发送至对应的业务对象的终端设备。
在一种可能的实现方式中,所述系统还包括数据采集模块;
所述数据采集模块用于接收所述业务处理设备发送的业务数据,并将所述业务数据发送至所述存储器内的消息队列中。
第三方面,本申请实施例提供了一种数据告警装置,包括:
获取单元,用于获取所述业务数据,并确定获取的业务数据的目标数据类型;
调用单元,用于调用与所述目标数据类型匹配的告警规则;
生成单元,用于若所述业务数据满足所述告警规则,则生成告警事件;
告警单元,用于按照指定的告警方式,将所述告警事件发送至对应的业务对象的终端设备。
在一种可能的实现方式中,所述获取单元,还用于:
从消息队列中获取所述业务数据;所述业务数据为接收到业务处理设备发送的业务数据后存储在所述消息队列中的数据。
在一种可能的实现方式中,所述调用单元,还用于:
若所述业务数据的目标数据类型属于预设的数据类型,且所述目标数据类型对应的告警规则处于开启状态,则调用与所述目标数据类型匹配的告警规则。
在一种可能的实现方式中,所述告警单元,还用于:
将所述告警事件保存至本地告警队列中;
若所述业务对象的账户处于在线状态,则从所述本地告警队列中提取所述告警事件,并通过局域网发送至所述业务对象的终端设备,以使所述终端设备将所述告警事件通过消息页面显示给所述业务对象;
将发送所述告警事件的行为信息保存至数据库中。
在一种可能的实现方式中,所述告警单元,还用于:
将所述告警事件保存至插件告警队列中;
若当前时间未处于免打扰时间段,根据预先选定的通信插件将所述告警事件发送至所述业务对象的终端设备;
将发送所述告警事件的行为信息保存至数据库中。
第四方面,本申请实施例提供了一种计算机可读存储介质,其上存储有计算机程序指令,当所述计算机程序指令被处理器执行时实现第一方面中任一项数据告警方法的步骤。
本申请实施例提供的数据告警方法,获取业务数据,并确定获取的业务数据的目标数据类型,调用与目标数据类型匹配的告警规则,若业务数据满足告警规则,则生成告警事件,按照指定的告警方式,将告警事件发送至对应的业务对象的终端设备。通过本申请中提供的数据告警方法,可以同时处理多种业务数据类型的告警任务。
附图说明
为了更清楚地说明本申请实施例中的技术方案,下面将对实施例描述中所需要使用的附图作简要介绍,显而易见地,下面描述中的附图仅仅是本申请的一些实施例,对于本领域的普通技术人员来讲,在不付出创造性劳动性的前提下,还可以根据这些附图获得其他的附图。
图1为本申请实施例提供的一种数据告警方法的流程示意图;
图2为本申请实施例提供的一种质量类型的业务数据的示意图;
图3为本申请实施例提供的一种调用告警规则的流程示意图;
图4为本申请实施例提供的一种通过本地告警方式发送告警事件的流程示意图;
图5为本申请实施例提供的一种通过插件告警方式发送告警事件的流程示意图;
图6为本申请实施例提供的一种数据告警系统的结构示意图;
图7为本申请实施例提供的一种数据告警装置的结构示意图。
具体实施方式
为了使本申请的目的、技术方案和优点更加清楚,下面将结合附图对本申请作进一步地详细描述,显然,所描述的实施例仅仅是本申请一部分实施例,而不是全部的实施例。基于本申请中的实施例,本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其它实施例,都属于本申请保护的范围。
需要说明的是,本申请的文件中涉及的术语“包括”和“具有”以及它们的变形,意图在于覆盖不排他的包含,例如,包含了一系列步骤或单元的过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或单元,而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或单元。
为了解决复杂场景下,多种业务数据类型的告警任务,提高处理告警任务的效率,本申请实施例提出了一种数据告警方法、系统、装置及存储介质,获取业务数据,并确定获取的业务数据的目标数据类型,调用与目标数据类型匹配的告警规则,若业务数据满足告警规则,则生成告警事件,按照指定的告警方式,将告警事件发送至对应的业务对象的终端设备。通过本申请中提供的数据告警方法,可以同时处理多种业务数据类型的告警任务。
本申请中的数据告警方法应用于服务器,图1示出了本申请实施例提供的一种数据告警方法的流程示意图,应用于服务器。其中,服务器以数据中台为依托实现实时监控和采集业务数据,发出告警以完成告警任务,保证业务可以顺利完成。数据中台可以实现实时采集、治理、存储、查询、展示数据,并搭载数据智能引擎,高效积累数据资产,赋能业务应用场景,助力企业构建扎实的数据根基,实现数字化经营。
如图1所示,本申请实施例提供的数据告警方法包括如下步骤:
步骤S101,获取业务数据,并确定获取的业务数据的目标数据类型。
服务器中的处理器会以主动调用的方式获取存储器中的业务数据,业务数据在上传时包括数据格式,由处理器调用业务数据之后,会根据业务数据中包括的数据格式确定数据类型,数据类型包括:接入类型、开发类型、质量类型等。
在一种可能的实施例中,图2示出了一种质量类型的业务数据的示意图,以质量类型业务数据的数据格式为例,处理器在获取到质量类型的业务数据之后,根据图2中的数据可以确定获取到的业务数据的类型为质量类型,以此对业务数据进行后续的处理。图2中的业务数据信息包括:告警一级来源、告警二级来源、项目ID、实例ID、告警对象名称、告警对象ID、告警数据、上报时间。
在一种可能的实施例中,步骤S101还包括:从消息队列中获取业务数据,务数据为接收到业务处理设备发送的业务数据后存储在所述消息队列中的数据。
其中,业务数据是由布置在各处的业务处理设备采集并主动上报到服务器的数据采集模块中,在由数据采集模块将业务数据存储在服务器的储存器的消息队列内,服务器中的处理器主动获取消息队列中的业务数据,并对业务数据进行处理。存储器的消息队列可以基于卡夫卡(KAFKA)消息队列的方式实现。
处理器处理KAFKA消息队列的业务数据,对于处理过业务数据的过程,会将处理进度记录在数据库中,保证在某一业务数据满足告警规则,生成告警事件之后,保证处理器可以根据这一业务数据的在消息队列中的指定位置继续对后续的业务数据进行处理,对于所有业务数据的处理有且仅有一次,采用KAFKA消息队列构建了数据采集模块与处理器之间传输实时业务数据的管道,进而将数据采集模块与处理器解耦,在新增多个业务处理设备采集数据并发送到数据采集模块时,使得处理器也不会因为突然新增大量数据而陷入瘫痪,保证了服务器的稳定性。
在另一种可能的实施方式中,可以添加数据上报模块,若出现运行失败的业务流程,则由业务处理设备采集之后,将数据发送到数据上报模块中,非运行失败的业务流程的业务数据,则由业务处理设备采集之后,发送到数据采集模块。服务器中的处理器可以直接获取数据上报模块中的业务数据,由于数据上报模块中的业务数据均为业务流程运行失败时采集的数据,所以确定业务数据的类型后,可以根据数据类型以及业务数据中的信息,直接生成告警事件,并根据指定的告警方式将告警事件发送至对应的业务对象的终端设备。
步骤S102:调用与目标数据类型匹配的告警规则。
处理器根据业务数据中包括的数据格式确定数据类型,在存储器中存储着针对各种场景告警任务的告警规则,处理器确定数据类型之后,从储存器中调用与数据类型匹配的告警规则,在一个告警规则中可以配置监控的业务对象、触发告警的业务逻辑、告警信息的接收人、告警方式、推送告警方式的次数、推送间隔以及免打扰时间段等。
在一种可能的实施例中,处理器获取到图2中的业务数据之后,不仅可以确定数据类型,还可以确定告警源、项目ID、告警对象、具体的告警数据、业务数据上报时间等信息。处理器确定获取到的业务数据为质量类型业务数据,同时根据确定的上述信息,调用针对于质量类型业务数据的告警规则。
在一种可能的实施例中,如图3所示,调用与目标数据类型匹配的告警规则,包括:
步骤S301:获取业务数据。
步骤S302:判断业务数据的目标数据类型是否属于预设的数据类型。若是,则进行步骤S303,若否,则结束。
步骤S303:判断目标数据类型对应的告警规则是否处于开启状态。若是,则进行步骤S304,若否,则结束。
步骤S304:调用与目标数据类型匹配的告警规则。
步骤S305:判断业务数据是否满足告警规则。若是,则进行步骤S306,若否,则结束。
步骤S306:生成告警事件。
示例性地,若处理器获取的为质量类型的业务数据,而在服务器中仅配置了接入类型和开发类型这两种数据类型的告警规则,那么在判断此次业务数据的目标数据类型是否属于预设的数据类型时,判断的结果则为否,即,结束,并且此条业务数据的处理过程会记录在数据库中,根据判断结果,记录此条业务数据不在服务器处理业务数据的数据类型范围内,则继续处理下一条业务数据。
若处理器获取的为接入类型的业务数据,而在服务器中仅配置了接入类型和开发类型这两种数据类型的告警规则,则目标数据类型属于预设的数据类型。若此次接入类型的业务数据中包含的信息为某一天停车场中的停车数量,而正常的停车数量可能为300,则与此业务数据对应的告警规则可能为停车数量不超过350,若超过,则证明车辆的接入数量不符合要求,则满足告警规则,从而生成告警事件,触发告警。而此次业务数据中包含的信息为停车数量为500,满足告警规则,但是这天恰好是学生参观本企业,那么停车场中的停车数量超过350则为正常现象,那么此条告警规则在这一天则可以选择停止开启,业务数据中包含的信息为停车数量为500,也不会触发告警。这一天,判断目标数据类型对应的告警规则是否处于开启状态,判断结果则为未处于开启状态,进程结束,并且此条业务数据的处理过程会记录在数据库中,根据判断结果,记录此条业务数据不在服务器处理业务数据的数据类型范围内,则继续处理下一条业务数据。
若不在这一天,此业务数据对应的告警规则开启,业务数据中包含的信息为停车数量为500,此业务数据对应的告警规则可能为停车数量不超过350,则满足告警规则的触发条件。
根据图3中示出的调用告警规则的流程示意图,成功调用与目标数据类型匹配的告警规则之后,进行步骤S103。
步骤S103:若业务数据满足告警规则,则生成告警事件。
判断业务数据中的信息满足预设的告警规则,则生成告警事件,告警事件中可以包括告警源、具体的业务数据、业务数据上报时间、告警信息的接收人、告警方式、推送告警方式的次数等信息。
在一种可能的实施例中,若获取的业务数据类型为图2中的质量类型的业务数据,告警规则可以配置为检测某个物理模型的数据质量周期表达式运行结果,当运行出现失败时,则证明该业务中的数据可能存在质量问题,则生成告警事件,产生告警。告警事件可以包括运行结果失败的源头、具体的业务数据、业务数据上报时间等。
步骤S104:按照指定的告警方式,将告警事件发送至对应的业务对象的终端设备。
在业务流程运行的过程中,业务对象可以选择指定的告警方式,在业务流程运行出现问题时,可以接收服务器发送的告警事件,业务对象可以根据告警事件处理业务流程。指定的告警方式包括:本地告警方式以及插件告警方式。业务对象选择哪种告警方式,服务器就会通过哪种告警方式将告警事件发送至业务对象的终端设备。业务对象可以为企业内部的工作人员。
在一种可能的实施例中,如图4所示,若业务对象指定的告警方式为本地告警方式,包括:
步骤S401:将告警事件保存至本地告警队列中。
步骤S402:从本地告警队列中提取告警事件。
步骤S403:判断业务对象的账户是否处于在线状态。若是,则进行步骤S404,若否,回到步骤S403。
步骤S404:通过局域网发送至业务对象的终端设备,以使终端设备将告警事件通过消息页面显示给业务对象。
步骤S405:将发送告警事件的行为信息保存至数据库中。
其中,在本地告警队列中提取告警事件之后,根据这一告警事件建立发送告警事件的任务线程,只针对这一告警事件建立的任务线程,并不影响其余告警事件的发送。告警事件中包括接收告警事件的业务对象的账户,判断业务对象的账户是否处于在线状态,若处于在线状态,服务器则可以通过一种在单个TCP(Transmission Control Protocol,传输控制协议)连接上进行全双工通信的协议将告警事件直接推送至业务对象的账户中。在业务对象的客户端收到告警事件之后,会一消息页面的形式在客户端的显示屏上显示几秒,这里的显示时长可以在选择告警方式时一起进行选择,并将告警事件插入业务对象客户端的本地未处理列表中。最后将发送告警事件的行为信息保存至数据库中。
在一种可能的实施例中,如图5所示,若业务对象指定的告警方式为插件告警方式,包括:
步骤S501:将告警事件保存至插件告警队列中。
步骤S502:判断当前时间是否处于免打扰时间段,若否,则进行步骤S503,若是,则回到步骤S502。
步骤S503:根据预先选定的通信插件将告警事件发送至业务对象的终端设备。
步骤S504:将发送告警事件的行为信息保存至数据库中。
其中,将告警事件保存至插件告警队列之后,服务器会判断当前时间段是否处于免打扰时间段,这里的免打扰时间段可以为下班时间、午休时间、节假日时间等,若当前时间是处于免打扰时间段,则暂时不向业务对象的终端设备发送告警事件,若当前时间是不处于免打扰时间段,则根据预先选定的通信插件将告警事件发送至业务对象的终端设备。通信插件可以包括多种,如手机短信、邮件、电话等类型的插件。最后将发送告警事件的行为信息保存至数据库中。
在一种可选的实施例中,可以同时选择两种告警方式。具体地说,在生成告警事件之后,在采用图4所示的本地告警方式将告警事件发送至业务对象的账户的同时,处理器判断除本地告警方式以外,指定的告警方式是否包括插件告警方式,若存在,则再以图5所示的插件告警方式的方式将告警事件发送至业务对象的终端设备中。
与上述方法实施例相对应地,本申请实施例还提供了一种数据告警系统,该数据告警系统可以为服务器,也可以为电子设备或者多个电子设备,该数据告警系统至少包括用于存储数据的存储器和处理器,其中,对于用于数据处理的处理器而言,在执行处理时,可以采用微处理器、CPU、GPU(Graphics Processing Unit,图形处理单元)、DSP或FPGA实现。对于存储器来说,存储器中存储有操作指令,该操作指令可以为计算机可执行代码,通过该操作指令来实现上述本申请实施例的数据告警方法的流程中的各个步骤。
在一种可能的实施例中,数据告警系统还包括数据采集模块;
数据采集模块用于接收业务处理设备发送的业务数据,并将业务数据发送至所述存储器内的消息队列中。
图6为本申请实施例提供的一种数据告警系统的结构示意图。如图6所示,数据告警系统600包括存储器601、处理器602、数据采集模块603和总线604。该存储器601、处理器602和数据采集模块603均通过总线604连接,该总线604用于该存储器601、处理器602和数据采集模块603之间传输数据。
其中,存储器601可用于存储软件程序以及模块,处理器602通过运行存储在存储器601中的软件程序以及模块,从而执行数据告警系统600的各种功能应用以及数据处理,如本申请实施例提供的数据告警方法。存储器601可主要包括存储程序区和存储数据区,其中,存储程序区可存储操作系统、至少一个应用的应用程序等;存储数据区可存储根据数据告警系统600的使用所创建的数据等。此外,存储器601可以包括高速随机存取存储器,还可以包括非易失性存储器,例如至少一个磁盘存储器件、闪存器件、或其他易失性固态存储器件。
处理器602是数据告警系统600的控制中心,利用总线604以及各种接口和线路连接整个数据告警系统600的各个部分,通过运行或执行存储在存储器601内的软件程序和/或模块,以及调用存储在存储器601内的数据,执行数据告警系统600的各种功能和处理数据。可选的,处理器602可包括一个或多个处理单元,如CPU、GPU(Graphics ProcessingUnit,图形处理单元)、数字处理单元等。
本申请实施例还提供了一种数据告警装置。图7为本申请实施例提供的一种数据告警装置的结构示意图;如图7所示,该数据告警装置包括:
获取单元701,用于获取业务数据,并确定获取的业务数据的目标数据类型;
调用单元702,用于调用与目标数据类型匹配的告警规则;
生成单元703,用于若业务数据满足所述告警规则,则生成告警事件;
告警单元704,用于按照指定的告警方式,将告警事件发送至对应的业务对象的终端设备。
在一种可能的实现方式中,获取单元701,还用于:
从消息队列中获取业务数据;业务数据为接收到业务处理设备发送的业务数据后存储在消息队列中的数据。
在一种可能的实现方式中,调用单元702,还用于:
若业务数据的目标数据类型属于预设的数据类型,且目标数据类型对应的告警规则处于开启状态,则调用与目标数据类型匹配的告警规则。
在一种可能的实现方式中,告警单元704,还用于:
将告警事件保存至本地告警队列中;
若业务对象的账户处于在线状态,则从本地告警队列中提取告警事件,并通过局域网发送至业务对象的终端设备,以使终端设备将告警事件通过消息页面显示给业务对象;
将发送告警事件的行为信息保存至数据库中。
在一种可能的实现方式中,告警单元704,还用于:
将告警事件保存至插件告警队列中;
若当前时间未处于免打扰时间段,根据预先选定的通信插件将告警事件发送至业务对象的终端设备;
将发送告警事件的行为信息保存至数据库中。
本申请实施例还提供了一种计算机存储介质,该计算机存储介质中存储有计算机可执行指令,该计算机可执行指令用于实现本申请任一实施例所记载的游戏控制方法。
所述程序产品可以采用一个或多个可读介质的任意组合。可读介质可以是可读信号介质或者可读存储介质。可读存储介质例如可以是——但不限于——电、磁、光、电磁、红外线、或半导体的系统、装置或器件,或者任意以上的组合。可读存储介质的更具体的例子(非穷举的列表)包括:具有一个或多个导线的电连接、便携式盘、硬盘、随机存取存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或闪存)、光纤、便携式紧凑盘只读存储器601(CD-ROM)、光存储器件、磁存储器件、或者上述的任意合适的组合。
以上所述,仅为本申请的具体实施方式,但本申请的保护范围并不局限于此,任何熟悉本技术领域的技术人员在本申请揭露的技术范围内,可轻易想到变化或替换,都应涵盖在本申请的保护范围之内。
Claims (10)
1.一种数据告警方法,其特征在于,所述方法包括:
获取所述业务数据,并确定获取的业务数据的目标数据类型;
调用与所述目标数据类型匹配的告警规则;
若所述业务数据满足所述告警规则,则生成告警事件;
按照指定的告警方式,将所述告警事件发送至对应的业务对象的终端设备。
2.根据权利要求1所述的方法,其特征在于,所述获取所述业务数据,包括:
从消息队列中获取所述业务数据;所述业务数据为接收到业务处理设备发送的业务数据后存储在所述消息队列中的数据。
3.根据权利要求1所述的方法,其特征在于,所述调用与所述目标数据类型匹配的告警规则,包括:
若所述业务数据的目标数据类型属于预设的数据类型,且所述目标数据类型对应的告警规则处于开启状态,则调用与所述目标数据类型匹配的告警规则。
4.根据权利要求1所述的方法,其特征在于,所述指定的告警方式包括本地告警方式;所述按照指定的告警方式,将所述告警事件发送至对应的业务对象的终端设备,包括:
将所述告警事件保存至本地告警队列中;
若所述业务对象的账户处于在线状态,则从所述本地告警队列中提取所述告警事件,并通过局域网发送至所述业务对象的终端设备,以使所述终端设备将所述告警事件通过消息页面显示给所述业务对象;
将发送所述告警事件的行为信息保存至数据库中。
5.根据权利要求1所述的方法,其特征在于,所述指定的告警方式包括插件告警方式;所述按照指定的告警方式,将所述告警事件发送至对应的业务对象的终端设备,包括:
将所述告警事件保存至插件告警队列中;
若当前时间未处于免打扰时间段,根据预先选定的通信插件将所述告警事件发送至所述业务对象的终端设备;
将发送所述告警事件的行为信息保存至数据库中。
6.一种数据告警系统,其特征在于,包括存储器和处理器,所述存储器上存储有可在所述处理器上运行的计算机程序,当所述计算机程序被所述处理器执行时,可以实现如下步骤:
所述处理器获取所述业务数据,并确定获取的业务数据的目标数据类型;
调用与所述目标数据类型匹配的告警规则;
若所述业务数据满足所述告警规则,则生成告警事件;
按照指定的告警方式,将所述告警事件发送至对应的业务对象的终端设备。
7.根据权利要求6所述的系统,其特征在于,所述系统还包括数据采集模块;
所述数据采集模块用于接收所述业务处理设备发送的业务数据,并将所述业务数据发送至所述存储器内的消息队列中。
8.一种数据告警装置,其特征在于,包括:
获取单元,用于获取所述业务数据,并确定获取的业务数据的目标数据类型;
调用单元,用于调用与所述目标数据类型匹配的告警规则;
生成单元,用于若所述业务数据满足所述告警规则,则生成告警事件;
告警单元,用于按照指定的告警方式,将所述告警事件发送至对应的业务对象的终端设备。
9.根据权利要求8所述的装置,其特征在于,所述调用单元,还用于:
若所述业务数据的目标数据类型属于预设的数据类型,且所述目标数据类型对应的告警规则处于开启状态,则调用与所述目标数据类型匹配的告警规则。
10.一种计算机可读存储介质,其上存储有计算机程序指令,其特征在于,当所述计算机程序指令被处理器执行时实现如权利要求1-5中任一项所述的方法。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202110858060.7A CN113468025A (zh) | 2021-07-28 | 2021-07-28 | 一种数据告警方法、系统、装置及存储介质 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202110858060.7A CN113468025A (zh) | 2021-07-28 | 2021-07-28 | 一种数据告警方法、系统、装置及存储介质 |
Publications (1)
Publication Number | Publication Date |
---|---|
CN113468025A true CN113468025A (zh) | 2021-10-01 |
Family
ID=77882960
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202110858060.7A Pending CN113468025A (zh) | 2021-07-28 | 2021-07-28 | 一种数据告警方法、系统、装置及存储介质 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN113468025A (zh) |
Cited By (4)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN113900755A (zh) * | 2021-10-11 | 2022-01-07 | 重庆紫光华山智安科技有限公司 | 告警页面处理方法、装置、计算机设备及可读存储介质 |
CN113947437A (zh) * | 2021-10-25 | 2022-01-18 | 同程网络科技股份有限公司 | 数据处理方法、装置、电子设备及介质 |
CN114386035A (zh) * | 2021-12-31 | 2022-04-22 | 航天信息股份有限公司 | 一种检测威胁数据的方法、装置及电子设备 |
CN115225459A (zh) * | 2022-07-14 | 2022-10-21 | 杭州指令集智能科技有限公司 | 一种适用于高并发海量设备的低延时设备告警方法 |
Citations (6)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN109871399A (zh) * | 2019-01-28 | 2019-06-11 | 中船重工鹏力(南京)大气海洋信息系统有限公司 | 一种分布式的告警规则引擎设计方法 |
WO2020029407A1 (zh) * | 2018-08-08 | 2020-02-13 | 平安科技(深圳)有限公司 | 告警数据的管理方法、装置、计算机设备及存储介质 |
CN111354174A (zh) * | 2018-12-24 | 2020-06-30 | 中移(杭州)信息技术有限公司 | 一种告警方法、装置、服务器及可读存储介质 |
CN111385148A (zh) * | 2020-03-06 | 2020-07-07 | 深圳鼎盛电脑科技有限公司 | 业务告警方法、装置、计算机设备及存储介质 |
CN112052134A (zh) * | 2020-07-21 | 2020-12-08 | 北京奇艺世纪科技有限公司 | 一种业务数据的监控方法及装置 |
WO2021008414A1 (zh) * | 2019-07-17 | 2021-01-21 | 深圳市智物联网络有限公司 | 一种物联网设备的告警方法及相关装置 |
-
2021
- 2021-07-28 CN CN202110858060.7A patent/CN113468025A/zh active Pending
Patent Citations (6)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
WO2020029407A1 (zh) * | 2018-08-08 | 2020-02-13 | 平安科技(深圳)有限公司 | 告警数据的管理方法、装置、计算机设备及存储介质 |
CN111354174A (zh) * | 2018-12-24 | 2020-06-30 | 中移(杭州)信息技术有限公司 | 一种告警方法、装置、服务器及可读存储介质 |
CN109871399A (zh) * | 2019-01-28 | 2019-06-11 | 中船重工鹏力(南京)大气海洋信息系统有限公司 | 一种分布式的告警规则引擎设计方法 |
WO2021008414A1 (zh) * | 2019-07-17 | 2021-01-21 | 深圳市智物联网络有限公司 | 一种物联网设备的告警方法及相关装置 |
CN111385148A (zh) * | 2020-03-06 | 2020-07-07 | 深圳鼎盛电脑科技有限公司 | 业务告警方法、装置、计算机设备及存储介质 |
CN112052134A (zh) * | 2020-07-21 | 2020-12-08 | 北京奇艺世纪科技有限公司 | 一种业务数据的监控方法及装置 |
Non-Patent Citations (2)
Title |
---|
SEYED ALI MIRHEIDARI 等: "Alert Correlation Algorithms: A Survey and Taxonomy", ARXIV:1181.00921, 30 November 2018 (2018-11-30), pages 1 - 15 * |
郝鹏海 等: "基于Kafka和Kubernetes的云平台监控告警系统", 计算机系统应用, no. 08, 15 August 2020 (2020-08-15), pages 121 - 126 * |
Cited By (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN113900755A (zh) * | 2021-10-11 | 2022-01-07 | 重庆紫光华山智安科技有限公司 | 告警页面处理方法、装置、计算机设备及可读存储介质 |
CN113900755B (zh) * | 2021-10-11 | 2024-04-16 | 重庆紫光华山智安科技有限公司 | 告警页面处理方法、装置、计算机设备及可读存储介质 |
CN113947437A (zh) * | 2021-10-25 | 2022-01-18 | 同程网络科技股份有限公司 | 数据处理方法、装置、电子设备及介质 |
CN114386035A (zh) * | 2021-12-31 | 2022-04-22 | 航天信息股份有限公司 | 一种检测威胁数据的方法、装置及电子设备 |
CN115225459A (zh) * | 2022-07-14 | 2022-10-21 | 杭州指令集智能科技有限公司 | 一种适用于高并发海量设备的低延时设备告警方法 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN113468025A (zh) | 一种数据告警方法、系统、装置及存储介质 | |
CN112311617A (zh) | 一种配置化数据监控告警方法及系统 | |
CN110347694B (zh) | 一种基于物联网的设备监控方法、装置及系统 | |
CN113347269A (zh) | 一种工业系统的数据更新方法、电子设备和存储介质 | |
CN114996085A (zh) | 一种基于Prometheus的实时业务监控方法和系统 | |
CN110009273B (zh) | 信息处理方法及装置、存储介质、电子装置 | |
CN110865921A (zh) | 数据监控方法、装置、可读存储介质和电子设备 | |
CN114298799A (zh) | 订单信息的展示方法、装置、存储介质及计算机设备 | |
US20180139160A1 (en) | Method, system and server for removing alerts | |
CN110888790B (zh) | 日志管理方法及装置、电子设备、存储介质 | |
CN111274047A (zh) | 信息处理方法、终端、系统、计算机设备和存储介质 | |
CN113901153B (zh) | 数据处理方法及相关设备 | |
CN110401570B (zh) | 告警方法、装置、系统、设备及可读存储介质 | |
CN113098978B (zh) | 一种数据传输方法、装置及介质 | |
CN113965563B (zh) | 基于模型的业务处理方法及装置、服务器 | |
CN114553944A (zh) | 预警消息推送方法和系统 | |
CN110611576B (zh) | 一种数据质量监测方法、装置、设备及存储介质 | |
CN115766696A (zh) | 一种文件上传方法、装置、电子设备及存储介质 | |
CN112925659A (zh) | 消息处理方法、装置、设备及计算机存储介质 | |
CN111815466A (zh) | 交易流量控制方法、装置、设备及可读存储介质 | |
CN111400156A (zh) | 日志分析方法和装置 | |
CN117155755B (zh) | 一种告警信息处理方法、装置、电子设备和存储介质 | |
CN112434894A (zh) | 一种实时风险控制方法、计算机设备及可读存储介质 | |
CN112785739B (zh) | 签到处理方法、计算机设备及可读存储介质 | |
CN112714057B (zh) | 即时消息处理方法、装置、设备及存储介质 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination |