WO2024125111A1 - Cloud service alarm method and apparatus, and system and computing node - Google Patents

Abstract

In the present application, the method comprises: a database node sending usage indicators of the database node to a data lake, and the data lake storing the usage indicators of the database node; when fault processing of the database node is completed, a high-order management service receiving a health analysis event of the database node; when receiving the health analysis event, the high-order management service acquiring the usage indicators of the database node from the data lake; the high-order management service using the usage indicators to perform analysis so as to obtain whether a user application has restored connections to healthy database nodes; and if the user application is not connected to the healthy database nodes, an alarm platform giving an alarm to a user. In this way, during fault processing of database nodes, if user applications have not connected healthy database nodes, an alarm is given to user in a timely manner, and the users are reminded to restore the use of the user applications to the healthy database nodes in a timely manner.

Description

Cloud service alarm method, device, system and computing node Technical Field

The present application relates to the field of computers, and in particular to a cloud service alarm method, a data node, a distributed database, a computing node, and a computer program product.

Background technique

The ultimate high availability of the database is the goal pursued by database cloud services. In real-world scenarios, hardware failures, unexpected network fluctuations, etc., will trigger the high availability switch of the database, which will generate user-side database client perception.

Conventional database connection tools use a manual connection method. When the user starts the tool, the database is connected and the connection is maintained. Once the original connection is disconnected due to an abnormality, the client tool will only have an error message when trying to query again, and will not automatically reconnect after network fluctuations.

Summary of the invention

In view of this, the present application provides a cloud service alarm method and device, system, computing node, computer program product and non-volatile storage medium. When handling a database node failure, if the user is still using an abnormal database, the user will be promptly alarmed.

In the first aspect, the present application provides a method for cloud service alarm. A database node sends a usage indicator of the database node to a data lake, and the data lake stores the usage indicator of the database node; when the fault handling of the database node is completed, the high-level management service receives a health analysis event of the database node; when the high-level management service receives the health analysis event, it obtains the usage indicator of the database node from the data lake; the high-level management service uses the usage indicator to analyze whether the user application has restored the connection to the healthy database node; if the user application is not connected to the healthy database node, the alarm platform alarms the user.

In this way, after the failure of the database node is handled, if the user application has not yet connected to a healthy database node, the user will be promptly alerted to remind the user to restore the use of the healthy database node by the user application in a timely manner.

In a possible design of the first aspect, the high-level management service subscribes to the health analysis event of the database node in the message service; and the message service receives the health analysis event of the database node.

In a possible design of the first aspect, completing the fault handling of the database node includes: completing the master-slave switching between the master database node and the slave database node.

In a possible design of the first aspect, completing the fault handling of the database node includes: the database node completing fault recovery.

In a possible design of the first aspect, the usage indicator of the database node includes one or more of the following:

Processor utilization of the database node;

The memory utilization of the database node;

The number of user connections to the database node.

In a second aspect, the present application provides a cloud service alarm device, which includes multiple functional modules for implementing different steps of the method provided in the first aspect or any possible design of the first aspect.

In a third aspect, the present application provides a system, comprising: a database node, configured to send a usage indicator of the database node to a data lake; the data lake, configured to store the usage indicator of the database node; a high-level management service, configured to receive a health analysis event of the database node when completing the fault handling of the database node, obtain the usage indicator of the database node from the data lake, and use the usage indicator to analyze whether the user application has restored the connection to the healthy database node; The alarm platform is used to alarm the user if the user application is not connected to a healthy database node.

In this way, when handling a database node failure, if the user application has not yet connected to a healthy database node, the user will be promptly alerted to remind the user to restore the user application's use of the healthy database node in a timely manner.

In a possible design of the third aspect, the high-level management service is used to subscribe to the health analysis events of the database node in the message service; and the message service is used to receive the health analysis events of the database node.

In a possible design of the third aspect, completing the fault handling of the database node includes: completing the master-slave switching between the master database node and the slave database node.

In a possible design of the third aspect, completing the fault handling of the database node includes: the database node completing fault recovery.

In a possible design of the third aspect, the usage indicator of the database node includes one or more of the following:

Processor utilization of the database node;

The memory utilization of the database node;

The number of user connections to the database node.

In a fourth aspect, the present application provides a computing device cluster, characterized in that it includes at least one computing device, each computing device includes a processor and a memory; the processor of the at least one computing device is used to execute instructions stored in the memory of the at least one computing device, so that the computing device cluster executes the method provided by the above-mentioned first aspect or various possible designs of the first aspect.

The present application provides a computing node, the computing node comprising a processor and a memory. The processor executes instructions stored in the memory, so that the computing node deploys the device provided in the second aspect.

In a fifth aspect, the present application provides a computer-readable storage medium having instructions stored therein. When a processor of a computing node executes the instructions, the computing node executes the method provided by the first aspect or various possible designs of the first aspect.

The present application provides a computer-readable storage medium, in which instructions are stored. When a processor of a computing node executes the instructions, the computing node implements the apparatus provided in the second aspect.

In a sixth aspect, the present application provides a computer program product, the computer program product comprising instructions, the instructions being stored in a computer-readable storage medium. A processor of a computing node can read the instructions from the computer-readable storage medium; the processor executes the instructions, so that the computing node executes the method provided by the first aspect or various possible designs of the first aspect.

The present application provides a computer program product, which includes instructions, which are stored in a computer-readable storage medium. A processor of a computing node can read the instructions from the computer-readable storage medium; the processor executes the instructions, and the computing node implements the apparatus provided in the second aspect.

BRIEF DESCRIPTION OF THE DRAWINGS

FIG1 is a flow chart of a cloud service alarm method provided by way of example in this application;

FIG2 is a flow chart of a cloud service alarm method provided by way of example in this application;

FIG3 is a flowchart of a computing device 100 provided by way of example in this application;

FIG4 is a schematic diagram of an architecture of a cluster provided as an example in this application;

FIG5 is a schematic diagram of an architecture of a cluster provided as an example in this application.

Detailed ways

The technical solution provided in this application will be described below in conjunction with the drawings in this application.

Fig. 1 provides an example of a cloud service alarm method. The method flow of the method is described below in conjunction with Fig. 1. The method at least includes steps S11 to S16.

Step S11: The database node sends the usage indicator of the database node to the data lake.

Database nodes deploy databases and provide database services to users. For example, users can use databases on database nodes.

There can be one or more database nodes. For example, a database system includes: a master database node, and one or more slave database nodes. The master database node supports user read and write operations. The slave database node can support user read operations. When the master database node fails or needs to be upgraded, the master and slave database nodes can be switched, that is, the master database node becomes a slave database node, and a slave database node becomes a master database node.

As a possible implementation of step S11, each database node autonomously monitors the usage index of the node, and actively reports or sends the monitored usage index to the database.

As a possible implementation example of the present application, the usage indicator of the database node includes one or more of the following:

Processor utilization of the database node;

The memory utilization of the database node;

The number of user connections to the database node.

For example, a database node uses a central processing unit (CPU) and memory to run a database. The database node monitors the CPU utilization and memory usage of the database node in real time. In addition, the database node also monitors the total number of user database connections (i.e., the number of user connections to the database node) in real time.

Step S12: The data lake stores usage indicators of the database nodes.

The data lake has cloud storage capabilities. In this application, the data lake is used to store usage indicators of database nodes.

Step S13: When the fault handling of the database node is completed, the high-level management service receives the health analysis event of the database node.

Database nodes may fail, such as single node failure or master-slave switchover. When the failure is eliminated, a health analysis event will be triggered, which will trigger the high-level management service to analyze whether the user is using a healthy database. The analysis will determine whether the user is using a healthy database.

Two business scenarios are given for completing the fault handling of the database node. In scenario example 1, the master database node and the slave database node complete the master-slave switch. In scenario example 2, the database node completes fault recovery.

As a business scenario example of how a high-level management service obtains health analysis events, the high-level management service subscribes to the health analysis events of the database node in the message service; the message service receives the health analysis events of the database node.

Step S14: When the high-level management service receives the health analysis event, it obtains the usage indicator of the database node from the data lake.

Step S15: The high-level management service uses the usage indicator to analyze whether the user application has restored the connection to the healthy database node.

Health analysis events trigger high-level management services to analyze whether user applications are connected to healthy databases, and to determine whether user applications are using healthy databases. For example, after the master and slave database nodes complete the master-slave switch, analyze whether the user's database connection is switched to the new master database node, that is, whether the user is currently using the new master database node to process business.

In the present application, if the analysis in step S15 leads to the conclusion that the user application is not connected to a healthy database node, the alarm platform is notified to alarm the user.

Step S16: If the user application is not connected to a healthy database node, the alarm platform alerts the user.

Through step S11 to step S16, the present application can promptly warn the user if the user application is still not connected to a healthy database node after completing the fault handling of the database node.

In this application, as shown in Figure 1, database nodes, high-availability services, message services, data lakes, high-level management services, and alarm platforms can be deployed independently. As another implementation method, some of the database nodes, high-availability services, message services, data lakes, high-level management services, and alarm platforms can be integrated and deployed together, such as the alarm platform can be integrated into the high-level management service, and the high-availability service can be integrated into the database node.

The present application provides an example implementation of the method shown in FIG1 , as shown in FIG2 .

In Figure 2, the database node is used to deploy the database cloud service purchased by the user.

In Figure 2, the high availability service is responsible for managing the high availability of the database, including database fault repair, master-slave switching, abnormal status monitoring, etc.

In Figure 2, the high-level management service is responsible for the lifecycle management of the database service, including the creation, specification change, power on and off, and deletion of database service nodes.

In Figure 2, the data lake is a data system used to store monitoring indicators of database nodes, which can perform efficient indicator item queries.

In Figure 2, the message service is responsible for delivering event notifications to the database management service;

In Figure 2, the alarm platform is responsible for alerting users.

FIG2 is an example process of implementing the method shown in FIG1 .

The database node sends the database node usage indicators to the data lake in real time, such as CPU utilization, memory utilization, and number of user connections. These usage indicators can reflect whether the user application has restored the connection to the healthy database node.

If the high-availability service completes the fault recovery or master-slave switching of the database node, the high-availability service sends a health analysis event to the message service. Since the high-level management service has subscribed to the health analysis event in the message service, the message service will actively send the health analysis event to the high-level management service. The health analysis event will trigger the high-level management service to perform a health analysis on the database node, such as analyzing whether the user application has restored the connection to the healthy database node, such as analyzing whether the user application is connected to and using the primary database node. To implement health analysis, the high-level management service obtains the usage indicator of the database node from the data lake, and uses the usage indicator to complete whether the user application has restored the connection to the healthy database node. If the analysis result is that the user application is not connected to the healthy database node, the alarm platform will alarm the user. In this way, the user can manually connect to the healthy database node and use the healthy database node to support the business.

【system】

The present application also provides a cloud service alarm system, as shown in FIG1 or FIG2, including:

A database node, used to send usage indicators of the database node to the data lake;

The data lake is used to store usage indicators of the database nodes;

A high-level management service, configured to receive a health analysis event of the database node when the fault handling of the database node is completed, obtain a usage indicator of the database node from the data lake, and use the usage indicator to analyze whether the user application has restored the connection to the healthy database node;

The alarm platform is used to alarm the user if the user application is not connected to a healthy database node.

In a possible implementation of the system, the high-level management service is used to subscribe to the health analysis events of the database node in the message service;

The message service is used to receive health analysis events of the database node.

In a possible implementation of the system, completing the fault handling of the database node includes: completing the master-slave switch between the master database node and the slave database node.

In a possible implementation of the system, completing the fault handling of the database node includes: the database node completing fault recovery.

In a possible implementation of the system, the usage index of the database node includes one or more of the following:

Processor utilization of the database node;

The memory utilization of the database node;

The number of user connections to the database node.

Database nodes, data lakes, high-level management services, alarm platforms, and message services can all be implemented through software or hardware. As an example, the implementation of high-level management services is described below. Similarly, the implementation of database nodes, data lakes, alarm platforms, and message services can refer to the implementation of high-level management services.

As an example of a software functional unit, a high-level management service may include code running on a computing instance. The computing instance may be at least one of a physical host (computing device), a virtual machine, a container, and other computing devices. Furthermore, the computing device may be one or more. For example, a high-level management service may include code running on multiple hosts/virtual machines/containers. It should be noted that the multiple hosts/virtual machines/containers used to run the application may be distributed in the same region or in different regions. The multiple hosts/virtual machines/containers used to run the code may be distributed in the same AZ or in different AZs, each AZ including a data center or multiple data centers with close geographical locations. Typically, a region may include multiple AZs.

Similarly, multiple hosts/virtual machines/containers used to run the code can be distributed in the same VPC or in multiple VPCs. Usually, a VPC is set up in a region. For cross-region communication between two VPCs in the same region and between VPCs in different regions, a communication gateway must be set up in each VPC to achieve interconnection between VPCs through the communication gateway.

As an example of a hardware functional unit, the high-level management service may include at least one computing device, such as a server, etc. Alternatively, the high-level management service may also be a device implemented by ASIC or PLD, etc. The PLD may be implemented by CPLD, FPGA, GAL or any combination thereof.

The multiple computing devices included in the advanced management service can be distributed in the same region or in different regions. The multiple computing devices included in the advanced management service can be distributed in the same AZ or in different AZs. Similarly, the multiple computing devices included in the advanced management service can be distributed in the same VPC or in multiple VPCs. The multiple computing devices can be any combination of computing devices such as servers, ASICs, PLDs, CPLDs, FPGAs, and GALs.

【Computing equipment】

The present application also provides a computing device 100. As shown in FIG3 , the computing device 100 includes: a bus 102, a processor 104, a memory 106, and a communication interface 108. The processor 104, the memory 106, and the communication interface 108 communicate with each other through the bus 102. The computing device 100 may be a server or a terminal device. It should be understood that the present application does not limit the number of processors and memories in the computing device 100.

The bus 102 may be a peripheral component interconnect (PCI) bus or an extended industry standard architecture (EISA) bus, etc. The bus may be divided into an address bus, a data bus, a control bus, etc. For ease of representation, FIG. 3 is represented by only one line, but does not mean that there is only one bus or one type of bus. The bus 104 may include a path for transmitting information between various components of the computing device 100 (e.g., the memory 106, the processor 104, and the communication interface 108).

The processor 104 may include any one or more processors such as a central processing unit (CPU), a graphics processing unit (GPU), a microprocessor (MP) or a digital signal processor (DSP).

The memory 106 may include a volatile memory, such as a random access memory (RAM). The processor 104 may also include a non-volatile memory, such as a read-only memory (ROM), a flash memory, a hard disk drive (HDD), or a solid state drive (SSD).

The memory 106 stores executable program codes, and the processor 104 executes the executable program codes to respectively implement the functions of the aforementioned database node, data lake, high-level management service, alarm platform, and message service, thereby implementing the cloud service alarm method. That is, the memory 106 stores instructions for executing the cloud service alarm method.

Alternatively, the memory 106 stores executable codes, and the processor 104 executes the executable codes to respectively implement the aforementioned database nodes. The functions of the cloud service alarm point, data lake, high-level management service, alarm platform and message service are combined to realize the cloud service alarm method. That is, the memory 106 stores instructions for executing the cloud service alarm method.

The communication interface 103 uses a transceiver module such as, but not limited to, a network interface card or a transceiver to implement communication between the computing device 100 and other devices or a communication network.

【Computing Device Cluster】

The embodiment of the present application also provides a computing device cluster. The computing device cluster includes at least one computing device. The computing device can be a server, such as a central server, an edge server, or a local server in a local data center. In some embodiments, the computing device can also be a terminal device such as a desktop computer, a laptop computer, or a smart phone.

As shown in Fig. 4, the computing device cluster includes at least one computing device 100. The memory 106 in one or more computing devices 100 in the computing device cluster may store the same instructions for executing the cloud service alarm method.

In some possible implementations, the memory 106 of one or more computing devices 100 in the computing device cluster may also store partial instructions for executing the method for cloud service alarm. In other words, the combination of one or more computing devices 100 may jointly execute the instructions for executing the method for cloud service alarm.

It should be noted that the memory 106 in different computing devices 100 in the computing device cluster can store different instructions, which are respectively used to execute part of the functions of the high-level management service. That is, the instructions stored in the memory 106 in different computing devices 100 can implement the functions of one or more modules in the database node, data lake, high-level management service, alarm platform and message service.

In some possible implementations, one or more computing devices in a computing device cluster may be connected via a network. The network may be a wide area network or a local area network, etc. FIG. 5 shows a possible implementation. As shown in FIG. 5 , two computing devices 100A and 100B are connected via a network. Specifically, the network is connected via a communication interface in each computing device. In this type of possible implementation, the memory 106 in the computing device 100A stores instructions for executing functions of high-level management services. At the same time, the memory 106 in the computing device 100B stores instructions for executing functions of database nodes, data lakes, alarm platforms, and message services.

The connection method between the computing device clusters shown in Figure 5 can be considered that the cloud service alarm method provided in this application requires a large amount of storage, so it is considered to entrust the functions implemented by the database node, data lake, alarm platform and message service to the computing device 100B for execution.

It should be understood that the functions of the computing device 100A shown in FIG5 may also be completed by multiple computing devices 100. Similarly, the functions of the computing device 100B may also be completed by multiple computing devices 100.

The embodiment of the present application also provides another computing device cluster. The connection relationship between the computing devices in the computing device cluster can be similar to the connection mode of the computing device cluster described in Figures 4 and 5. The difference is that the memory 106 in one or more computing devices 100 in the computing device cluster can store the same instructions for executing the cloud service alarm method.

In some possible implementations, the memory 106 of one or more computing devices 100 in the computing device cluster may also store partial instructions for executing the method for cloud service alarm. In other words, the combination of one or more computing devices 100 may jointly execute the instructions for executing the method for cloud service alarm.

It should be noted that the memory 106 in different computing devices 100 in the computing device cluster can store different instructions for executing part of the functions of the cloud service alarm system. That is, the instructions stored in the memory 106 in different computing devices 100 can implement the functions of one or more devices in the database node, data lake, high-level management service, alarm platform and message service.

The embodiment of the present application also provides a computer program product including instructions. The computer program product may be a software or program product including instructions that can be run on a computing device or stored in any available medium. When the computer program product is run on at least one computing device, the at least one computing device is caused to execute a cloud service alarm method.

The present application also provides a computer-readable storage medium. The computer-readable storage medium may be a computer device capable of storing The computer readable storage medium includes any available medium or a data storage device such as a data center including one or more available mediums. The available medium may be a magnetic medium (e.g., a floppy disk, a hard disk, a tape), an optical medium (e.g., a DVD), or a semiconductor medium (e.g., a solid state drive). The computer readable storage medium includes instructions that instruct the computing device to execute the cloud service alarm method.

Finally, it should be noted that the above embodiments are only used to illustrate the technical solutions of the present invention, rather than to limit it. Although the present invention has been described in detail with reference to the aforementioned embodiments, those skilled in the art should understand that they can still modify the technical solutions described in the aforementioned embodiments, or make equivalent replacements for some of the technical features therein. However, these modifications or replacements do not cause the essence of the corresponding technical solutions to deviate from the protection scope of the technical solutions of the embodiments of the present invention.

Claims (13)

A cloud service alarm method, characterized in that the method comprises: The database node sends the usage indicator of the database node to the data lake, and the data lake stores the usage indicator of the database node; When the fault handling of the database node is completed, the high-level management service receives a health analysis event of the database node; The high-level management service obtains the usage indicator of the database node from the data lake when receiving the health analysis event; The high-level management service uses the usage indicator to analyze whether the user application has restored the connection to the healthy database node; If the user application is not connected to the healthy database node, the alarm platform will alarm the user. The method according to claim 1, characterized in that the method comprises: The high-level management service subscribes to the health analysis event of the database node in the message service; The message service receives a health analysis event of the database node. The method according to claim 2, characterized in that The completing the fault handling of the database node includes: the master database node and the slave database node completing the master-slave switch. The method according to any one of claims 1 to 3, characterized in that The completing the fault handling of the database node includes: the database node completing fault recovery. The method according to any one of claims 1 to 4, characterized in that the usage index of the database node includes one or more of the following: Processor utilization of the database node; The memory utilization of the database node; The number of user connections to the database node. A cloud service alarm system, characterized in that the system comprises: A database node, used to send usage indicators of the database node to the data lake; The data lake is used to store usage indicators of the database nodes; A high-level management service, configured to receive a health analysis event of the database node when the fault handling of the database node is completed, obtain a usage indicator of the database node from the data lake, and use the usage indicator to analyze whether the user application has restored the connection to the healthy database node; The alarm platform is used to alarm the user if the user application is not connected to the healthy database node. The system according to claim 6, characterized in that The high-level management service is used to subscribe to the health analysis events of the database node in the message service; The message service is used to receive health analysis events of the database node. The system according to claim 6 or 7 is characterized in that completing the fault handling of the database node includes: completing the master-slave switching between the master database node and the slave database node. The system according to any one of claims 6 to 8, characterized in that completing the fault handling of the database node includes: the database node completing fault recovery. The system according to any one of claims 6 to 9, characterized in that the usage indicator of the database node The mark may include one or more of the following: Processor utilization of the database node; The memory utilization of the database node; The number of user connections to the database node. A computing device cluster, characterized in that it includes at least one computing device, each computing device includes a processor and a memory; The processor of the at least one computing device is configured to execute instructions stored in the memory of the at least one computing device, so that the computing device cluster executes the method according to any one of claims 1 to 5. A computer program product comprising instructions, characterized in that when the instructions are executed by a computing device cluster, the computing device cluster executes the method according to any one of claims 1 to 5. A computer-readable storage medium, characterized in that it includes computer program instructions. When the computer program instructions are executed by a computing device cluster, the computing device cluster executes the method according to any one of claims 1 to 5.