CN115309612B - Method and device for monitoring data - Google Patents
Method and device for monitoring data Download PDFInfo
- Publication number
- CN115309612B CN115309612B CN202211231159.5A CN202211231159A CN115309612B CN 115309612 B CN115309612 B CN 115309612B CN 202211231159 A CN202211231159 A CN 202211231159A CN 115309612 B CN115309612 B CN 115309612B
- Authority
- CN
- China
- Prior art keywords
- index
- change
- target
- monitoring
- monitoring index
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000012544 monitoring process Methods 0.000 title claims abstract description 339
- 238000000034 method Methods 0.000 title claims abstract description 56
- 230000008859 change Effects 0.000 claims abstract description 201
- 238000010276 construction Methods 0.000 claims description 20
- 230000008569 process Effects 0.000 claims description 13
- 238000004590 computer program Methods 0.000 claims description 11
- 238000012508 change request Methods 0.000 claims description 9
- 230000008878 coupling Effects 0.000 abstract description 6
- 238000010168 coupling process Methods 0.000 abstract description 6
- 238000005859 coupling reaction Methods 0.000 abstract description 6
- 238000005516 engineering process Methods 0.000 abstract description 3
- 238000010586 diagram Methods 0.000 description 8
- 238000012545 processing Methods 0.000 description 8
- 238000004891 communication Methods 0.000 description 6
- 230000006870 function Effects 0.000 description 6
- 238000012986 modification Methods 0.000 description 4
- 230000004048 modification Effects 0.000 description 4
- 230000003287 optical effect Effects 0.000 description 4
- 230000008901 benefit Effects 0.000 description 2
- 239000000835 fiber Substances 0.000 description 2
- 238000012806 monitoring device Methods 0.000 description 2
- 230000000644 propagated effect Effects 0.000 description 2
- 239000004065 semiconductor Substances 0.000 description 2
- 239000002131 composite material Substances 0.000 description 1
- 238000013481 data capture Methods 0.000 description 1
- 238000012217 deletion Methods 0.000 description 1
- 230000037430 deletion Effects 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 230000006872 improvement Effects 0.000 description 1
- 238000003780 insertion Methods 0.000 description 1
- 230000037431 insertion Effects 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
- 239000013307 optical fiber Substances 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/3003—Monitoring arrangements specially adapted to the computing system or computing system component being monitored
- G06F11/302—Monitoring arrangements specially adapted to the computing system or computing system component being monitored where the computing system component is a software system
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/3065—Monitoring arrangements determined by the means or processing involved in reporting the monitored data
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- Computing Systems (AREA)
- Quality & Reliability (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Mathematical Physics (AREA)
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The invention discloses a method and a device for monitoring data, and relates to the technical field of financial science and technology. One embodiment of the method comprises: the change information of the target monitoring index can be determined, and the changed index value is analyzed; searching a target strategy matched with the target monitoring index from preset changing strategies of various monitoring indexes; and judging whether the changed index value has risk or not based on the target strategy. By determining the change information of the target monitoring index configured in the data source and judging the change risk, the problems of strong coupling and poor expansibility caused by the need of developing corresponding codes for monitoring the index are solved, the universality and flexibility of the monitoring data are improved, the consumption of the labor cost and the time cost of the monitoring data is reduced, the efficiency of the monitoring data is improved, and the efficiency of monitoring the operation risk is improved.
Description
Technical Field
The invention relates to the technical field of financial science and technology, in particular to a method and a device for monitoring data.
Background
When an application system is developed, the security of monitoring data is an important component in the development, and especially in the case that data processed by the application system is financial data, the legality and compliance of the monitoring data and the data processing process are particularly important.
When data is changed, it is usually necessary to monitor whether there is a risk of the change of the data, including monitoring whether there is a risk of performing an operation of changing the data; the existing data monitoring method is to add monitoring codes to corresponding monitoring data, and the existing method has the problems of strong code coupling, low flexibility and poor expansibility of the monitoring data, especially under the condition of large data volume of the data to be monitored, the consumption of manpower and time cost is improved, and the efficiency of monitoring data and monitoring operation risk is reduced.
Disclosure of Invention
In view of this, embodiments of the present invention provide a method and an apparatus for monitoring data, which can determine change information of a target monitoring index, and analyze a changed index value; searching a target strategy matched with the target monitoring index from preset changing strategies of multiple monitoring indexes; and judging whether the changed index value has risk or not based on the target strategy. By determining the change information of the target monitoring index configured in the data source and judging the change risk, the problems of strong coupling and poor expansibility caused by the need of developing a corresponding code for the monitoring index are solved, the universality and flexibility of the monitoring data are improved, the consumption of the labor cost and the time cost of the monitoring data is reduced, and the efficiency of the monitoring data and the monitoring operation risk is improved.
To achieve the above object, according to an aspect of an embodiment of the present invention, there is provided a method of monitoring data, including: determining change information of a target monitoring index configured in a data source, and analyzing a changed index value in the change information; searching a target strategy matched with the target monitoring index from preset changing strategies of various monitoring indexes; and under the condition that the changed index value is determined to have risk based on the target strategy, sending the index value before the change of the target monitoring index and the changed index value to a management end of the target monitoring index.
Optionally, the method for monitoring data further includes: monitoring a data source to which one or more configured monitoring indexes belong by using a preset middleware, and determining the changed monitoring indexes as the target monitoring indexes under the condition that the monitoring indexes contained in the data source are changed.
Optionally, the method for monitoring data further includes: storing the determined target monitoring index and the change information of the target monitoring index into a message queue through the middleware; and executing the step of determining the change information of the target monitoring index configured in the data source and analyzing the changed index value in the change information through the message queue.
Optionally, the method for monitoring data further includes: setting a message queue with a plurality of themes; the storing the target monitoring index and the change information of the target monitoring index to a message queue includes: and storing the target monitoring index and the change information of the target monitoring index into a message queue under a theme matched with the target monitoring index.
Optionally, the method for monitoring data further includes: receiving a construction request of a change strategy of a monitoring index, and analyzing construction data from the construction request, wherein the construction data comprises a monitoring index identifier, a plurality of index information corresponding to the monitoring index identifier, and a risk range corresponding to each index information; generating a preset change strategy corresponding to the monitoring index based on the construction data, and storing the change strategy; searching a target strategy matched with the target monitoring index from a plurality of preset change strategies of various monitoring indexes; the method comprises the following steps: searching a target index identification matched with the target monitoring index from the plurality of change strategies, and taking the change strategy corresponding to the target index identification as the target strategy matched with the target monitoring index.
Optionally, the method for monitoring data further includes: receiving a change request of a change strategy aiming at any one or more monitoring indexes, and analyzing change data from the change request, wherein the change data comprises monitoring index identifications to be changed, one or more change index information corresponding to the monitoring index identifications to be changed, and change risk ranges corresponding to the change index information; and storing the changed change strategy based on the change strategy corresponding to the change data change.
Optionally, the method for monitoring data further includes: acquiring index information matched with the target monitoring index in the target strategy and a risk range corresponding to the index information according to the target monitoring index identifier; and under the condition that any index information of the target monitoring index does not meet the corresponding risk range, determining that the target monitoring index has risk.
Optionally, the sending the pre-change index value and the post-change index value of the target monitoring index to the management end of the target monitoring index includes: determining a change prompt template matched with the type of the monitoring index; adding the index value before the change, the index value after the change and the risk range corresponding to the index value after the change of the target monitoring index to the change prompt template to generate a target template; and sending the target template to a management end of the target monitoring index so that the management end processes the target monitoring index.
To achieve the above object, according to a second aspect of an embodiment of the present invention, there is provided an apparatus for monitoring data, including: the system comprises an index determining module, a strategy determining module and a risk determining module; wherein,
the index determining module is used for determining change information of a target monitoring index configured in a data source and analyzing a changed index value in the change information;
the strategy determining module is used for searching a target strategy matched with the target monitoring index from preset changing strategies of various monitoring indexes;
and the risk determining module is used for sending the index value before the change of the target monitoring index and the index value after the change to a management end of the target monitoring index under the condition that the changed index value is determined to have risk based on the target strategy.
Optionally, the apparatus for monitoring data is further configured to monitor, by using a preset middleware, a data source to which one or more configured monitoring indexes belong, and determine, when it is monitored that a monitoring index included in the data source changes, the changed monitoring index as the target monitoring index.
Optionally, the device for monitoring data is further configured to store the determined target monitoring index and the change information of the target monitoring index in a message queue through the middleware; and executing the step of determining the change information of the target monitoring index configured in the data source and analyzing the changed index value in the change information through the message queue.
Optionally, the device for monitoring data is further configured to set a message queue with multiple topics; the storing the target monitoring index and the change information of the target monitoring index to a message queue includes: and storing the target monitoring index and the change information of the target monitoring index into a message queue under a theme matched with the target monitoring index.
Optionally, the data monitoring device is further configured to receive a construction request of a change policy of a monitoring index, and parse construction data from the construction request, where the construction data includes a monitoring index identifier, a plurality of index information corresponding to the monitoring index identifier, and a risk range corresponding to each of the index information; generating a preset change strategy corresponding to the monitoring index based on the construction data, and storing the change strategy; searching a target strategy matched with the target monitoring index from a plurality of preset change strategies of various monitoring indexes; the method comprises the following steps: searching a target index identification matched with the target monitoring index from the plurality of change strategies, and taking the change strategy corresponding to the target index identification as the target strategy matched with the target monitoring index.
Optionally, the device for monitoring data is further configured to receive a change request of a change policy for any one or more monitoring indicators, and analyze change data from the change request, where the change data includes an identifier of a monitoring indicator to be changed, one or more pieces of change indicator information corresponding to the identifier of the monitoring indicator to be changed, and a change risk range corresponding to the change indicator information; and storing the changed change strategy based on the change strategy corresponding to the change data change.
Optionally, the data monitoring device is further configured to obtain, according to the target monitoring index identifier, index information matched with the target monitoring index in the target policy and a risk range corresponding to the index information; and under the condition that any index information of the target monitoring index does not meet the corresponding risk range, determining that the target monitoring index has risk.
Optionally, the apparatus for monitoring data further sends an index value before the change of the target monitoring index and the index value after the change to a management end of the target monitoring index, including: determining a change prompt template matched with the category of the monitoring index; adding the index value before the change of the target monitoring index, the index value after the change and the risk range corresponding to the index value after the change to the change prompt template to generate a target template; and sending the target template to a management end of the target monitoring index so that the management end processes the target monitoring index.
To achieve the above object, according to a third aspect of the embodiments of the present invention, there is provided an electronic device for monitoring data, including: one or more processors; a storage device for storing one or more programs which, when executed by the one or more processors, cause the one or more processors to implement a method as in any one of the above methods of monitoring data.
To achieve the above object, according to a fourth aspect of the embodiments of the present invention, there is provided a computer readable medium having a computer program stored thereon, wherein the program is configured to implement, when executed by a processor, any one of the above methods of monitoring data.
One embodiment of the above invention has the following advantages or benefits: the change information of the target monitoring index can be determined, and the changed index value is analyzed; searching a target strategy matched with the target monitoring index from preset changing strategies of various monitoring indexes; and judging whether the changed index value has risk or not based on the target strategy. By determining the change information of the target monitoring index configured in the data source and judging the change risk, the problems of strong coupling and poor expansibility caused by the need of developing corresponding codes for the monitoring index are solved, the universality and flexibility of the monitoring data are improved, the consumption of the labor cost and the time cost of the monitoring data is reduced, and the efficiency of the data volume monitoring is improved.
Further effects of the above-mentioned non-conventional alternatives will be described below in connection with the embodiments.
Drawings
The drawings are included to provide a better understanding of the invention and are not to be construed as unduly limiting the invention. Wherein:
FIG. 1 is a flow chart illustrating a method for monitoring data according to an embodiment of the present invention;
FIG. 2 is a schematic flow chart of monitoring data according to an embodiment of the present invention;
fig. 3 is a schematic structural diagram of an apparatus for monitoring data according to an embodiment of the present invention;
FIG. 4 is an exemplary system architecture diagram in which embodiments of the present invention may be employed;
fig. 5 is a schematic block diagram of a computer system suitable for use in implementing a terminal device or server of an embodiment of the invention.
Detailed Description
Exemplary embodiments of the present invention are described below with reference to the accompanying drawings, in which various details of embodiments of the invention are included to assist understanding, and which are to be considered as merely exemplary. Accordingly, those of ordinary skill in the art will recognize that various changes and modifications of the embodiments described herein can be made without departing from the scope and spirit of the invention. Also, descriptions of well-known functions and constructions are omitted in the following description for clarity and conciseness.
As shown in fig. 1, an embodiment of the present invention provides a method for monitoring data, which may include the following steps:
step S101: determining the change information of a target monitoring index configured in a data source, and analyzing the changed index value in the change information.
Specifically, the target monitoring index is a monitored index, and the monitored index may be one or more data configured in a data source, where the data source may be a database, a file, or the like; the invention does not limit the specific format of the data source. In the case that the data source is a database, the index identifier of the target monitoring index may exist in a single key value or a composite primary key. It is understood that the index identification of the target monitoring index can determine the change strategy associated with the target monitoring index.
By determining the change information of the target monitoring index configured in the data source, the data updating condition of the index to be monitored can be monitored in real time to obtain the change information of the target monitoring index, and the index value after the target monitoring index is changed is analyzed to judge whether the changed index value has risk.
The method for determining the change information of the target monitoring index configured in the data source is consistent with the descriptions of step S201 to step S203, and is not described herein again.
Step S102: and searching a target strategy matched with the target monitoring index from preset changing strategies of various monitoring indexes.
Specifically, a change strategy of various monitoring indexes can be preset; the change strategy comprises a monitoring index identifier, a plurality of index information corresponding to the monitoring index identifier and a risk range corresponding to each index information; for example: the change strategy A comprises a numerical value (namely an index value) marked as a monitoring index A and a numerical value risk range corresponding to the index value; for another example, the change policy B includes a processing time (i.e., an index value) identified as the monitoring index B and a risk time range corresponding to the processing time.
It can be understood that the change policy is used to determine whether the monitoring index corresponding to the change policy is at risk after the change.
Further, before a target strategy matched with the target monitoring index is searched from preset changing strategies of various monitoring indexes, the changing strategies of various monitoring indexes are constructed; specifically, the method for constructing the change strategy is to receive a construction request of the change strategy of the monitoring index, and analyze construction data from the construction request, wherein the construction data includes a monitoring index identifier, a plurality of index information corresponding to the monitoring index identifier, and a risk range corresponding to each index information; generating a preset change strategy corresponding to the monitoring index based on the construction data, and storing the change strategy;
further, searching a target strategy matched with the target monitoring index from preset changing strategies of various monitoring indexes; the method comprises the following steps: searching a target index identification matched with the target monitoring index from the plurality of change strategies, and taking the change strategy corresponding to the target index identification as the target strategy matched with the target monitoring index. For example: the preset change strategies of various monitoring indexes are stored in keys (index identifiers): value (change policy) is in the form of a monitoring index a: changing the strategy A; monitoring index B: changing the strategy B; monitoring index C: and changing the strategy C.
After determining change information of a monitoring index A (namely a target monitoring index), analyzing a changed index value in the change information; and determining a change strategy corresponding to the monitoring index A as a change strategy A from preset change strategies of various monitoring indexes. It can be understood that the preset change policy of the monitoring index includes a corresponding relationship between the monitoring index and the change policy, and the storing the change policy includes storing a corresponding relationship between the monitoring index and the change policy.
Furthermore, the change policy of multiple existing preset monitoring indexes can be changed (added, modified or deleted, etc.), that is, a change request of the change policy for any one or more monitoring indexes is received, and change data is analyzed from the change request, where the change data includes a monitoring index identifier to be changed, one or more pieces of change index information corresponding to the monitoring index identifier to be changed, and a change risk range corresponding to the change index information; and storing the changed change strategy based on the change strategy corresponding to the change data change. Specifically, the flow of the change is similar to the flow of constructing the change policy.
It can be understood that by constructing or changing a change strategy of the monitoring index, any index can be monitored without modifying a code, and the index value after the monitored monitoring index is changed is monitored to determine whether the changed index value has a risk, so that the flexibility, the expansibility and the universality of the monitoring index are improved to a greater extent. The efficiency of monitoring the index and monitoring the operation risk of the operation index is improved.
Further, the method for determining whether the monitoring index has the risk includes: acquiring index information matched with the target monitoring index in the target strategy and a risk range corresponding to the index information according to the target monitoring index identifier; and under the condition that any index information of the target monitoring index does not meet the corresponding risk range, determining that the target monitoring index has risk. For example: the change strategy corresponding to the monitoring index A is a target strategy A; the target policy a includes an index value (i.e., index information) of the monitoring index a and an index value range (i.e., risk range), for example, if the index value is quota data related to a transaction, it is determined that the monitoring index is at risk when the modified index value (e.g., the quota data is increased) of the monitoring index a exceeds the quota range (i.e., risk range) corresponding to the index value range, thereby determining that there is a risk in the operation on the monitoring index.
Step S103: and under the condition that the changed index value is determined to have risk based on the target strategy, sending the index value before the change of the target monitoring index and the changed index value to a management end of the target monitoring index.
Specifically, when determining that the changed index value has a risk by using a change policy, the index value before the change of the target monitoring index and the changed index value are sent to a management end of the target monitoring index.
Preferably, the sending the pre-change index value and the post-change index value of the target monitoring index to the management terminal of the target monitoring index includes: determining a change prompt template matched with the category of the monitoring index; adding the index value before the change of the target monitoring index, the index value after the change and the risk range corresponding to the index value after the change to the change prompt template to generate a target template; and sending the target template to a management end of the target monitoring index so that the management end processes the target monitoring index.
Specifically, different change prompt templates can be set for different types of monitoring indexes; for example: under the condition that the monitoring index is the transaction type, a transaction change prompt template is arranged; and when the monitoring index is a process node, a node change prompt template and the like are arranged.
Further, a corresponding change prompt template is searched according to the category of the monitoring index, for example, the change prompt template may include: and a monitoring index flag which changes the index value before the change to the index value after the change in a certain time range. Generating the target template for the monitoring index a may include: the abc value of the monitoring index a changes from "20%" to "50%" at x month x No. 19.
Further, the target template may be sent to a management end that monitors the monitoring index a through a mail, an instant message, a short message, software, and other tools, so that the management end processes the target monitoring index; and processing the target monitoring index comprises sending a risk prompt to a relevant manager so that the relevant manager can process the risk in time.
Therefore, by determining the change information of the monitoring index and judging whether the change information has risks based on the configured change strategy, the flexible processing of the monitoring data (including the monitoring operation risks) is realized under the condition that no code is required to be modified, and the universality and the expansibility of the monitoring data and the monitoring operation risks are improved.
As shown in fig. 2, an embodiment of the present invention provides a process for monitoring data, where the process may include the following steps:
step S201: monitoring a database to which one or more configured monitoring indexes belong by using a preset middleware, and determining the changed monitoring indexes as the target monitoring indexes under the condition that the monitoring indexes contained in the database are changed.
Specifically, in an embodiment of the present invention, the presetting of the middleware includes using a log-based CDC (Change Data Capture) technology, and when a database is changed (for example, a Change after operations such as insertion, update, and deletion) in general, the Change information is stored in a corresponding database log, and the Change information of the monitoring index included in the database can be acquired by monitoring the operation log corresponding to the database by using the CDC and analyzing the log information of the database. Therefore, the non-intrusive (i.e. without modifying codes) data monitoring method of the embodiment overcomes the problems of strong code coupling, low flexibility and poor expansibility of the monitored data in the existing method, especially improves the consumption of manpower and time cost under the condition of large data volume of the data to be monitored, and reduces the efficiency of monitoring the data.
Further, under the condition that the monitoring indexes contained in the database are judged to be changed, the changed monitoring indexes are determined to be the target monitoring indexes; it can be understood that, the log of the database can record the change of any data of the database, so when the change of the database is monitored, if the change of the monitoring index exists, the changed monitoring index is determined as the target monitoring index, so as to further judge the change information of the target monitoring index.
Step S202: and storing the determined target monitoring index and the change information of the target monitoring index into a message queue through the middleware.
Specifically, after the target monitoring index is determined, the change information of the target monitoring index is stored in a message queue (for example, a Kafka queue). In an embodiment of the present invention, the method for storing the change information of the target monitoring index in the message queue may send a JSON message containing the change information to the message queue; after receiving the JSON message, the message queue obtains JSON message parsing message content from the message queue to obtain a target monitoring index and change information (for example, including a changed index value and the like) of the target monitoring index, where the changed index value may be one or more of data types such as time range data, a numerical value, a text, a boolean value and the like. For example, the modified index value of the monitoring index B (i.e., the target monitoring index) is in the examination and approval time range, it is understood that the examination and approval time range set in the modification strategy corresponding to the monitoring index B is a legal range (i.e., a risk range), for example, from [ 8.
Further, a message queue with various themes is set; the storing the target monitoring index and the change information of the target monitoring index to a message queue includes: and storing the target monitoring index and the change information of the target monitoring index into a message queue under a theme matched with the target monitoring index. Specifically, for different topics associated with the monitoring index, message queues of multiple topics may be set, for example: a transaction subject message queue, an approval subject message queue and the like, namely, a plurality of target monitoring indexes are respectively processed according to different subjects; acquiring JSON message analysis message content from the message queue to obtain a target monitoring index, and acquiring JSON messages in the topic queue through subscribing the topic queue; therefore, the monitoring indexes can be classified and managed by dividing the topics into a plurality of topic queues, the complexity of monitoring data is reduced, and the efficiency of monitoring data is improved.
Step S203: and executing the step of determining the change information of the target monitoring index configured in the database through the message queue and analyzing the changed index value in the change information.
Specifically, a step of determining change information of a target monitoring index configured in a database and analyzing a changed index value in the change information is executed through a message queue; the description of the step of analyzing the changed index value in the change information about executing the change information for determining the target monitoring index configured in the database is consistent with step S101, and is not repeated here.
As shown in fig. 3, an embodiment of the present invention provides an apparatus 300 for monitoring data, including: an index determining module 301, a strategy determining module 302 and a risk determining module 303; wherein,
the index determining module 301 is configured to determine change information of a target monitoring index configured in a data source, and analyze a changed index value in the change information;
the policy determining module 302 is configured to search a target policy matched with the target monitoring index from among preset changing policies of multiple monitoring indexes;
the risk determining module 303 is configured to send an index value before the change of the target monitoring index and the changed index value to a management end of the target monitoring index when it is determined that the changed index value is at risk based on the target policy.
An embodiment of the present invention further provides an electronic device for monitoring data, including: one or more processors; the storage device is used for storing one or more programs, and when the one or more programs are executed by the one or more processors, the one or more processors are enabled to realize the method provided by any one of the above embodiments.
Embodiments of the present invention further provide a computer-readable medium, on which a computer program is stored, where the computer program, when executed by a processor, implements the method provided in any of the above embodiments.
Fig. 4 shows an exemplary system architecture 400 of a method of monitoring data or an apparatus for monitoring data to which embodiments of the present invention may be applied.
As shown in fig. 4, the system architecture 400 may include terminal devices 401, 402, 403, a network 404, and a server 405. The network 404 serves as a medium for providing communication links between the terminal devices 401, 402, 403 and the server 405. Network 404 may include various types of connections, such as wire, wireless communication links, or fiber optic cables, to name a few.
A user may use terminal devices 401, 402, 403 to interact with a server 405 via a network 404 to receive or send messages or the like. The terminal devices 401, 402, 403 may have various client applications installed thereon, such as a financial product client application, a financial instrument client, a mailbox client, and the like.
The terminal devices 401, 402, 403 may be various electronic devices having a display screen and supporting various client applications, including but not limited to smartphones, tablet computers, laptop and desktop computers, and the like.
The server 405 may be a server providing various services, such as a background management server providing support for client applications used by users with the terminal devices 401, 402, 403. The background management server can process the received data change request of the monitoring index and feed back the information whether the determined change index has risk to the terminal equipment.
It should be noted that the method for monitoring data provided by the embodiment of the present invention is generally performed by the server 405, and accordingly, the apparatus for monitoring data is generally disposed in the server 405.
It should be understood that the number of terminal devices, networks, and servers in fig. 4 is merely illustrative. There may be any number of terminal devices, networks, and servers, as desired for implementation.
Referring now to FIG. 5, shown is a block diagram of a computer system 500 suitable for use with a terminal device implementing an embodiment of the present invention. The terminal device shown in fig. 5 is only an example, and should not bring any limitation to the functions and the scope of use of the embodiments of the present invention.
As shown in fig. 5, the computer system 500 includes a Central Processing Unit (CPU) 501 that can perform various appropriate actions and processes according to a program stored in a Read Only Memory (ROM) 502 or a program loaded from a storage section 508 into a Random Access Memory (RAM) 503. In the RAM 503, various programs and data necessary for the operation of the system 500 are also stored. The CPU 501, ROM 502, and RAM 503 are connected to each other via a bus 504. An input/output (I/O) interface 505 is also connected to bus 504.
The following components are connected to the I/O interface 505: an input portion 506 including a keyboard, a mouse, and the like; an output portion 507 including a display such as a Cathode Ray Tube (CRT), a Liquid Crystal Display (LCD), and the like, and a speaker; a storage portion 508 including a hard disk and the like; and a communication section 509 including a network interface card such as a LAN card, a modem, or the like. The communication section 509 performs communication processing via a network such as the internet. The driver 510 is also connected to the I/O interface 505 as necessary. A removable medium 511 such as a magnetic disk, an optical disk, a magneto-optical disk, a semiconductor memory, or the like is mounted on the drive 510 as necessary, so that a computer program read out therefrom is mounted on the storage section 508 as necessary.
In particular, according to the embodiments of the present disclosure, the processes described above with reference to the flowcharts may be implemented as computer software programs. For example, embodiments of the present disclosure include a computer program product comprising a computer program embodied on a computer-readable medium, the computer program comprising program code for performing the method illustrated by the flow chart. In such an embodiment, the computer program may be downloaded and installed from a network through the communication section 509, and/or installed from the removable medium 511. The computer program performs the above-described functions defined in the system of the present invention when executed by the Central Processing Unit (CPU) 501.
It should be noted that the computer readable medium shown in the present invention can be a computer readable signal medium or a computer readable storage medium or any combination of the two. A computer readable storage medium may be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any combination of the foregoing. More specific examples of the computer readable storage medium may include, but are not limited to: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the present invention, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device. In the present invention, however, a computer readable signal medium may include a propagated data signal with computer readable program code embodied therein, for example, in baseband or as part of a carrier wave. Such a propagated data signal may take many forms, including, but not limited to, electro-magnetic, optical, or any suitable combination thereof. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device. Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to: wireless, wire, fiber optic cable, RF, etc., or any suitable combination of the foregoing.
The flowchart and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present invention. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams or flowchart illustration, and combinations of blocks in the block diagrams or flowchart illustration, can be implemented by special purpose hardware-based systems that perform the specified functions or acts, or combinations of special purpose hardware and computer instructions.
The modules and/or units described in the embodiments of the present invention may be implemented by software, and may also be implemented by hardware. The described modules and/or units may also be provided in a processor, which may be described as: a processor includes a determine indicator module, a determine policy module, and a determine risk module. The names of these modules do not limit the module itself in some cases, for example, the index determining module may be further described as a "module that determines change information of a target monitoring index configured in a data source and analyzes a changed index value in the change information".
As another aspect, the present invention also provides a computer-readable medium that may be contained in the apparatus described in the above embodiments; or may be separate and not incorporated into the device. The computer readable medium carries one or more programs which, when executed by a device, cause the device to comprise: determining change information of a target monitoring index configured in a data source, and analyzing a changed index value in the change information; searching a target strategy matched with the target monitoring index from preset changing strategies of various monitoring indexes; and under the condition that the changed index value is determined to have risk based on the target strategy, sending the index value before the change of the target monitoring index and the changed index value to a management end of the target monitoring index.
The embodiment of the invention can determine the change information of the target monitoring index and analyze the changed index value; searching a target strategy matched with the target monitoring index from preset changing strategies of multiple monitoring indexes; and judging whether the changed index value has risk or not based on the target strategy. By determining the change information of the target monitoring index configured in the data source and judging the change risk, the problems of strong coupling and poor expansibility caused by the need of developing corresponding codes for monitoring the index are solved, the universality and flexibility of the monitoring data are improved, the consumption of the labor cost and the time cost of the monitoring data is reduced, and the efficiency of monitoring the data and the monitoring operation risk is improved.
The above-described embodiments should not be construed as limiting the scope of the invention. Those skilled in the art will appreciate that various modifications, combinations, sub-combinations, and substitutions can occur, depending on design requirements and other factors. Any modification, equivalent replacement, and improvement made within the spirit and principle of the present invention should be included in the protection scope of the present invention.
Claims (9)
1. A method of monitoring data, comprising:
monitoring a data source to which one or more configured monitoring indexes belong by using a preset middleware, and determining the changed monitoring index as a target monitoring index under the condition that the monitoring index contained in the data source is changed;
determining change information of the target monitoring index, and analyzing a changed index value in the change information;
searching a target index identification matched with the target monitoring index from preset change strategies of various monitoring indexes, and taking the change strategy corresponding to the target index identification as a target strategy matched with the target monitoring index;
acquiring index information matched with the target monitoring index in the target strategy and a risk range corresponding to the index information according to the target index identifier; determining that the target monitoring index has a risk under the condition that any index information of the target monitoring index does not meet the corresponding risk range;
and under the condition that the changed index value is determined to have risk based on the target strategy, sending the index value before the change of the target monitoring index and the changed index value to a management end of the target monitoring index.
2. The method of claim 1, further comprising:
storing the determined target monitoring index and the change information of the target monitoring index into a message queue through the middleware;
and executing the steps of determining the change information of the target monitoring index through the message queue and analyzing the changed index value in the change information.
3. The method of claim 2, further comprising: setting a message queue with a plurality of themes;
the storing the target monitoring index and the change information of the target monitoring index to a message queue includes:
and storing the target monitoring index and the change information of the target monitoring index into a message queue under a theme matched with the target monitoring index.
4. The method of claim 1, further comprising:
receiving a request for constructing a change strategy of the monitoring index,
analyzing construction data from the construction request, wherein the construction data comprises a monitoring index identifier, a plurality of index information corresponding to the monitoring index identifier, and a risk range corresponding to each index information;
and generating a preset change strategy corresponding to the monitoring index based on the construction data, and storing the change strategy.
5. The method of claim 4, further comprising:
receiving a change request of a change strategy aiming at any one or more monitoring indexes,
analyzing change data from the change request, wherein the change data comprises a monitoring index identifier to be changed, one or more pieces of change index information corresponding to the monitoring index identifier to be changed, and a change risk range corresponding to the change index information;
and storing the changed change strategy based on the change strategy corresponding to the change data change.
6. The method of claim 1,
the sending the pre-changed index value and the post-changed index value of the target monitoring index to the management end of the target monitoring index includes:
determining a change prompt template matched with the category of the monitoring index;
adding the index value before the change of the target monitoring index, the index value after the change and the risk range corresponding to the index value after the change to the change prompt template to generate a target template;
and sending the target template to a management end of the target monitoring index so that the management end processes the target monitoring index.
7. An apparatus for monitoring data, comprising: the system comprises an index determining module, a strategy determining module and a risk determining module; wherein,
the index determining module is used for monitoring a data source to which one or more configured monitoring indexes belong by using a preset middleware, and determining the changed monitoring indexes as target monitoring indexes under the condition that the monitoring indexes contained in the data source are changed; determining change information of the target monitoring index, and analyzing a changed index value in the change information;
the strategy determining module is used for searching a target index identifier matched with the target monitoring index from preset changing strategies of various monitoring indexes, and taking the changing strategy corresponding to the target index identifier as a target strategy matched with the target monitoring index; acquiring index information matched with the target monitoring index in the target strategy and a risk range corresponding to the index information according to the target index identifier; determining that the target monitoring index has a risk under the condition that any index information of the target monitoring index does not meet the corresponding risk range;
and the risk determining module is used for sending the index value before the change of the target monitoring index and the index value after the change to a management end of the target monitoring index under the condition that the changed index value is determined to have risk based on the target strategy.
8. An electronic device, comprising:
one or more processors;
a storage device for storing one or more programs,
the one or more programs, when executed by the one or more processors, cause the one or more processors to implement the method recited in any of claims 1-6.
9. A computer-readable medium, on which a computer program is stored, which, when being executed by a processor, carries out the method according to any one of claims 1-6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202211231159.5A CN115309612B (en) | 2022-10-10 | 2022-10-10 | Method and device for monitoring data |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202211231159.5A CN115309612B (en) | 2022-10-10 | 2022-10-10 | Method and device for monitoring data |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN115309612A CN115309612A (en) | 2022-11-08 |
| CN115309612B true CN115309612B (en) | 2023-02-28 |
Family
ID=83866101
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202211231159.5A Active CN115309612B (en) | 2022-10-10 | 2022-10-10 | Method and device for monitoring data |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN115309612B (en) |
Family Cites Families (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110908862A (en) * | 2019-11-08 | 2020-03-24 | 北京浪潮数据技术有限公司 | Monitoring method and device, electronic equipment and storage medium |
| CN114090366A (en) * | 2020-09-01 | 2022-02-25 | 北京沃东天骏信息技术有限公司 | Method, device and system for monitoring data |
| CN112527598B (en) * | 2020-12-10 | 2023-08-18 | 北京百度网讯科技有限公司 | Method, apparatus, device, storage medium and program product for monitoring data |
-
2022
- 2022-10-10 CN CN202211231159.5A patent/CN115309612B/en active Active
Also Published As
| Publication number | Publication date |
|---|---|
| CN115309612A (en) | 2022-11-08 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111190888A (en) | Method and device for managing graph database cluster | |
| CN113760722A (en) | Test system and test method | |
| CN112948726A (en) | Method, device and system for processing abnormal information | |
| CN113779017A (en) | Method and apparatus for data asset management | |
| CN110110032B (en) | Method and device for updating index file | |
| CN112948138A (en) | Method and device for processing message | |
| CN115309612B (en) | Method and device for monitoring data | |
| CN115454956A (en) | Log generation method and device, electronic equipment and storage medium | |
| CN114979256A (en) | Message pushing method and device, electronic equipment and computer readable medium | |
| CN111460020B (en) | Method, device, electronic equipment and medium for resolving message | |
| CN114764713A (en) | Method and device for generating merchant patrol task, electronic equipment and storage medium | |
| CN113726885A (en) | Method and device for adjusting flow quota | |
| CN113312900A (en) | Data verification method and device | |
| CN113011858A (en) | Audit project configuration and execution method and device | |
| CN113778847A (en) | Test report generation method and device | |
| CN112463616A (en) | Chaos testing method and device for Kubernetes container platform | |
| CN108509455B (en) | Data table processing method and device | |
| CN110908763A (en) | Acceptance method, device, equipment and storage medium | |
| CN113568803A (en) | Method, electronic device and computer program product for monitoring a storage system | |
| CN112559001A (en) | Method and device for updating application | |
| CN111930704B (en) | Service alarm equipment control method, device, equipment and computer readable medium | |
| CN110262756B (en) | Method and device for caching data | |
| CN114253520B (en) | Interface code generation method and device | |
| CN115174224B (en) | Information security monitoring method and device suitable for industrial control network | |
| CN110019682B (en) | System, method and apparatus for processing information |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |