CN110806960B - Information processing method and device and terminal equipment - Google Patents

Abstract

Embodiments of the present invention provide an information processing method, device and terminal equipment. The method includes: obtaining monitoring information corresponding to the business to be monitored, where the monitoring information includes business monitoring indicators and their corresponding monitoring data, and obtaining the indicator type of the business monitoring indicator. , according to the indicator type of the business monitoring indicator, the storage format of the monitoring data corresponding to the business monitoring indicator is unified, the target monitoring information is obtained, and the target monitoring information is pushed to the middleware of the second terminal, so that the second terminal obtains the subscription The client of the target monitoring information sends the target monitoring information to the client. Since the target monitoring information has been stored in a unified storage format, neither the second terminal nor the client need to process the target monitoring information when storing it. It can be stored only after processing to improve the efficiency of data storage.

Description

Information processing methods, devices and terminal equipment

Technical field

Embodiments of the present invention relate to the field of computer technology, and in particular, to an information processing method, device and terminal equipment.

Background technique

With the development of computer technology, in order to facilitate people's lives, enterprises or platforms provide more and more types of services.

In the existing technology, in order to ensure that the business can run normally, it is necessary to configure business monitoring indicators for the business, monitor the business monitoring indicators, obtain corresponding monitoring data, and send the monitoring data to the terminal that needs the monitoring data, so that relevant personnel can It can be determined whether the business monitoring indicators are abnormal based on the monitoring data stored in the terminal, that is, whether there is an abnormality in the business, so that the abnormality can be handled in a timely manner.

However, the inventor found that there are at least the following problems in the prior art: since there are many types of monitoring data and the format is complex, after the obtained monitoring data is directly sent to the terminal, the terminal needs to process the monitoring data before it can be processed. Storage, data storage efficiency is low.

Contents of the invention

Embodiments of the present invention provide an information processing method, device and terminal equipment to solve the problem of low data storage efficiency in the prior art.

In a first aspect, embodiments of the present invention provide an information processing method, including:

Obtain monitoring information corresponding to the business to be monitored, where the monitoring information includes business monitoring indicators and their corresponding monitoring data;

Obtain the indicator type of the business monitoring indicator;

According to the indicator type of the business monitoring indicator, the monitoring data corresponding to the business monitoring indicator is stored in a unified storage format to obtain the target monitoring information;

The target monitoring information is pushed to the middleware of the second terminal, so that the second terminal obtains a client that subscribes to the target monitoring information and sends the target monitoring information to the client.

In one possible design, according to the indicator type of the business monitoring indicator, the monitoring data corresponding to the business monitoring indicator is stored in a unified storage format to obtain target monitoring information, including:

Classify the business monitoring indicators to obtain multiple indicator sets, wherein the indicator sets include business monitoring indicators of the same indicator type;

For each indicator set, obtain the standard storage format corresponding to the indicator set, and perform unified storage format processing on the monitoring data corresponding to each business monitoring indicator in the indicator set according to the standard storage format, wherein the storage format is unified The processing includes at least one of unit unification processing, file occupied space unification processing, and accuracy unification processing.

In one possible design, pushing the target monitoring information to the middleware of the second terminal includes:

Encapsulate the monitoring data in the target monitoring information according to the preset JSON message format to obtain multiple JSON messages;

Push the JSON message to the middleware.

In a possible design, after pushing the data message to the middleware, the method further includes:

Obtain data transfer logs and obtain JSON nodes from said data transfer logs;

Obtain the node message corresponding to the JSON node, and determine whether the message format of the node message is complete;

If the message format of the node message is incomplete, the monitoring data corresponding to the node message is retransmitted.

In one possible design, after obtaining the monitoring information corresponding to the service to be monitored, the method further includes:

Obtain the numerical interval corresponding to the business monitoring indicator;

According to the monitoring data and numerical intervals corresponding to the business monitoring indicators, the monitoring results of the business monitoring indicators are obtained, where the monitoring results include normal indicators and abnormal indicators.

In a possible design, the middleware includes a message queue and a message partition.

In one possible design, pushing the target monitoring information to the middleware of the second terminal includes:

Obtain the target monitoring information corresponding to the preset core business, and use the target monitoring information corresponding to the core business as the core monitoring information.

Push the core monitoring information to a target message queue of the second terminal, where the target message queue is a message queue corresponding to the preset core service.

In a second aspect, an embodiment of the present invention provides an information processing device, including:

An information acquisition module, used to obtain monitoring information corresponding to the business to be monitored, where the monitoring information includes business monitoring indicators and their corresponding monitoring data;

A type acquisition module, used to obtain the indicator type of the business monitoring indicator;

An information processing module, configured to unify the storage format of the monitoring data corresponding to the business monitoring indicators according to the indicator type of the business monitoring indicators to obtain target monitoring information;

An information push module, configured to push the target monitoring information to the middleware of the second terminal, so that the second terminal obtains the client that subscribes to the target monitoring information and sends the target monitoring information to the client. .

In a possible design, the information processing module is specifically used to:

Classify the business monitoring indicators to obtain multiple indicator sets, wherein the indicator sets include business monitoring indicators of the same indicator type;

For each indicator set, obtain the standard storage format corresponding to the indicator set, and perform unified storage format processing on the monitoring data corresponding to each business monitoring indicator in the indicator set according to the standard storage format, wherein the storage format is unified The processing includes at least one of unit unification processing, file occupied space unification processing, and accuracy unification processing.

In a possible design, the information push module is specifically used to:

Encapsulate the monitoring data in the target monitoring information according to the preset JSON message format to obtain multiple JSON messages;

Push the JSON message to the middleware.

In a possible design, the information push module is also configured to: after pushing the data message to the middleware, obtain a data transfer log, and obtain a JSON node from the data transfer log ;

Obtain the node message corresponding to the JSON node, and determine whether the message format of the node message is complete;

If the message format of the node message is incomplete, the monitoring data corresponding to the node message is retransmitted.

In a possible design, the information acquisition module is also configured to: after obtaining the monitoring information corresponding to the business to be monitored, obtain the numerical interval corresponding to the business monitoring indicator;

According to the monitoring data and numerical intervals corresponding to the business monitoring indicators, the monitoring results of the business monitoring indicators are obtained, where the monitoring results include normal indicators and abnormal indicators.

In a possible design, the middleware includes a message queue and a message partition.

In a possible design, the information push module is specifically used to:

Obtain the target monitoring information corresponding to the preset core business, and use the target monitoring information corresponding to the core business as the core monitoring information;

Push the core monitoring information to a target message queue of the second terminal, where the target message queue is a message queue corresponding to the preset core service.

In a third aspect, an embodiment of the present invention provides a terminal device, including: at least one processor and a memory;

The memory stores computer execution instructions;

The at least one processor executes the computer execution instructions stored in the memory, so that the at least one processor executes the information processing method according to any one of the first aspects.

In a fourth aspect, embodiments of the present invention provide a computer-readable storage medium. Computer-executable instructions are stored in the computer-readable storage medium. When a processor executes the computer-executable instructions, any one of the aspects of the first aspect is implemented. The information processing method described.

Embodiments of the present invention provide an information processing method, device and terminal equipment. The method unifies the storage format of the monitoring data corresponding to the business monitoring indicators according to the indicator type corresponding to the business monitoring indicators, so that the storage of the monitoring data can be unified. The format is unified, and the target monitoring information after the unified storage format is pushed to the middleware of the second terminal, so that the middleware can promptly send the target monitoring information to the client that needs to monitor the data, improving the efficiency of data transmission. Speed, and because the target monitoring information has been unified in storage format, whether the second terminal or the client stores the target monitoring information, there is no need to process it before storing it, which improves the efficiency of data storage.

Description of the drawings

In order to explain the embodiments of the present invention or the technical solutions in the prior art more clearly, the drawings needed to be used in the description of the embodiments or the prior art will be briefly introduced below. Obviously, the drawings in the following description are only These are some embodiments of the present invention. For those of ordinary skill in the art, other drawings can be obtained based on these drawings without exerting any creative effort.

Figure 1 is a schematic architectural diagram of an information processing system provided by an embodiment of the present invention;

Figure 2 is a flow chart 1 of an information processing method provided by an embodiment of the present invention;

Figure 3 is a flow chart 2 of the information processing method provided by the embodiment of the present invention;

Figure 4 is a schematic structural diagram of an information processing device provided by an embodiment of the present invention;

Figure 5 is a schematic diagram of the hardware structure of a terminal device provided by 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 only some of the embodiments of the present invention, rather than all 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 fall within the scope of protection of the present invention.

The terms "first", "second", "third", "fourth", etc. (if present) in the description and claims of the present invention and the above-mentioned drawings are used to distinguish similar objects and are not necessarily used to Describe a specific order or sequence. It is to be understood that the figures so used are interchangeable under appropriate circumstances so that the embodiments of the invention described herein, for example, can be practiced in sequences other than those illustrated or described herein. In addition, the terms "including" and "having" and any variations thereof are intended to cover non-exclusive inclusions, e.g., a process, method, system, product, or apparatus that encompasses a series of steps or units and need not be limited to those explicitly listed. Those steps or elements may instead include other steps or elements not expressly listed or inherent to the process, method, product or apparatus.

In the existing technology, in order to ensure that the business can run normally, it is necessary to configure the corresponding business monitoring indicators, monitor the business monitoring indicators, obtain the corresponding monitoring data, and send the monitoring data to the terminal that needs the monitoring data, so that the relevant personnel can It can be determined whether the business monitoring indicators are abnormal based on the monitoring data stored in the terminal, that is, whether there is an abnormality in the business, so that the abnormality can be handled in a timely manner. However, because there are many types of monitoring data and the format is complex, after the obtained monitoring data is directly sent to the terminal, The terminal also needs to format the monitoring data before it can be stored, and the efficiency of data storage is low.

In view of the problems existing in the prior art, this application proposes an information processing method, device and terminal equipment. The method is applied to the first terminal 101 in the information processing system as shown in Figure 1. The first terminal 101 monitors the The indicator type corresponding to the indicator, perform unified storage format processing on the monitoring data corresponding to the business monitoring indicator, so that the storage format of the monitoring data is unified, and push the target monitoring information after the unified storage format processing to the second terminal 102 in the middleware, so that the middleware can promptly send the target monitoring information to the client 103 that needs to monitor data, improving the speed of data transmission, and because the target monitoring information has been unified in storage format, no matter it is the second terminal When the client stores the target monitoring information, it does not need to process it before storing it, which improves the efficiency of data storage.

The technical solution of the present invention will be described in detail below with specific examples. The following specific embodiments can be combined with each other, and the same or similar concepts or processes may not be described again in some embodiments.

Figure 2 is a flow chart of an information processing method provided by an embodiment of the present invention. The execution subject of this embodiment can be the first terminal in the embodiment shown in Figure 1. This embodiment is not particularly limited here. As shown in Figure 2, the method of this embodiment may include:

S201. Obtain monitoring information corresponding to the business to be monitored, where the monitoring information includes business monitoring indicators and corresponding monitoring data.

In this embodiment, relevant monitoring software or equipment performs real-time or scheduled monitoring of the business to be monitored, obtains corresponding monitoring information, realizes automatic collection of monitoring information, and sends the obtained monitoring information to the first terminal. The monitoring information includes business Monitoring indicators and monitoring data corresponding to each business monitoring indicator.

Among them, the business monitoring indicators corresponding to the business to be monitored are pre-set by relevant personnel according to actual needs. For example, the business monitoring indicators include running memory occupied, access rate and other indicators.

Among them, the business to be monitored can be the business in the system based on the hybrid cloud platform architecture.

After obtaining the monitoring data corresponding to each business monitoring indicator, you can also determine whether there is an abnormality in the business monitoring indicator based on the monitoring data corresponding to the business monitoring indicator. The specific process is: obtain the value range corresponding to the business monitoring indicator, and based on the corresponding value range of the business monitoring indicator Monitor data and numerical intervals to obtain monitoring results of business monitoring indicators, where the monitoring results include normal indicators and abnormal indicators.

In this embodiment, the numerical interval corresponding to the first business monitoring indicator is obtained. The first business monitoring indicator is any one of the business monitoring indicators included in the monitoring information. According to the monitoring corresponding to the first business monitoring indicator The data and numerical range determine whether there is an abnormality in the first business monitoring indicator, that is, the monitoring result corresponding to the first business monitoring indicator is obtained. When the monitoring result is an abnormal indicator, alarm information can be generated in time and sent to the relevant terminal or management personnel, so as to This enables relevant personnel to promptly solve the problems existing in the business corresponding to the first business monitoring indicator based on the alarm information. There is no need for subsequent manual work to determine whether there are abnormalities in the business monitoring indicators based on the monitoring data, thereby improving the efficiency of abnormal determination and improving problem resolution. efficiency.

Among them, the numerical interval corresponding to the business monitoring indicator is determined based on the historical monitoring data corresponding to the business monitoring indicator. For example, the maximum value and the minimum value are determined based on the historical monitoring data, and the business monitoring indicator is determined based on the minimum value and maximum value. The corresponding fluctuation range of the monitoring data is used to obtain the numerical interval. When the monitoring data is not within the numerical interval, the possibility of problems with the monitoring data is greater.

The specific process of determining whether there is an abnormality in the first business monitoring indicator based on the monitoring data and the numerical range corresponding to the first business monitoring indicator may be: counting the number of monitoring data that is not within the numerical range, and obtaining the first number. If the first number is If a number is greater than the first preset number, it is determined that the monitoring result is that the indicator is abnormal. If the first number is less than or equal to the first preset number, it is determined that the monitoring result is that the indicator is normal.

In order to ensure the availability and accuracy of the monitoring data, when the first number is less than or equal to the first preset number, abnormal data in the monitoring data can be removed, that is, monitoring data that is not within the value range can be removed.

S202. Obtain the indicator type of the business monitoring indicator.

In this embodiment, since there are many types of business monitoring indicators, in order to facilitate the client to obtain, store and utilize monitoring data, the storage format of the same type of monitoring data can be unified, that is, the storage format of the same type of monitoring data can be unified. Carry out unified processing. When unifying the storage format of monitoring data, it is necessary to use the indicator types corresponding to the obtained business monitoring indicators.

When obtaining the indicator type of the business monitoring indicator, the indicator type corresponding to the business monitoring indicator can be obtained from a preset storage location, or the monitoring information can also directly include the indicator type corresponding to the business monitoring indicator.

S203. According to the indicator type of the business monitoring indicator, perform unified storage format processing on the monitoring data corresponding to the business monitoring indicator to obtain target monitoring information.

In this embodiment, according to the indicator type of each business monitoring indicator, the storage format of the monitoring data corresponding to the business monitoring indicator is unified to obtain the target monitoring information. The target monitoring information includes the business monitoring indicator and its corresponding unified processing. subsequent monitoring data.

S204. Push the target monitoring information to the middleware of the second terminal, so that the second terminal obtains the client that subscribes to the target monitoring information and sends the target monitoring information to the client.

In this embodiment, the target monitoring information is pushed to the middleware of the second terminal. After the middleware in the second terminal obtains the client that subscribes to the target monitoring information, it sends the target monitoring information to the client to achieve Data synchronization and sharing.

Among them, middleware includes message partitioning and message queue.

For non-core services, when pushing the target monitoring information to the middleware of the second terminal, the target monitoring information corresponding to the non-core services is actually pushed to the message partition in KAFKA. When pushing the target monitoring information to the message partition, the Data Transmission Service (DTS) can be used to achieve this, which can increase the speed of data transmission without occupying a large amount of system resources during the transmission process.

In order to enable the second terminal to transmit monitoring data to the client in PULL mode, the second terminal uses MYSQL as the bridge data pool and sets the flag bits corresponding to each business monitoring indicator in the MYSQL database. When the monitoring data corresponding to the business monitoring indicators is obtained, After reading the data, the flag bit corresponding to the business monitoring indicator is 1, otherwise it will be 0. When the target monitoring information needs to be sent to the client, KAFKA transmits the monitoring data to the client in PULL mode through the MYSQL database.

For the core business, when pushing the target monitoring information to the middleware of the second terminal, the target monitoring information corresponding to the core business is actually pushed to the exclusive queue corresponding to the core business. The specific process is: Obtain the preset core business Corresponding target monitoring information, and use the target monitoring information corresponding to the core business as core monitoring information. Push the core monitoring information to the target message queue of the second terminal, where the target message queue is a message queue corresponding to the preset core business.

In this embodiment, after obtaining the monitoring information corresponding to each business to be monitored, the target monitoring information corresponding to the preset core business is obtained, and the target monitoring information is used as the core monitoring information, and the relevant components are called to make the target monitoring information The component pushes the core monitoring information to the target message queue, that is, to its exclusive message queue, so that the client can consume the core monitoring information in time, effectively ensuring the timeliness of the data and greatly improving the transmission speed.

Among them, the core business can be an important business set by relevant personnel according to actual needs or a business with high real-time requirements.

Optionally, in order to detect abnormalities in the core business in a timely manner and ensure the continuity of monitoring, you can also set up buried points in the core business, collect buried point logs, and detect whether there are abnormal log information in the buried point logs. If there are abnormal logs, information, the alarm information is generated and sent to the manager or relevant terminal. The alarm information includes the identification of the abnormal business, so that the manager can promptly handle the problem based on the alarm information.

Optionally, push the target monitoring information to the middleware of the second terminal, including:

Encapsulate the monitoring data in the target monitoring information according to the preset JSON message format and obtain multiple JSON messages. Push the JSON message to the middleware.

In this embodiment, after obtaining the target monitoring information, the monitoring data corresponding to each business monitoring indicator in the target monitoring information can be encapsulated according to the preset JSON message format, and a JSON message corresponding to each business monitoring indicator can be generated, and Transmit the generated JSON message to the middleware of the second terminal.

In order to ensure the accuracy, integrity, and continuity of the monitoring data, during the process of pushing the JSON message to the middleware of the second terminal, the data transfer log can be obtained, and the JSON node can be obtained from the data transfer log. Obtain the node message corresponding to the JSON node and determine whether the message format of the node message is complete. If the message format of the node message is incomplete, the monitoring data corresponding to the node message is retransmitted.

In this embodiment, during the process of transmitting the JSON message to the second terminal, a corresponding data transmission log will be generated, and each JSON message will be used as a JSON node. Correspondingly, the data transmission log includes multiple JSON nodes. Each JSON node also corresponds to a node message. Compare the preset JSON message format with the message format corresponding to the node message to determine whether the message format corresponding to the node message is complete. If the The message format of the node message is incomplete, which means that the monitoring data corresponding to the node message is abnormal and an abnormal breakpoint occurs, and the monitoring data corresponding to the node message needs to be retransmitted.

Among them, the node message is actually a JSON message.

Optionally, you can also determine whether the monitoring data corresponding to the node message is legal. If it is not legal, you also need to retransmit the monitoring data corresponding to the node. When judging whether the monitoring data is legal, you can determine whether there are special data in the monitoring data. character or whether it is empty. For example, if the monitoring data should all be numeric characters, but there are special characters such as # in the monitoring data corresponding to the node message, it is determined that the monitoring data corresponding to the node message is illegal and needs to be retransmitted. .

Optionally, after determining the monitoring data corresponding to the node messages that need to be retransmitted, they can be retransmitted in batches or one by one.

As can be seen from the above description, according to the indicator type corresponding to the business monitoring indicator, the storage format of the monitoring data corresponding to the business monitoring indicator is unified, so that the storage format of the monitoring data is unified, and the target after the storage format is unified The monitoring information is pushed to the middleware of the second terminal, so that the middleware can promptly send the target monitoring information to the client that needs to monitor data, improving the speed of data transmission, and because the target monitoring information has been unified in storage format , when the second terminal or the client stores the target monitoring information, there is no need to process it before storing it, which improves the efficiency of data storage.

In order to facilitate the client to store and utilize monitoring data, similar monitoring data can be stored in a unified storage format. The process of unified storage format processing of monitoring data will be described in detail below with reference to a specific embodiment.

Figure 3 is a flow chart 2 of the speech processing method provided by the embodiment of the present invention. As shown in Figure 3, on the basis of the above embodiment, the specific implementation process of unifying the storage format of monitoring data is described in detail. As shown in Figure 3, the method includes:

S301. Obtain monitoring information corresponding to the business to be monitored, where the monitoring information includes business monitoring indicators and corresponding monitoring data.

S302. Obtain the indicator type of the business monitoring indicator.

Among them, S301-S302 are similar to S201-S202 in the embodiment of FIG. 2, and will not be described again here.

S303. Classify the business monitoring indicators to obtain multiple indicator sets, where the indicator sets include business monitoring indicators of the same indicator type.

In this embodiment, the business monitoring indicators are classified according to the indicator type of each business monitoring indicator, and the business monitoring indicators with the same indicator type are regarded as an indicator set, that is, the indicator type of the business monitoring indicators included in an indicator set is same.

When the business monitoring indicators are the same, it means that the corresponding monitoring data belongs to the same type of data, and the monitoring data can be unified according to the same storage format.

S304. For each indicator set, obtain the standard storage format corresponding to the indicator set, and perform unified storage format processing on the monitoring data corresponding to each business monitoring indicator in the indicator set according to the standard storage format. The storage format unified processing includes At least one of unit unification processing, file occupation space unification processing, and accuracy unification processing.

In this embodiment, the standard storage format corresponding to the first indicator set is obtained and used as the first storage format. The first indicator set is any indicator set in each indicator set, and the storage format corresponding to the first indicator set is obtained, The storage format corresponding to the first indicator set is actually the storage format corresponding to the indicator type of the first indicator set. According to the standard of the first storage format, the first monitoring data corresponding to each business monitoring indicator in the first indicator set is subjected to storage format unification processing. The storage format unification processing includes unit unification processing and file occupied space unification processing. and precision are processed uniformly.

Among them, the obtained monitoring data actually exists in the form of files, that is, the obtained monitoring data is actually files containing monitoring data. The storage format represents the standard for monitoring data storage, such as the precision of storage, the unit of storage, and the file usage size, that is, the space occupied by the file.

The unit unification process refers to unifying the units of each first monitoring data into the units corresponding to the first storage format. For example, the unit of some first monitoring data is seconds, and the unit of some first monitoring data is minutes. The unit corresponding to the first storage format is seconds, so the units of all first monitoring data need to be unified into seconds.

Among them, the unification process of file occupied space refers to unifying the storage space occupied by each first monitoring data, that is, unifying the storage space occupied by the first file containing the first monitoring data. For example, some first files The occupied storage space is 100M, some first files occupy 200M, and the files corresponding to the first storage format occupy 150M, so the space occupied by all first files needs to be unified to 150M.

The accuracy unification process refers to unifying the accuracy of each first monitoring data. For example, the accuracy of some first monitoring data is two decimal places, and the accuracy of some first monitoring data is three decimal places. The accuracy corresponding to a storage format is two decimal places, so the accuracy of all first monitoring data needs to be unified to two decimal places.

Optionally, the storage format unification processing also includes data format unification processing. For example, the data format of the first file containing the first monitoring data, that is, the file type is unified. For example, some data of the first file The format is doc format. The data format of some first files is txt format. The data format corresponding to the first storage format is doc format. Therefore, the data format of all first files needs to be unified into doc format.

In this embodiment, after the storage format of monitoring data with the same indicator type is unified, the storage format of the monitoring data can be unified, so that the second terminal and the client can directly obtain, store and utilize the monitoring data without having to modify the monitoring data. storage format for processing.

S305. Push the target monitoring information to the middleware of the second terminal, so that the second terminal obtains the client that subscribes to the target monitoring information and sends the target monitoring information to the client.

Among them, S305 is similar to S204 in the embodiment of FIG. 2, and will not be described again here.

Figure 4 is a schematic structural diagram of an information processing device provided by an embodiment of the present invention. As shown in Figure 4, the information processing device 400 provided by this embodiment may include: an information acquisition module 401, a type acquisition module 402, a type acquisition module 403 and Information push module 404.

Among them, the information acquisition module 401 is used to obtain monitoring information corresponding to the business to be monitored, where the monitoring information includes business monitoring indicators and their corresponding monitoring data.

The type acquisition module 402 is used to obtain the indicator type of the business monitoring indicator.

The information processing module 403 is used to unify the storage format of the monitoring data corresponding to the business monitoring indicators according to the indicator type of the business monitoring indicators to obtain target monitoring information.

The information push module 404 is used to push the target monitoring information to the middleware of the second terminal, so that the second terminal obtains the client that subscribes to the target monitoring information and sends the target monitoring information to the client.

In one possible design, the information processing module is specifically used to:

Classify the business monitoring indicators to obtain multiple indicator sets, where the indicator sets include business monitoring indicators of the same indicator type.

For each indicator set, the standard storage format corresponding to the indicator set is obtained. According to the standard storage format, the storage format is unified for the monitoring data corresponding to each business monitoring indicator in the indicator set. The storage format unification includes unit unification. At least one of normalization processing, file occupation space unification processing, and accuracy unification processing.

In one possible design, the information push module is specifically used to:

Encapsulate the monitoring data in the target monitoring information according to the preset JSON message format and obtain multiple JSON messages.

Push the JSON message to the middleware.

In a possible design, the information push module is also used to obtain the data transfer log after pushing the data message to the middleware, and obtain the JSON node from the data transfer log.

Obtain the node message corresponding to the JSON node and determine whether the message format of the node message is complete.

If the message format of the node message is incomplete, the monitoring data corresponding to the node message is retransmitted.

In a possible design, the information acquisition module is also used to: after acquiring the monitoring information corresponding to the business to be monitored, acquire the numerical interval corresponding to the business monitoring indicator.

According to the monitoring data and numerical intervals corresponding to the business monitoring indicators, the monitoring results of the business monitoring indicators are obtained, where the monitoring results include normal indicators and abnormal indicators.

In one possible design, the middleware includes message queues and message partitions.

In one possible design, the information push module is specifically used to:

Obtain the target monitoring information corresponding to the preset core business, and use the target monitoring information corresponding to the core business as the core monitoring information.

Push the core monitoring information to the target message queue of the second terminal, where the target message queue is a message queue corresponding to the preset core business.

The information processing device provided by the embodiment of the present invention can implement the method of the above embodiment. The implementation principles and technical effects are similar and will not be described again here.

Figure 5 is a schematic diagram of the hardware structure of a terminal device provided by an embodiment of the present invention. As shown in Figure 5, the terminal device 500 provided in this embodiment includes: at least one processor 501 and a memory 502. Among them, the processor 501 and the memory 502 are connected through a bus 503.

During specific implementation, at least one processor 501 executes computer execution instructions stored in memory 502, so that at least one processor 501 executes the information processing method in the above method embodiment.

The specific implementation process of the processor 501 can be found in the above-mentioned method embodiments. The implementation principles and technical effects are similar and will not be described again in this embodiment.

In the above-mentioned embodiment shown in Figure 5, it should be understood that the processor may be a central processing unit (English: Central Processing Unit, referred to as: CPU), or other general-purpose processor, digital signal processor (English: Digital Signal Processor) Signal Processor (DSP for short), Application Specific Integrated Circuit (English: Application Specific Integrated Circuit (ASIC for short)), etc. A general-purpose processor may be a microprocessor or the processor may be any conventional processor, etc. The steps of the method disclosed in conjunction with the invention can be directly embodied and executed by a hardware processor, or executed by a combination of hardware and software modules in the processor.

The memory may include high-speed RAM memory and may also include non-volatile storage NVM, such as at least one disk memory.

The bus may be an Industry Standard Architecture (Industry Standard Architecture, ISA) bus, a Peripheral Component Interconnect (PCI) bus, or an Extended Industry Standard Architecture (Extended Industry Standard Architecture, EISA) bus, etc. The bus can be divided into address bus, data bus, control bus, etc. For ease of presentation, the bus in the drawings of this application is not limited to only one bus or one type of bus.

Embodiments of the present invention also provide a computer-readable storage medium. Computer-executable instructions are stored in the computer-readable storage medium. When the processor executes the computer-executable instructions, the information processing method of the above method embodiment is implemented.

The above-mentioned computer-readable storage medium, the above-mentioned readable storage medium can be implemented by any type of volatile or non-volatile storage device or their combination, such as static random access memory (SRAM), electrically erasable memory. Programmable read-only memory (EEPROM), erasable programmable read-only memory (EPROM), programmable read-only memory (PROM), read-only memory (ROM), magnetic memory, flash memory, magnetic or optical disk. Readable storage media can be any available media that can be accessed by a general purpose or special purpose computer.

An exemplary readable storage medium is coupled to the processor such that the processor can read information from the readable storage medium and write information to the readable storage medium. Of course, the readable storage medium may also be an integral part of the processor. The processor and the readable storage medium may be located in Application Specific Integrated Circuits (ASIC). Of course, the processor and the readable storage medium may also exist as discrete components in the device.

Persons of ordinary skill in the art can understand that all or part of the steps to implement the above method embodiments can be completed by hardware related to program instructions. The aforementioned program can be stored in a computer-readable storage medium. When the program is executed, the steps including the above-mentioned method embodiments are executed; and the aforementioned storage media include: ROM, RAM, magnetic disks, optical disks and other media that can store program codes.

Finally, it should be noted that the above embodiments are only used to illustrate the technical solution of the present invention, but not to limit it. Although the present invention has been described in detail with reference to the foregoing embodiments, those of ordinary skill in the art should understand that: The technical solutions described in the foregoing embodiments can still be modified, or some or all of the technical features can be equivalently replaced; and these modifications or substitutions do not deviate from the essence of the corresponding technical solutions from the technical solutions of the embodiments of the present invention. scope.

Claims (5)

1. An information processing method, characterized by comprising:

acquiring monitoring information corresponding to a service to be monitored, wherein the monitoring information comprises a service monitoring index and corresponding monitoring data thereof;

acquiring the index type of the service monitoring index;

classifying the service monitoring indexes to obtain a plurality of index sets, wherein each index set comprises service monitoring indexes with the same index type;

for each index set, acquiring a standard storage format corresponding to the index set, and carrying out storage format unification processing on monitoring data corresponding to each service monitoring index in the index set according to the standard storage format to obtain target monitoring information, wherein the storage format unification processing comprises unit unification processing, file occupation space unification processing and precision unification processing;

pushing the target monitoring information to a middleware of a second terminal, so that the second terminal obtains a client subscribing the target monitoring information, and sending the target monitoring information to the client, wherein the middleware comprises a message queue and a message partition;

the pushing the target monitoring information to the middleware of the second terminal comprises the following steps:

acquiring target monitoring information corresponding to a preset core service, and taking the target monitoring information corresponding to the core service as core monitoring information;

encapsulating the core monitoring information according to a preset JSON message format to obtain a plurality of JSON messages;

pushing the JSON message to a target message queue of a second terminal, wherein the target message queue is a message queue corresponding to the preset core service, so that the second terminal obtains a client subscribing the target monitoring information and sends the target monitoring information to the client;

after pushing the JSON message to the target message queue of the second terminal, the method further includes:

acquiring a data transmission log, and acquiring a JSON node from the data transmission log;

acquiring a node message corresponding to the JSON node, and judging whether the message format of the node message is complete;

and if the message format of the node message is incomplete, retransmitting the monitoring data corresponding to the node message.

2. The method according to claim 1, further comprising, after the obtaining the monitoring information corresponding to the service to be monitored:

acquiring a numerical interval corresponding to the service monitoring index;

and obtaining a monitoring result of the service monitoring index according to the monitoring data and the numerical interval corresponding to the service monitoring index, wherein the monitoring result comprises normal index and abnormal index.

3. An information processing apparatus, characterized by comprising:

the information acquisition module is used for acquiring monitoring information corresponding to the service to be monitored, wherein the monitoring information comprises service monitoring indexes and corresponding monitoring data thereof;

the type acquisition module is used for acquiring the index type of the service monitoring index;

information processing module for

Classifying the service monitoring indexes to obtain a plurality of index sets, wherein each index set comprises service monitoring indexes with the same index type;

for each index set, acquiring a standard storage format corresponding to the index set, and carrying out storage format unification processing on monitoring data corresponding to each service monitoring index in the index set according to the standard storage format to obtain target monitoring information, wherein the storage format unification processing comprises unit unification processing, file occupation space unification processing and precision unification processing;

information pushing module for

Pushing the target monitoring information to a middleware of a second terminal, so that the second terminal obtains a client subscribing the target monitoring information, and sending the target monitoring information to the client, wherein the middleware comprises a message queue and a message partition;

the information pushing module is particularly used for

Acquiring target monitoring information corresponding to a preset core service, and taking the target monitoring information corresponding to the core service as core monitoring information;

encapsulating the core monitoring information according to a preset JSON message format to obtain a plurality of JSON messages;

pushing the JSON message to a target message queue of a second terminal, wherein the target message queue is a message queue corresponding to the preset core service, so that the second terminal obtains a client subscribing the target monitoring information and sends the target monitoring information to the client;

the information pushing module is also used for

After pushing the JSON message to a target message queue of a second terminal, acquiring a data transmission log, and acquiring a JSON node from the data transmission log;

acquiring a node message corresponding to the JSON node, and judging whether the message format of the node message is complete;

and if the message format of the node message is incomplete, retransmitting the monitoring data corresponding to the node message.

4. A terminal device, comprising: at least one processor and memory;

the memory stores computer-executable instructions;

the at least one processor executing computer-executable instructions stored in the memory causes the at least one processor to perform the information processing method of claim 1 or 2.

5. A computer-readable storage medium, in which computer-executable instructions are stored, which when executed by a processor, implement the information processing method according to claim 1 or 2.