CN114827168A - Alarm aggregation reporting method and device, computer equipment and storage medium - Google Patents

Abstract

The embodiment of the invention discloses an alarm aggregation reporting method, an alarm aggregation reporting device, computer equipment and a storage medium. The application relates to the technical field of alarming, which comprises: regularly inquiring whether a preset database has a main node or not; if the main node does not exist in the preset database, selecting one slave node from the plurality of slave nodes through an optimistic lock mechanism of the preset database as the main node, and setting the effective lease time of the main node as preset lease time; regularly inquiring whether the host node meets a renewal condition; if the main node meets the lease renewal condition, acquiring the current time, and resetting the effective lease time according to the current time and the preset lease time; if the main node receives the alarm information within the effective lease time, the alarm information is aggregated within the preset alarm aggregation time according to the alarm strategy to obtain aggregated information, and the aggregated information is reported to related personnel. The embodiment of the application can reduce the alarm frequency and improve the overall effectiveness of the alarm.

Description

Alarm aggregation reporting method, device, computer equipment and storage medium

technical field

Embodiments of the present invention relate to the technical field of alarms, and in particular, to a method, apparatus, computer equipment, and storage medium for aggregated reporting of alarms.

Background technique

With the development of Internet technology, the microservice architecture has gradually become the mainstream of the Internet architecture. Correspondingly, the alarm service architecture adapted to the microservice architecture is also evolving. The main problem of the alarm service in the existing technology is alarm Flooding, alarm flooding refers to the generation of a large number of alarms in a short period of time. On the one hand, the flooding of alarms will cause serious alarms to be overwhelmed by general alarms, so that the operation and maintenance personnel cannot find the fault; on the other hand, it will also increase the cost of sending massive alarm information. The overall effectiveness of the alert is thus reduced.

SUMMARY OF THE INVENTION

Embodiments of the present invention provide a method, device, computer equipment and storage medium for aggregated reporting of alarms, aiming to solve the problem of low overall effectiveness of existing alarms.

In a first aspect, an embodiment of the present invention provides an alarm aggregation reporting method, which includes:

Regularly query whether there is a master node in the preset database;

If the master node does not exist in the preset database, select a slave node from a plurality of slave nodes as the master node through the optimistic locking mechanism of the preset database, and use the effective locking mechanism of the master node. The lease time is set to the preset lease time;

If the master node exists in the preset database, regularly query whether the master node satisfies the lease renewal condition;

If the master node satisfies the lease renewal condition, obtain the current time, and reset the valid lease time according to the current time and the preset lease time;

If the master node receives the alarm information within the valid lease period, the master node aggregates the alarm information according to the alarm policy within the preset alarm aggregation time to obtain aggregated information, and reports the aggregated information to the relevant personnel.

In a second aspect, an embodiment of the present invention further provides an alarm aggregation reporting device, which includes:

a first query unit, used for regularly querying whether there is a master node in the preset database;

The selection unit is configured to select a slave node from a plurality of slave nodes as the master node through the optimistic locking mechanism of the preset database if the master node does not exist in the preset database, and select all slave nodes as the master node. The valid lease time of the master node is set to the preset lease time;

a second query unit, configured to periodically query whether the master node satisfies the lease renewal condition if the master node exists in the preset database;

a setting unit, configured to obtain the current time if the master node satisfies the lease renewal condition, and reset the valid lease time according to the current time and the preset lease time;

The aggregation reporting unit is configured to, if the master node receives alarm information within the valid lease period, aggregate the alarm information according to an alarm policy within a preset alarm aggregation time to obtain aggregated information, and aggregate all the alarm information. The aggregated information is reported to the relevant personnel.

In a third aspect, an embodiment of the present invention further provides a computer device, which includes a memory and a processor, the memory stores a computer program, and the processor implements the above method when executing the computer program.

In a fourth aspect, an embodiment of the present invention further provides a computer-readable storage medium, where the storage medium stores a computer program, and the computer program can implement the foregoing method when executed by a processor.

Embodiments of the present invention provide a method, apparatus, computer equipment, and storage medium for alarm aggregation reporting. Wherein, the method includes: regularly querying whether a master node exists in a preset database; if the master node does not exist in the preset database, selecting from a plurality of slave nodes through an optimistic locking mechanism of the preset database Select a slave node as the master node, and set the effective lease period time of the master node to the preset lease period time; if the master node exists in the preset database, regularly query whether the master node is Satisfy the lease renewal condition; if the master node satisfies the lease renewal condition, obtain the current time, and reset the valid lease period time according to the current time and the preset lease period time; If the master node receives the alarm information within the valid lease period, it aggregates the alarm information according to the alarm policy within the preset alarm aggregation time to obtain aggregated information, and reports the aggregated information to the relevant personnel. In the technical solution of the embodiment of the present invention, a slave node is selected from a plurality of nodes as the master node, and a valid lease period is set for the master node; Aggregating alarm information can reduce the number of alarms and improve the overall effectiveness of alarms.

Description of drawings

In order to explain the technical solutions of the embodiments of the present invention more clearly, the following briefly introduces the accompanying drawings used in the description of the embodiments. Obviously, the drawings in the following description are some embodiments of the present invention, which are of great significance to the art For those of ordinary skill, other drawings can also be obtained from these drawings without any creative effort.

FIG. 1 is a schematic flowchart of an alarm aggregation reporting method provided by an embodiment of the present invention;

FIG. 2 is a schematic block diagram of an apparatus for reporting alarm aggregation provided by an embodiment of the present invention; and

FIG. 3 is a schematic block diagram of a computer device according to an embodiment of the present invention.

Detailed ways

The technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are part of the embodiments of the present invention, but not all of the embodiments. Based on the embodiments of the present invention, all other embodiments obtained by those of ordinary skill in the art without creative efforts shall fall within the protection scope of the present invention.

It is to be understood that, when used in this specification and the appended claims, the terms "comprising" and "comprising" indicate the presence of the described features, integers, steps, operations, elements and/or components, but do not exclude one or The presence or addition of a number of other features, integers, steps, operations, elements, components, and/or sets thereof.

It is also to be understood that the terminology used in this specification of the present invention is for the purpose of describing particular embodiments only and is not intended to limit the present invention. As used in this specification and the appended claims, the singular forms "a," "an," and "the" are intended to include the plural unless the context clearly dictates otherwise.

It should further be understood that, as used in this specification and the appended claims, the term "and/or" refers to and including any and all possible combinations of one or more of the associated listed items .

As used in this specification and the appended claims, the term "if" may be contextually interpreted as "when" or "once" or "in response to determining" or "in response to detecting" . Similarly, the phrases "if it is determined" or "if the [described condition or event] is detected" may be interpreted, depending on the context, to mean "once it is determined" or "in response to the determination" or "once the [described condition or event] is detected. ]" or "in response to detection of the [described condition or event]".

Please refer to FIG. 1 . FIG. 1 is a schematic flowchart of an alarm aggregation reporting method provided by an embodiment of the present invention. The alarm aggregation reporting method according to the embodiment of the present invention can be applied to terminals, such as smart terminal devices such as smart phones, laptops, desktop computers, and notebook computers, and the alarm aggregation reporting method is implemented by software installed on the server. This reduces the number of alarms and improves the overall effectiveness of the alarms. The following describes the alarm aggregation reporting method in detail. As shown in FIG. 1, the method includes the following steps S100-S140.

S100, regularly query whether there is a master node in the preset database.

In this embodiment of the present invention, before aggregating alarm information to obtain aggregated information and reporting the aggregated information, it is necessary to regularly query whether a master node exists in a preset database, where the preset database is a TDSQL database. It should be noted that, in this embodiment of the present invention, querying whether there is a master node in the TDSQL database, that is, querying whether the number of the master nodes is 0 or whether the lease period of the master node has expired.

S110. If the master node does not exist in the preset database, select a slave node from a plurality of slave nodes as the master node through the optimistic locking mechanism of the preset database, and assign the master node to the master node. The valid lease time for is set to the preset lease time.

In the embodiment of the present invention, if the master node does not exist in the preset database, indicating that the number of master nodes is 0 or the lease period of the master node has expired, the optimistic locking mechanism of the TDSQL database is used. One slave node is selected from a plurality of slave nodes as the master node. Specifically, if the master node does not exist in the TDSQL database, each slave node will send the IP address and port information to the TDSQL database for registration in the TDSQL database, and the TDSQL The database allows only one slave node to register successfully through the optimistic locking mechanism, and informs the slave node whether the registration is successful through the return value. Understandably, in practical applications, if the return value received by the slave node is Master, indicating that the slave node is successfully registered, the slave node is used as the master node; if the return value received by the slave node is the master node; If it is Slave, indicating that the slave node is registered and identified, the slave node will continue to be the slave node. After a slave node is selected from a plurality of slave nodes as the master node, the effective lease period time of the master node needs to be set as a preset lease period time, wherein the preset lease period time is 60s.

It should be noted that, in this embodiment of the present invention, after the effective lease time is set on the master node, multiple slave nodes will also periodically query whether the lease period of the master node exceeds the preset lease If the lease period of the master node exceeds the preset lease period time, indicating that the master node does not exist in the preset database, then return to executing the step of regularly querying whether there is a master node in the preset database, to re-select the new primary node.

S120. If the master node exists in the preset database, regularly query whether the master node satisfies the lease renewal condition.

In this embodiment of the present invention, if the master node exists in the preset database, indicating that the number of master nodes is not 0 and the lease period of the master node has not expired, the master node is periodically queried whether The lease renewal condition is satisfied, wherein the lease renewal condition is that the effective lease period time of the master node is less than the preset lease renewal time threshold. It should be noted that, in this embodiment of the present invention, the value of the preset lease renewal time threshold is related to the lease renewal time of the regular query. For example, if the lease renewal time of the regular query is 10s, the preset lease renewal time requires If the setting is greater than 10s, it is necessary to ensure that the lease of the master node is renewed before the lease period of the master node expires.

S130. If the master node satisfies the lease renewal condition, obtain the current time, and reset the valid lease time according to the current time and the preset lease time.

In this embodiment of the present invention, if the master node satisfies the lease renewal condition, the current time is obtained, and the preset lease time is added to the current time to obtain the master node's Valid lease period time. Specifically, for example, if it is assumed that the current time is 12:12 on April 1, 2022, and the preset lease period is 60s, that is, 1 minute, then the preset lease period is April 1, 2022 12:13.

S140. If the master node receives alarm information within the valid lease period, the master node aggregates the alarm information according to an alarm policy within a preset alarm aggregation time to obtain aggregated information, and reports the aggregated information to the relevant personnel.

In this embodiment of the present invention, if the master node receives alarm information within the valid lease period, the master node identifies the alarm policy according to a preset policy identifier. Understandably, the master node can receive information from all The alarm information sent by the slave node can also be directly received from the service service; if the alarm policy is the first alarm policy, the first alarm policy is used within the preset alarm aggregation time according to the first alarm policy. Aggregate the alarm information to obtain aggregated information, wherein the preset alarm aggregation time is 60s, and the first alarm policy is the default alarm policy; if the alarm policy is the second alarm policy, the preset alarm policy is set in the preset alarm policy. The alarm information is aggregated according to the second alarm policy within the alarm aggregation time to obtain the aggregated information, wherein the second alarm policy is a threshold alarm policy, and the policy is suitable for alarms whose urgency is not high and needs to be Continue to pay attention to the alarm scenario of the alarm information within a period of time; if the alarm policy is the third alarm policy, aggregate the alarm information according to the third alarm policy within the preset alarm aggregation time to obtain the aggregation information, wherein the third alarm strategy is a multiple alarm strategy, and the strategy is suitable for application scenarios where the urgency of the alarm is moderate. It should be noted that, in this embodiment of the present invention, the aggregated information reports information such as the number of alarms, the time of the last alarm, and the cause of the alarm.

Further, the first alarm strategy is specifically to determine whether the alarm information is received for the first time; if the alarm information is received for the first time, the time when the alarm information is received is used as the start alarm time, for example It is 12:30 on April 1, 2022, and the number of alarms is set to 1; if the alarm information is not received for the first time and within the preset alarm aggregation time, the number of alarms is updated, and the number of alarms is set to 1. The number of alarms is compared with the first threshold of the number of alarms, where the first threshold of number of alarms N1 is 5; if the number of alarms is not greater than the threshold of the first number of alarms, the received alarm information is reported to The relevant personnel; on the contrary, if the number of alarms is greater than the threshold of the first number of alarms, the received alarm information will be saved, that is, from 12:30 on April 1, 2022 to April 2022 During the period of 12:31 on the 1st, the number of alarms is greater than the alarm information corresponding to the first threshold of the number of alarms; after the preset alarm aggregation time of 60s arrives, it will start from the start alarm time The time after the preset alarm aggregation time is taken as the alarm end time, for example, at 12:31 on April 1, 2022, and the alarm end time and the last alarm in the preset alarm aggregation time are calculated. If the time difference is 10s and the preset time threshold is 20s, when the time difference of 10s is less than the preset time threshold of 20s, it means that the alarm continues, then The preset alarm aggregation time is reassigned to 120s, and the alarm information received from the alarm end time and within the preset alarm aggregation time period is saved, that is, 2022 is saved. The alarm information received during the period from 12:31 on April 1, 2022 to 12:32 on April 1, 2022; the alarm end time is taken as the start alarm time, and the execution returns After the preset alarm aggregation time arrives, the time from the start alarm time and after the preset alarm aggregation time is taken as the alarm end time; the cycle is executed until the time difference is not less than the preset alarm aggregation time. Time threshold, for example, if the time difference is 25s greater than the preset time threshold of 20s, then aggregate all the unreported alarm information to obtain aggregated information, and report the aggregated information to relevant personnel. Understandably, the second alarm strategy needs to report N1 plus 1 alarm.

Further, the second alarm policy is specifically to count the number of times of the received alarm information within the preset alarm aggregation time to obtain the total number of alarms; if the total number of alarms is greater than the second threshold of the number of alarms, then The alarm information is aggregated to obtain the aggregated information, wherein the second threshold of the number of alarms is 5, and the aggregated information is reported to relevant personnel. Understandably, the second alarm policy only needs to report an alarm once.

Further, the third alarm policy is specifically to count the number of alarms from the first time the alarm information is received within the preset alarm aggregation time; if the number of alarms is a multiple of the threshold of the third number of alarms, wherein, The third alarm times threshold is 10. Specifically, when the alarm times is 10, since 10 is a multiple of the third alarm times threshold of 10, The alarm information is aggregated, and the aggregated information is reported to the relevant personnel, and so on. When the number of alarms is 20, the alarm information between the 11th and the 20th time is aggregated The information is reported to the relevant personnel. Understandably, if it is assumed that the total number of alarms is 22 within the preset alarm aggregation time, the 21st and 22nd alarm information will not be uploaded, and the third alarm policy only needs to be reported twice. Alarms, that is, uploading alarms that are multiples of the third farewell threshold.

FIG. 2 is a schematic block diagram of an alarm aggregation reporting apparatus 200 provided by an embodiment of the present invention. As shown in FIG. 2 , corresponding to the above alarm aggregation reporting method, the present invention further provides an alarm aggregation reporting apparatus 200 . The alarm aggregation reporting apparatus 200 includes a unit for executing the above-mentioned alarm aggregation reporting method, and the apparatus may be configured in a server. Specifically, please refer to FIG. 2 , the alarm aggregate reporting apparatus 200 includes a first query unit 201 , a selection unit 202 , a second query unit 203 , a setting unit 204 and an aggregate reporting unit 205 .

Wherein, the first query unit 201 is configured to regularly query whether there is a master node in the preset database; the selection unit 202 is configured to query the preset database if the master node does not exist in the preset database. The optimistic locking mechanism selects a slave node from a plurality of slave nodes as the master node, and sets the effective lease time of the master node as the preset lease time; the second query unit 203 is used for if If the master node exists in the preset database, then regularly query whether the master node satisfies the lease renewal condition; the setting unit 204 is configured to obtain the current time if the master node satisfies the lease renewal condition, and The effective lease time is reset according to the current time and the preset lease time; the aggregation reporting unit 205 is configured to: if the master node receives alarm information within the effective lease time, Then, the alarm information is aggregated according to the alarm policy within the preset alarm aggregation time to obtain aggregated information, and the aggregated information is reported to the relevant personnel.

In some embodiments, such as this embodiment, the aggregation reporting unit 205 includes an identification unit 2051 , a first aggregation unit 2052 , a second aggregation unit 2053 and a third aggregation unit 2054 .

Wherein, the identifying unit 2051 is configured to identify the alarm policy according to the preset policy identifier; the first aggregation unit 2052 is configured to, if the alarm policy is the first alarm policy, according to the preset alarm aggregation time The first alarm policy aggregates the alarm information to obtain aggregated information; the second aggregation unit 2053 is configured to, if the alarm policy is the second alarm policy, perform the aggregation according to the The second alarm policy aggregates the alarm information to obtain the aggregated information; the third aggregation unit 2054 is configured to, if the alarm policy is the third alarm policy, perform the aggregation according to the third alarm policy within the preset alarm aggregation time. The alarm policy aggregates the alarm information to obtain the aggregated information.

In some embodiments, such as this embodiment, the first aggregation unit 2052 includes a determination unit 20521, a setting subunit 20522, an update unit 20523, a reporting unit 20524, a first storage unit 20525, a first calculation unit 20526, a first Two saving unit 20527, return execution unit 20528 and first aggregation sub-unit 20529.

The determining unit 20521 is used to determine whether the alarm information is received for the first time; the setting subunit 20522 is used to determine the time when the alarm information is received if the alarm information is received for the first time As the start alarm time, and set the number of alarms to 1; the updating unit 20523 is configured to update the number of alarms if the alarm information is not received for the first time and within the preset alarm aggregation time, and set the number of alarms to 1. The alarm times are compared with the first alarm times threshold; the reporting unit 20524 is configured to report the received alarm information to the relevant personnel if the alarm times is not greater than the first alarm times threshold; The first storage unit 20525 is configured to save the received alarm information if the alarm count is greater than the first alarm count threshold; the calculation unit 20526 is configured to store the alarm information after the preset alarm aggregation time arrives , the time after the preset alarm aggregation time from the start alarm time is taken as the alarm end time, and the time between the alarm end time and the last alarm information time in the preset alarm aggregation time is calculated. The second saving unit 20527 is configured to reassign the preset alarm aggregation time if the time difference is less than the preset time threshold, and will end the alarm from the alarm The received alarm information within the preset alarm aggregation time period is saved; the return execution unit 20528 is configured to use the alarm end time as the start alarm time, and return to execute the After the preset alarm aggregation time arrives, the time from the start alarm time and after the preset alarm aggregation time is taken as the alarm end time; the first aggregation subunit 20529 is used for if the time difference is is not less than the preset time threshold, then aggregate all the alarm information that has not been reported to obtain aggregated information.

In some embodiments, such as this embodiment, the second aggregation unit 2053 includes a second computing unit 20531 and a second aggregation sub-unit 20532.

Wherein, the second calculation unit 20531 is used to count the times of the received alarm information within the preset alarm aggregation time to obtain the total number of alarms; the second aggregation sub-unit 20532 is used to calculate the total number of alarms if the total If the number of alarms is greater than the second threshold of the number of alarms, the alarm information is aggregated to obtain the aggregated information.

In some embodiments, such as this embodiment, the third aggregation unit 2054 includes a third computing unit 20541 and a third aggregation sub-unit 20542 .

Wherein, the third calculation unit 20541 is used to count the number of alarms from the first time the alarm information is received within the preset alarm aggregation time; the third aggregation subunit 20542 is used to count the number of alarms if the number of alarms is The multiple of the third alarm times threshold, the alarm information is aggregated to obtain the aggregated information.

In some embodiments, such as this embodiment, the alarm aggregation reporting apparatus 200 further includes a third query unit 206 and a return unit 207 .

Wherein, the third query unit 206 is used for regularly querying whether the lease period of the master node exceeds the preset lease period time; the returning unit 207 is used for if the lease period of the master node exceeds the preset lease period If the lease period time is set, then return to the step of executing the regular query of whether there is a master node in the preset database.

The specific implementation manner of the alarm aggregation reporting apparatus 200 according to the embodiment of the present invention corresponds to the above-mentioned alarm aggregation reporting method, and details are not described herein again.

The above-mentioned alarm aggregation reporting apparatus may be implemented in the form of a computer program, and the computer program may be executed on the computer device as shown in FIG. 3 .

Please refer to FIG. 3 , which is a schematic block diagram of a computer device provided by an embodiment of the present application. The computer device 300 is a server. Specifically, the server can be an independent server, or can provide cloud services, cloud databases, cloud computing, cloud functions, cloud storage, network services, cloud communications, middleware services, domain name services, security Services, Content Delivery Network (CDN), and cloud servers for basic cloud computing services such as big data and artificial intelligence platforms.

Referring to FIG. 3 , the computer device 300 includes a processor 302 , a memory and a network interface 305 connected through a system bus 301 , wherein the memory may include a storage medium 303 and an internal memory 304 .

The storage medium 303 can store an operating system 3031 and a computer program 3032 . When the computer program 3032 is executed, it can cause the processor 302 to execute an alarm aggregation reporting method.

The processor 302 is used to provide computing and control capabilities to support the operation of the entire computer device 300 .

The internal memory 304 provides an environment for running the computer program 3032 in the storage medium 303. When the computer program 3032 is executed by the processor 302, the processor 302 can execute an alarm aggregation reporting method.

The network interface 305 is used for network communication with other devices. Those skilled in the art can understand that the structure shown in FIG. 3 is only a block diagram of a part of the structure related to the solution of the present application, and does not constitute a limitation on the computer device 300 to which the solution of the present application is applied. The specific computer device 300 may include more or fewer components than shown, or combine certain components, or have a different arrangement of components.

Wherein, the processor 302 is used for running the computer program 3032 stored in the memory, so as to realize the following steps: regularly query whether there is a master node in the preset database; if the master node does not exist in the preset database, then A slave node is selected from a plurality of slave nodes as the master node through the optimistic locking mechanism of the preset database, and the effective lease period time of the master node is set as the preset lease period time; Assuming that the master node exists in the database, regularly query whether the master node satisfies the lease renewal condition; if the master node satisfies the lease renewal condition, obtain the current time, and according to the current time and the preset The lease time is to reset the valid lease time; if the master node receives the alarm information within the valid lease time, it aggregates the alarm information according to the alarm policy within the preset alarm aggregation time. to obtain aggregated information and report the aggregated information to relevant personnel.

In some embodiments, such as this embodiment, when implementing the step of aggregating the alarm information according to an alarm policy within a preset alarm aggregation time to obtain aggregated information, the processor 302 specifically implements the following steps: The set policy identifier identifies the alarm policy; if the alarm policy is the first alarm policy, the alarm information is aggregated according to the first alarm policy within the preset alarm aggregation time to obtain aggregated information; If the alarm policy is the second alarm policy, then the alarm information is aggregated according to the second alarm policy within the preset alarm aggregation time to obtain the aggregated information; if the alarm policy is the third alarm policy, then The alarm information is aggregated according to the third alarm policy within a preset alarm aggregation time to obtain the aggregated information.

In some embodiments, such as this embodiment, when the processor 302 implements the step of aggregating the alarm information according to the first alarm policy within a preset alarm aggregation time to obtain aggregated information, the specific implementation is as follows Steps: determine whether the alarm information is received for the first time; if the alarm information is received for the first time, the time when the alarm information is received is used as the start alarm time, and the number of alarms is set to 1; If the alarm information is not received for the first time and within the preset alarm aggregation time, the alarm times are updated, and the alarm times are compared with the first alarm times threshold; if the alarm times are not greater than the first alarm times If the number of alarms is greater than the threshold of the number of alarms, the received alarm information is reported to the relevant personnel; if the number of alarms is greater than the first threshold of alarm times, the received alarm information is saved; the preset After the alarm aggregation time arrives, the time from the start alarm time and after the preset alarm aggregation time is taken as the alarm end time, and the alarm end time and the last alarm aggregation time in the preset alarm aggregation time are calculated. The difference between the alarm information times to obtain the time difference; if the time difference is less than the preset time threshold, the preset alarm aggregation time is reassigned, starting from the alarm end time and ending at The received alarm information within the preset alarm aggregation time period is saved; the alarm end time is used as the start alarm time, and the execution is returned after the preset alarm aggregation time arrives. The step of starting the alarm time after the preset alarm aggregation time elapses as the alarm end time; if the time difference is not less than the preset time threshold, aggregate all the unreported alarm information to Get aggregated information.

In some embodiments, such as this embodiment, when the processor 302 implements the step of aggregating the alarm information according to the second alarm policy within a preset alarm aggregation time to obtain the aggregated information, the specific The following steps are implemented: the number of times of the received alarm information is counted within a preset alarm aggregation time to obtain the total number of alarms; if the total number of alarms is greater than the second threshold of the number of alarms, the alarm information is aggregated to obtain the aggregated information.

In some embodiments, such as this embodiment, when the processor 302 implements the step of aggregating the alarm information according to the third alarm policy within a preset alarm aggregation time to obtain the aggregated information, the specific The following steps are implemented: start counting the number of alarms when the alarm information is received for the first time within the preset alarm aggregation time; if the number of alarms is a multiple of the threshold of the third alarm number, aggregate the alarm information to Obtain the aggregated information.

In some embodiments, such as this embodiment, the processor 302 implements that if the master node does not exist in the preset database, the processor 302 obtains data from multiple slave nodes through an optimistic locking mechanism of the preset database. After the step of selecting a slave node as the master node and setting the effective lease period of the master node as the preset lease period, the specific implementation further includes the following steps: regularly querying whether the lease period of the master node is Exceeds the preset lease period time; if the lease period of the master node exceeds the preset lease period time, return to the step of performing the regular query on whether there is a master node in the preset database.

It should be understood that, in this embodiment of the present application, the processor 302 may be a central processing unit (Central Processing Unit, CPU), and the processor 302 may also be other general-purpose processors, digital signal processors (Digital Signal Processor, DSP), dedicated integrated Circuit (Application Specific Integrated Circuit, ASIC), off-the-shelf Programmable Gate Array (Field-Programmable Gate Array, FPGA) or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware components, and the like. Wherein, the general-purpose processor can be a microprocessor or the processor can also be any conventional processor or the like.

It can be understood by those skilled in the art that all or part of the processes in the methods for implementing the above embodiments can be completed by instructing relevant hardware through a computer program. The computer program can be stored in a storage medium, which is a computer-readable storage medium. The computer program is executed by at least one processor in the computer system to implement the flow steps of the above-described method embodiments.

Therefore, the present invention also provides a storage medium. The storage medium may be a computer-readable storage medium. The storage medium stores a computer program. The computer program is executed by at least one processor in the computer system to implement the process steps of the embodiments of the above-mentioned method for aggregated alarm reporting.

The storage medium may be various computer-readable storage media that can store program codes, such as a U disk, a removable hard disk, a read-only memory (Read-Only Memory, ROM), a magnetic disk, or an optical disk.

Those of ordinary skill in the art can realize that the units and algorithm steps of each example described in conjunction with the embodiments disclosed herein can be implemented in electronic hardware, computer software, or a combination of the two. Interchangeability, the above description has generally described the components and steps of each example in terms of function. Whether these functions are performed in hardware or software depends on the specific application and design constraints of the technical solution. Skilled artisans may implement the described functionality using different methods for each particular application, but such implementations should not be considered beyond the scope of the present invention.

In the several embodiments provided by the present invention, it should be understood that the disclosed apparatus and method may be implemented in other manners. For example, the apparatus embodiments described above are merely illustrative. For example, the division of each unit is only a logical function division, and there may be other division methods in actual implementation. For example, multiple units or components may be combined or may be integrated into another system, or some features may be omitted, or not implemented.

The steps in the method of the embodiment of the present invention may be adjusted, combined and deleted in sequence according to actual needs. Units in the apparatus of the embodiment of the present invention may be combined, divided, and deleted according to actual needs. In addition, each functional unit in each embodiment of the present invention may be integrated into one processing unit, or each unit may exist physically alone, or two or more units may be integrated into one unit.

The integrated unit, if implemented in the form of a software functional unit and sold or used as an independent product, may be stored in a storage medium. Based on this understanding, the technical solution of the present invention is essentially or a part that contributes to the prior art, or all or part of the technical solution can be embodied in the form of a software product, and the computer software product is stored in a storage medium , including several instructions to cause a computer device (which may be a personal computer, a terminal, or a network device, etc.) to execute all or part of the steps of the methods described in the various embodiments of the present invention.

In the above-mentioned embodiments, the description of each embodiment has its own emphasis. For parts that are not described in detail in a certain embodiment, reference may be made to the relevant descriptions of other embodiments.

It will be apparent to those skilled in the art that various modifications and variations can be made in the present invention without departing from the spirit and scope of the invention. Thus, even if these modifications and variations of the present invention fall within the scope of the claims of the present invention and their equivalents, the present invention is also intended to include these modifications and variations.

The above are only specific embodiments of the present invention, but the protection scope of the present invention is not limited to this. Any person skilled in the art can easily think of various equivalents within the technical scope disclosed by the present invention. Modifications or substitutions should be included within the protection scope of the present invention. Therefore, the protection scope of the present invention should be subject to the protection scope of the claims.

Claims (10)

1. An alarm aggregation reporting method, characterized in that, comprising: Regularly query whether there is a master node in the preset database; If the master node does not exist in the preset database, select a slave node from a plurality of slave nodes as the master node through the optimistic locking mechanism of the preset database, and use the effective locking mechanism of the master node. The lease time is set to the preset lease time; If the master node exists in the preset database, regularly query whether the master node satisfies the lease renewal condition; If the master node satisfies the lease renewal condition, obtain the current time, and reset the valid lease time according to the current time and the preset lease time; If the master node receives the alarm information within the valid lease period, the master node aggregates the alarm information according to the alarm policy within the preset alarm aggregation time to obtain aggregated information, and reports the aggregated information to the relevant personnel. 2 . The alarm aggregation reporting method according to claim 1 , wherein the aggregation of the alarm information according to an alarm policy within a preset alarm aggregation time to obtain aggregated information comprises: 2 . Identify the alarm policy according to the preset policy identifier; If the alarm policy is the first alarm policy, aggregate the alarm information according to the first alarm policy within a preset alarm aggregation time to obtain aggregated information; If the alarm policy is a second alarm policy, aggregate the alarm information according to the second alarm policy within a preset alarm aggregation time to obtain the aggregated information; If the alarm policy is a third alarm policy, the alarm information is aggregated according to the third alarm policy within a preset alarm aggregation time to obtain the aggregation information. 3 . The alarm aggregation reporting method according to claim 2 , wherein the aggregation of the alarm information according to the first alarm policy within a preset alarm aggregation time to obtain aggregation information comprises: 3 . Determine whether the alarm information is received for the first time; If the alarm information is received for the first time, the time when the alarm information is received is used as the start alarm time, and the number of alarms is set to 1; If the alarm information is not received for the first time and is within the preset alarm aggregation time, updating the number of alarms, and comparing the number of alarms with the first threshold of the number of alarms; If the number of alarms is not greater than the threshold of the first number of alarms, reporting the received alarm information to the relevant personnel; If the alarm times is greater than the first alarm times threshold, save the received alarm information; After the preset alarm aggregation time arrives, the time from the start alarm time and after the preset alarm aggregation time is taken as the alarm end time, and the alarm end time and the preset alarm aggregation time are calculated. The difference between the last time of the alarm information to obtain the time difference; Aggregate all the unreported alarm information according to the time difference, the alarm end time, the preset alarm aggregation time, and the preset time threshold to obtain aggregated information. 4 . The alarm aggregation reporting method according to claim 3 , wherein, according to the time difference, the alarm ending time, the preset alarm aggregation time, and a preset time threshold, all the unreported alarms are analyzed. 5 . The alarm information is aggregated to obtain aggregated information, including: If the time difference value is smaller than the preset time threshold, the preset alarm aggregation time is reassigned, and all received alarms starting from the alarm end time and within the preset alarm aggregation time period will be reassigned. The alarm information is saved; Take the alarm end time as the start alarm time, and return the time from the start alarm time after the preset alarm aggregation time to the alarm end time after the preset alarm aggregation time arrives. step; If the time difference is not less than the preset time threshold, aggregate all the unreported alarm information to obtain aggregated information. 5 . The alarm aggregation reporting method according to claim 2 , wherein the aggregation of the alarm information according to the second alarm policy within a preset alarm aggregation time to obtain the aggregation information comprises: 5 . Count the number of times of the received alarm information within the preset alarm aggregation time to obtain the total number of alarms; If the total number of alarms is greater than the second threshold of the number of alarms, the alarm information is aggregated to obtain the aggregated information. The alarm aggregation reporting method according to claim 2, wherein the aggregation of the alarm information according to the third alarm policy within a preset alarm aggregation time to obtain the aggregation information comprises: The number of alarms is counted from the first time the alarm information is received within the preset alarm aggregation time; If the number of alarms is a multiple of a third threshold of the number of alarms, the alarm information is aggregated to obtain the aggregated information. 7 . The alarm aggregation reporting method according to claim 1 , wherein if the master node does not exist in the preset database, an optimistic locking mechanism of the preset database is used to retrieve multiple slave nodes. 8 . After the step of selecting a slave node as the master node and setting the effective lease period of the master node as the preset lease period, the method further includes: Regularly query whether the lease period of the master node exceeds the preset lease period time; If the lease term of the master node exceeds the preset lease term time, return to the step of performing the regular query on whether there is a master node in the preset database. 8. An alarm aggregation reporting device, characterized in that it comprises: a first query unit, used for regularly querying whether there is a master node in the preset database; The selection unit is configured to select a slave node from a plurality of slave nodes as the master node through the optimistic locking mechanism of the preset database if the master node does not exist in the preset database, and select all slave nodes as the master node. The valid lease time of the master node is set to the preset lease time; a second query unit, configured to periodically query whether the master node satisfies the lease renewal condition if the master node exists in the preset database; a setting unit, configured to obtain the current time if the master node satisfies the lease renewal condition, and reset the valid lease time according to the current time and the preset lease time; The aggregation reporting unit is configured to, if the master node receives alarm information within the valid lease period, aggregate the alarm information according to the alarm policy within the preset alarm aggregation time to obtain aggregated information, and then The aggregated information is reported to the relevant personnel. 9. A computer device, characterized in that the computer device comprises a memory and a processor, a computer program is stored on the memory, and the processor implements any one of claims 1-7 when the processor executes the computer program The alarm aggregation reporting method described in item. 10. A computer-readable storage medium, wherein the storage medium stores a computer program, the computer program can implement the alarm aggregation according to any one of claims 1-7 when executed by a processor reporting method.

Images