CN111369354A - Data monitoring method and device for block chain application and storage medium - Google Patents
Data monitoring method and device for block chain application and storage medium Download PDFInfo
- Publication number
- CN111369354A CN111369354A CN201811590131.4A CN201811590131A CN111369354A CN 111369354 A CN111369354 A CN 111369354A CN 201811590131 A CN201811590131 A CN 201811590131A CN 111369354 A CN111369354 A CN 111369354A
- Authority
- CN
- China
- Prior art keywords
- data
- monitoring
- rule
- template
- transaction
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000012544 monitoring process Methods 0.000 title claims abstract description 224
- 238000000034 method Methods 0.000 title claims abstract description 35
- 238000012545 processing Methods 0.000 claims description 66
- 230000008676 import Effects 0.000 claims description 41
- 230000002159 abnormal effect Effects 0.000 claims description 14
- 238000012806 monitoring device Methods 0.000 claims description 6
- 238000004590 computer program Methods 0.000 claims description 5
- 238000012986 modification Methods 0.000 description 7
- 230000004048 modification Effects 0.000 description 7
- 238000010586 diagram Methods 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 3
- 230000008569 process Effects 0.000 description 3
- 230000001960 triggered effect Effects 0.000 description 3
- 238000011161 development Methods 0.000 description 2
- 238000007792 addition Methods 0.000 description 1
- 230000004075 alteration Effects 0.000 description 1
- 238000004891 communication Methods 0.000 description 1
- 230000006378 damage Effects 0.000 description 1
- 238000012217 deletion Methods 0.000 description 1
- 230000037430 deletion Effects 0.000 description 1
- 239000004744 fabric Substances 0.000 description 1
- 230000006870 function Effects 0.000 description 1
- 238000011835 investigation Methods 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 230000001105 regulatory effect Effects 0.000 description 1
- 238000012552 review Methods 0.000 description 1
- 230000003068 static effect Effects 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
- G06Q40/04—Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F21/00—Security arrangements for protecting computers, components thereof, programs or data against unauthorised activity
- G06F21/60—Protecting data
- G06F21/62—Protecting access to data via a platform, e.g. using keys or access control rules
- G06F21/6218—Protecting access to data via a platform, e.g. using keys or access control rules to a system of files or objects, e.g. local or distributed file system or database
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q20/00—Payment architectures, schemes or protocols
- G06Q20/38—Payment protocols; Details thereof
- G06Q20/382—Payment protocols; Details thereof insuring higher security of transaction
- G06Q20/3821—Electronic credentials
- G06Q20/38215—Use of certificates or encrypted proofs of transaction rights
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q20/00—Payment architectures, schemes or protocols
- G06Q20/38—Payment protocols; Details thereof
- G06Q20/40—Authorisation, e.g. identification of payer or payee, verification of customer or shop credentials; Review and approval of payers, e.g. check credit lines or negative lists
- G06Q20/401—Transaction verification
- G06Q20/4014—Identity check for transactions
Landscapes
- Engineering & Computer Science (AREA)
- Business, Economics & Management (AREA)
- Accounting & Taxation (AREA)
- Theoretical Computer Science (AREA)
- Finance (AREA)
- Physics & Mathematics (AREA)
- General Physics & Mathematics (AREA)
- Computer Security & Cryptography (AREA)
- Strategic Management (AREA)
- General Business, Economics & Management (AREA)
- Databases & Information Systems (AREA)
- Health & Medical Sciences (AREA)
- Bioethics (AREA)
- General Health & Medical Sciences (AREA)
- Computer Hardware Design (AREA)
- Software Systems (AREA)
- General Engineering & Computer Science (AREA)
- Development Economics (AREA)
- Economics (AREA)
- Marketing (AREA)
- Technology Law (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The embodiment of the application provides a data monitoring method, a device and a storage medium for block chain application, which relate to the technical field of block chains, and the method comprises the following steps: monitoring a transaction event of the block chain, and acquiring original transaction data in real time according to the transaction event; storing the acquired original data into a pre-constructed original database according to a preset rule; after receiving a data monitoring instruction, acquiring a corresponding data monitoring rule; and monitoring the data in the original database according to the data monitoring rule, so that the obtained monitoring result is more accurate by monitoring the original data in the embodiment of the application. And monitoring by adopting corresponding monitoring rules, so that the monitoring can be realized automatically. In addition, the user can make a monitoring rule according to the service requirement of the user, and the data is imported into the template and exported from the template, so that the scheme provided by the application can be suitable for different services.
Description
Technical Field
The embodiment of the invention relates to the technical field of block chains, in particular to a data monitoring method and device and a storage medium for block chain application.
Background
With the development of the block chain technology, the amount of service data is gradually increased. In order to ensure normal development of services and avoid service risks in advance, services need to be monitored. In the prior art, digital currency is one of the most widely applied fields in the application of blockchain technology, and the real user identity behind a transaction account number can be hidden in a blockchain, which causes that conventional monitoring is difficult to realize. In addition, the application of the block chain technology in many fields such as credit investigation, tax administration, medical treatment and the like is gradually developed, and malicious nodes, illegal information and the like also need to be stricken through effective monitoring.
Therefore, how to monitor data of blockchain applications becomes an urgent problem to be solved.
Disclosure of Invention
In the prior art, an embodiment of the present application provides a data monitoring method and system for blockchain application, where the system includes:
in one aspect, an embodiment of the present application provides a data monitoring method for blockchain application, where the method includes:
monitoring a transaction event of the block chain, and acquiring original transaction data in real time according to the transaction event;
storing the acquired original data into a pre-constructed original database according to a preset rule;
after receiving a data monitoring instruction, acquiring a corresponding data monitoring rule;
and monitoring the data in the original database according to the data monitoring rule.
On the other hand, an embodiment of the present application provides a data monitoring apparatus for block chain application, including:
the original data acquisition module is used for monitoring the transaction event of the block chain and acquiring original transaction data in real time according to the transaction event;
the storage module is used for storing the acquired original data into a pre-constructed original database according to a preset rule;
the rule acquisition module is used for acquiring a corresponding data monitoring rule after receiving a data monitoring instruction;
and the monitoring module is used for monitoring the data in the original database according to the data monitoring rule.
In another aspect, an embodiment of the present application provides a data monitoring apparatus for a blockchain application, including at least one processor and at least one memory, where the memory stores a computer program, and when the program is executed by the processor, the processor executes the steps of the data monitoring method for a blockchain application.
In another aspect, the present application provides a computer-readable storage medium, which stores a computer program executable by a data monitoring apparatus for a blockchain application, and when the program runs on the data monitoring apparatus for the blockchain application, the program causes the data monitoring apparatus for the blockchain application to perform the steps of the data monitoring method for the blockchain application.
In the embodiment of the application, the obtained monitoring result is more accurate by monitoring the original data. And monitoring by adopting corresponding monitoring rules, so that the monitoring can be realized automatically.
Drawings
In order to more clearly illustrate the technical solutions in the embodiments of the present invention, the drawings needed to be used in the description of the embodiments will be briefly introduced below, and it is obvious that the drawings in the following description are only some embodiments of the present invention, and it is obvious for those skilled in the art to obtain other drawings based on these drawings without inventive exercise.
Fig. 1 is a schematic view of an application scenario in which the present application is applicable;
fig. 2 is a schematic flowchart of a block chain application-oriented data monitoring method according to the present application;
fig. 3 is a second schematic flowchart of a data monitoring method for blockchain applications according to the present application;
fig. 4 is a schematic structural diagram of a data monitoring apparatus for blockchain applications according to the present application;
fig. 5 is a schematic structural diagram of a data monitoring device for blockchain applications according to the present application.
Detailed Description
In order to make the objects, technical solutions and advantages of the present invention more clearly apparent, the present invention is described in further detail below with reference to the accompanying drawings and embodiments. It should be understood that the specific embodiments described herein are merely illustrative of the invention and are not intended to limit the invention.
In view of the fact that the raw data to be monitored exists in the blockchain transaction, the raw data may be obtained from the transaction event and stored in the embodiment of the present application. May be stored in a database and does not allow any modification, which may include, for example, addition or deletion, modification of the original data, and the like. Therefore, during monitoring, the original data can be called from the database for monitoring. In order to improve the monitoring efficiency, a preset template can be adopted to process the original data, a preset monitoring rule expression is adopted to monitor the data, and then a preset template can be adopted to export the monitoring processing result according to the template. Therefore, in the embodiment of the application, not only can data monitoring of the block chain application be realized, but also monitoring rules can be configured by different users according to own requirements through the template.
The data monitoring for the blockchain application in the embodiment of the present application may be applied to an application scenario as shown in fig. 1, where the application scenario includes a database 101, a monitoring system 102, a user terminal 103, a blockchain node 104, and a monitoring terminal 105.
The user terminal can be provided with a browser or various applications, and the user can carry out transactions through the user terminal and execute the transactions through the block link nodes. A transaction event is generated in blockchain node 104 that contains the raw data for the transaction. The monitoring system 102 monitors the transaction event of the block chain in the block chain node 104, obtains the transaction original data in real time according to the transaction event, obtains the original data from the transaction original data, and stores the original data in the database 101. The monitoring client may configure monitoring rules on the monitoring system 102 according to its own requirements, and the monitoring system 102 may obtain raw data from the database 101 according to the configured monitoring rules, perform monitoring, and feed back a monitoring result to the monitoring client 105.
Wherein. The user terminals 103 and 105 may be smart phones, tablet computers, portable personal computers, or the like.
Based on the application scenario diagram shown in fig. 1, an embodiment of the present invention provides a data monitoring method for block chain application, as shown in fig. 2, including the following steps:
step 201: and monitoring the transaction event of the block chain, and acquiring original transaction data in real time according to the transaction event.
In particular, transaction events may be monitored from the blockchain through a standard interface.
Step 202: and storing the acquired original data into a pre-constructed original database according to a preset rule.
In specific implementation, the original data is stored in the blockchain ledger so that the original data cannot be deleted or tampered, and therefore, a monitoring result obtained from the blockchain ledger has reliability.
Further, different users may have different monitoring rules, in specific implementation, the data monitoring instruction includes a user identifier, and after receiving the data monitoring instruction, the data monitoring rule corresponding to the user identifier may be acquired to execute corresponding monitoring processing.
Step 203: and after receiving the data monitoring instruction, acquiring a corresponding data monitoring rule.
Step 204: and monitoring the data in the original database according to the data monitoring rule.
Based on the steps, the obtained monitoring result is more accurate by monitoring the original data in the embodiment of the application. And monitoring by adopting corresponding monitoring rules, so that the monitoring can be realized automatically.
Further, data formats processed by different service requirements may be different, and in order to be capable of adapting to service requirements of different users, the data may be monitored after being processed according to a template of the user in the embodiment of the present application. Specifically, the monitoring of the data in the original database according to the data monitoring rule may be implemented as:
step A1: acquiring data requested to be monitored by the data monitoring instruction from the original database;
step A2: importing a template according to data specified in the data monitoring rule, performing templating processing on the acquired data, and storing the processed data in a monitoring database;
step A3: monitoring the data in a monitoring database according to a monitoring rule expression in the data monitoring rule;
step A4: and if the abnormal data is monitored, generating an alarm event corresponding to the abnormal data.
That is, a user can configure a data import template according to own service requirements, the template can be configured with requirements for importing which data and data formats and the like, the processed data is stored in a monitoring database, and then the data in the monitoring database is processed uniformly according to a supervision rule expression. And when the abnormity is monitored, an alarm is triggered. For example, an alarm may be triggered to the monitoring client.
Further, in the embodiment of the present application, different alarm levels may be configured for different abnormal situations and corresponding measures may be adopted. The method can be specifically implemented as follows:
step B1: for each alarm event, determining the alarm level of the alarm event according to the corresponding relation between the alarm event and the alarm level;
the corresponding relation can also be set according to the requirements of the user.
The specific correspondence may be implemented in the form of a look-up table.
Step B2: determining a control decision according to the alarm content and the alarm level of the alarm event;
in specific implementation, the monitoring system 102 shown in fig. 1 may provide different control decisions, and the monitoring user may specifically set the control decisions corresponding to different events.
Step B3: and executing the determined control decision.
Therefore, in the embodiment of the application, different management and control decisions can be provided according to different conditions, and automatic processing for abnormal events is realized.
Further, the governing decision comprises at least one of: stopping the blockchain node, selling the blockchain node, forbidding transaction and canceling the blockchain user certificate; accordingly, executing the determined governing decision may be implemented as:
1) if the control decision is determined to be the stopping block chain node, stopping the service of the transaction release node included in the alarm event;
2) if the control decision is determined to be a cancellation block chain link point, canceling a certificate of a problem block chain node included in the alarm event;
and logging out the problematic blockchain link point certificate, so that the problematic blockchain node cannot perform transaction and endorsement.
3) If the control decision is determined to be that the transaction is prohibited, locking the intelligent contract included in the alarm event, and prohibiting the transaction of the intelligent contract;
in this way, for the transaction executed based on the intelligent contract, the occurrence of more abnormal conditions can be effectively avoided by forbidding the intelligent contract.
4) And if the control decision is determined to be the cancellation of the block chain user certificate, canceling the certificate for the transaction of the problem user included in the alarm event.
After the integer for the transaction is logged off, the user will not be able to proceed with the transaction.
Therefore, corresponding control measures can be automatically triggered according to different alarm events, and automatic processing of the abnormity is achieved.
Certainly, in specific implementation, some alarm events may have corresponding control measures to be automatically executed, or some alarm events may be output to a monitoring user, and the monitoring user manually triggers the processing of the abnormal event.
Further, as mentioned above, after monitoring the data in the monitoring database according to the monitoring rule expression in the data monitoring rule, a template may be derived according to the data in the data monitoring rule, and the data monitored according to the monitoring rule expression is subjected to templating processing and then output.
Further, in order to better adapt to the business requirements of different users, the user can add injuries and modify and view the template. Specifically, at least one of the following aspects (1) to (3) may be included:
(1) receiving a first processing instruction aiming at a data import template, and carrying out corresponding operation according to the first processing instruction; the first processing instruction comprises one of: adding a data import template, deleting the data import template, modifying the specified data import template, inquiring a specified data import module, starting the specified data import template, and stopping the specified data import template;
(2) receiving a second processing instruction aiming at the data export template, and carrying out corresponding operation according to the second processing instruction; the second processing instruction comprises one of: adding a data export template, deleting the data export template, modifying the specified data export template, inquiring the specified data export module, starting the specified data export template, and stopping the specified data export template;
(3) receiving a third processing instruction aiming at the data monitoring rule, and carrying out corresponding operation according to the third processing instruction; the third processing instruction comprises one of: adding a data monitoring rule, deleting the data monitoring rule, modifying the data monitoring rule, inquiring the data monitoring rule, starting the data monitoring rule and stopping the data monitoring rule.
Therefore, different monitoring users can properly process the data import template and the data export template according to own requirements, and can add, delete and modify the data monitoring rules according to own requirements in real time.
In specific implementation, the database nodes in which the data import templates, the data export templates, and the supervision rules are stored in the network are, for example, the database 101 shown in fig. 1, and the user terminal 105 accesses through a server (e.g., the monitoring system 102 in fig. 1). In this way, it is achieved that the data import template can be modified, queried, enabled, disabled or deleted by the user. Likewise, data-export templates may also be modified, queried, or deleted by users, and similar regulatory rules may be modified, queried, enabled, disabled, or deleted by users.
Of course, in further implementations, the generated alarm events may be stored, for example, in a database as shown in FIG. 1, for review by the user. The method can be specifically implemented as follows: receiving a query instruction for an alarm event; then, the alarm event in the query instruction is queried, and the supervision rule expression corresponding to the alarm event is obtained and output. Therefore, the user can inquire the alarm event and the supervision rule expression corresponding to the alarm event, so that the user can know the data monitoring condition conveniently.
In an embodiment, in this embodiment, superhedger Fabric may be used as the implementation of the block chain network.
A specific embodiment of the following system description is made on the data monitoring method for blockchain application according to the embodiment of the present application, and as shown in fig. 3, the method includes the following steps:
step 301: and receiving a configuration instruction of a user on the data export template, the monitoring rule and the data export template.
Step 302: and carrying out user configuration according to the configuration instruction.
Of course, it should be noted that the execution order of step 301 and step 302 is not limited. Can be configured at any time according to the requirements of users.
Step 303: and monitoring the transaction event of the block chain, and acquiring original transaction data in real time according to the transaction event.
Step 304: and storing the acquired original data into a pre-constructed original database according to a preset rule.
Step 305: and acquiring the data requested to be monitored by the data monitoring instruction from the original database.
Step 306: and importing a template according to the data specified in the data monitoring rule, performing templating processing on the acquired data, and storing the processed data in a monitoring database.
Step 307: and if the abnormal data is monitored, generating an alarm event corresponding to the abnormal data.
Step 308: for each alarm event, determining the alarm level of the alarm event according to the corresponding relation between the alarm event and the alarm level;
step 309: and determining a control decision according to the alarm content and the alarm level of the alarm event.
Step 310: if the control decision is determined to be the stopping block chain node, stopping the service of the transaction release node included in the alarm event; if the control decision is determined to be a cancellation block chain link point, canceling a certificate of a problem block chain node included in the alarm event; if the control decision is determined to be that the transaction is prohibited, locking an intelligent contract included in the alarm event, and prohibiting the transaction of the intelligent contract; and if the control decision is determined to be the cancellation of the block chain user certificate, canceling the certificate for the transaction of the problem user included in the alarm event.
Step 311: receiving a first processing instruction aiming at a data import template, and carrying out corresponding operation according to the first processing instruction; the first processing instruction comprises one of: adding a data import template, deleting the data import template, modifying the specified data import template, inquiring the specified data import module, starting the specified data import template, and stopping the specified data import template.
Step 312: receiving a second processing instruction aiming at the data export template, and carrying out corresponding operation according to the second processing instruction; the second processing instruction comprises one of: adding a data export template, deleting the data export template, modifying the specified data export template, inquiring the specified data export module, starting the specified data export template, and stopping the specified data export template.
Step 313: receiving a third processing instruction aiming at a data monitoring rule, and performing corresponding operation according to the third processing instruction; the third processing instruction comprises one of: adding a data monitoring rule, deleting the data monitoring rule, modifying the data monitoring rule, inquiring the data monitoring rule, starting the data monitoring rule and stopping the data monitoring rule.
The execution sequence of steps 311 to 313 is not limited.
Based on the same technical concept, an embodiment of the present application provides a data monitoring apparatus for blockchain application, where the apparatus may, as shown in fig. 4, include:
the original data acquisition module 401 is configured to monitor a transaction event of the block chain, and acquire original transaction data in real time according to the transaction event;
a storage module 402, configured to store the obtained raw data in a pre-constructed raw database according to a preset rule;
a rule obtaining module 403, configured to obtain a corresponding data monitoring rule after receiving the data monitoring instruction;
and the monitoring module 404 is configured to monitor the data in the original database according to the data monitoring rule.
Further, the monitoring module includes:
the data acquisition unit is used for acquiring the data requested to be monitored by the data monitoring instruction from the original database;
the import processing unit is used for importing a template according to the data specified in the data monitoring rule, performing templating processing on the acquired data and storing the processed data in a monitoring database;
the monitoring unit is used for monitoring the data in the monitoring database according to the monitoring rule expression in the data monitoring rule;
and the alarm event generating unit is used for generating an alarm event corresponding to the abnormal data if the abnormal data is monitored.
Further, the apparatus further comprises:
the alarm level determining module is used for determining the alarm level of each alarm event according to the corresponding relation between the alarm event and the alarm level;
the control decision determining module is used for determining a control decision according to the alarm content and the alarm level of the alarm event;
and the management and control module is used for executing the determined management and control decision.
Further, the governing decision comprises at least one of: stopping the blockchain node, selling the blockchain node, forbidding transaction and canceling the blockchain user certificate;
a management and control module comprising:
the first control unit is used for stopping the service of the transaction release node included in the alarm event if the control decision is determined to be the stopping of the blockchain node;
the second control unit is used for canceling the certificate of the problem block chain node included in the alarm event if the control decision is determined to be a cancellation block chain node;
the third control unit is used for locking the intelligent contract included in the alarm event and forbidding the transaction of the intelligent contract if the control decision is determined to be that the transaction is forbidden;
and the fourth management and control unit is used for logging off the certificate for transaction of the problem user included in the alarm event if the management and control decision is determined to be the logging off block chain user certificate.
Further, the data monitoring instruction includes a user identifier, and the rule obtaining module is configured to obtain a data monitoring rule corresponding to the user identifier.
Further, the apparatus further comprises:
and after monitoring the data in the monitoring database according to the monitoring rule expression in the data monitoring rule, exporting a template according to the data in the data monitoring rule, and outputting the data monitored according to the monitoring rule expression after templated processing.
Further, the apparatus further comprises:
a processing instruction processing module to:
receiving a first processing instruction aiming at a data import template, and carrying out corresponding operation according to the first processing instruction; the first processing instruction comprises one of: adding a data import template, deleting the data import template, modifying the specified data import template, inquiring a specified data import module, starting the specified data import template, and stopping the specified data import template; and/or the presence of a gas in the gas,
receiving a second processing instruction aiming at the data export template, and carrying out corresponding operation according to the second processing instruction; the second processing instruction comprises one of: adding a data export template, deleting the data export template, modifying the specified data export template, inquiring the specified data export module, starting the specified data export template, and stopping the specified data export template; and/or the presence of a gas in the gas,
receiving a third processing instruction aiming at a data monitoring rule, and performing corresponding operation according to the third processing instruction; the third processing instruction comprises one of: adding a data monitoring rule, deleting the data monitoring rule, modifying the data monitoring rule, inquiring the data monitoring rule, starting the data monitoring rule and stopping the data monitoring rule.
Further, the apparatus further comprises:
the query instruction receiving module is used for receiving a query instruction of the alarm event;
and the query module is used for querying the alarm event in the query instruction, acquiring and outputting the supervision rule expression corresponding to the alarm event.
Based on the same technical concept, the data monitoring device for blockchain applications is provided in the embodiments of the present application, as shown in fig. 5, including at least one processor 1501 and a memory 1502 connected to the at least one processor, where a specific connection medium between the processor 1501 and the memory 1502 is not limited in the embodiments of the present application, and the processor 1501 and the memory 1502 are connected through a bus in fig. 5 as an example. The bus may be divided into an address bus, a data bus, a control bus, etc.
In the embodiment of the present application, the memory 1502 stores instructions executable by the at least one processor 1501, and the at least one processor 1501 can execute the steps included in the data monitoring method for the blockchain application by executing the instructions stored in the memory 1502.
The processor 1501 is a control center for data monitoring for blockchain applications, and may utilize various interfaces and connections to various parts of the device for tracking vehicle position to process data by executing or executing instructions stored in the memory 1502 and calling up data stored in the memory 1502. Alternatively, the processor 1501 may include one or more processing units, and the processor 1501 may integrate an application processor, which mainly handles operating systems, user interfaces, application programs, and the like, and a modem processor, which mainly handles wireless communications. It will be appreciated that the modem processor described above may not be integrated into processor 1501. In some embodiments, the processor 1501 and the memory 1502 may be implemented on the same chip, or in some embodiments, they may be implemented separately on separate chips.
The processor 1501 may be a general-purpose processor, such as a Central Processing Unit (CPU), a digital signal processor, an Application Specific Integrated Circuit (ASIC), a field programmable gate array or other programmable logic device, discrete gate or transistor logic, discrete hardware components, or any combination thereof, configured to implement or perform the methods, steps, and logic blocks disclosed in the embodiments of the present Application. A general purpose processor may be a microprocessor or any conventional processor or the like. The steps of a method disclosed in connection with the embodiments of the present application may be directly implemented by a hardware processor, or may be implemented by a combination of hardware and software modules in a processor.
The memory 1502, which is a non-volatile computer-readable storage medium, may be used to store non-volatile software programs, non-volatile computer-executable programs, and modules. The Memory 1502 may include at least one type of storage medium, and may include, for example, a flash Memory, a hard disk, a multimedia card, a card-type Memory, a Random Access Memory (RAM), a Static Random Access Memory (SRAM), a Programmable Read Only Memory (PROM), a Read Only Memory (ROM), a charge Erasable Programmable Read Only Memory (EEPROM), a magnetic Memory, a magnetic disk, an optical disk, and so on. The memory 1502 is any other medium that can be used to carry or store desired program code in the form of instructions or data structures and that can be accessed by a computer, but is not limited to such. The memory 1502 in the embodiments of the present application may also be circuitry or any other device capable of performing a storage function for storing program instructions and/or data.
Based on the same inventive concept, embodiments of the present application provide a computer-readable storage medium, which stores a computer program executable by a data monitoring apparatus for a blockchain application, and when the program runs on the data monitoring apparatus for the blockchain application, the program causes the data monitoring apparatus for the blockchain application to execute the steps of the data monitoring method for the blockchain application.
While preferred embodiments of the present invention have been described, additional variations and modifications in those embodiments may occur to those skilled in the art once they learn of the basic inventive concepts. Therefore, it is intended that the appended claims be interpreted as including preferred embodiments and all such alterations and modifications as fall within the scope of the invention.
It will be apparent to those skilled in the art that various changes and modifications may be made in the present invention without departing from the spirit and scope of the invention. Thus, if such modifications and variations of the present invention fall within the scope of the claims of the present invention and their equivalents, the present invention is also intended to include such modifications and variations.
Claims (18)
1. A data monitoring method for block chain application is characterized by comprising the following steps:
monitoring a transaction event of the block chain, and acquiring original transaction data in real time according to the transaction event;
storing the acquired original data into a pre-constructed original database according to a preset rule;
after receiving a data monitoring instruction, acquiring a corresponding data monitoring rule;
and monitoring the data in the original database according to the data monitoring rule.
2. The method of claim 1, wherein monitoring the data in the raw database according to the data monitoring rules comprises:
acquiring data requested to be monitored by the data monitoring instruction from the original database;
importing a template according to data specified in the data monitoring rule, performing templating processing on the acquired data, and storing the processed data in a monitoring database;
monitoring the data in a monitoring database according to a monitoring rule expression in the data monitoring rule;
and if the abnormal data is monitored, generating an alarm event corresponding to the abnormal data.
3. The method of claim 2, further comprising:
for each alarm event, determining the alarm level of the alarm event according to the corresponding relation between the alarm event and the alarm level;
determining a control decision according to the alarm content and the alarm level of the alarm event;
and executing the determined control decision.
4. The method of claim 3, wherein the governance decision comprises at least one of: stopping the blockchain node, selling the blockchain node, forbidding transaction and canceling the blockchain user certificate;
executing the determined governance decision, comprising:
if the control decision is determined to be the stopping block chain node, stopping the service of the transaction release node included in the alarm event;
if the control decision is determined to be a cancellation block chain link point, canceling a certificate of a problem block chain node included in the alarm event;
if the control decision is determined to be that the transaction is prohibited, locking an intelligent contract included in the alarm event, and prohibiting the transaction of the intelligent contract;
and if the control decision is determined to be the cancellation of the block chain user certificate, canceling the certificate for the transaction of the problem user included in the alarm event.
5. The method according to claim 1, wherein the data monitoring instruction includes a user identifier, and after receiving the data monitoring instruction, acquiring a corresponding data monitoring rule includes:
and acquiring a data monitoring rule corresponding to the user identifier.
6. The method of claim 2, wherein after monitoring data in a monitoring database according to a monitoring rule expression in the data monitoring rule, the method further comprises:
and exporting a template according to the data in the data monitoring rule, and outputting the data monitored according to the supervision rule expression after performing templating treatment.
7. The method of claim 6, further comprising:
receiving a first processing instruction aiming at a data import template, and carrying out corresponding operation according to the first processing instruction; the first processing instruction comprises one of: adding a data import template, deleting the data import template, modifying the specified data import template, inquiring a specified data import module, starting the specified data import template, and stopping the specified data import template; and/or the presence of a gas in the gas,
receiving a second processing instruction aiming at the data export template, and carrying out corresponding operation according to the second processing instruction; the second processing instruction comprises one of: adding a data export template, deleting the data export template, modifying the specified data export template, inquiring the specified data export module, starting the specified data export template, and stopping the specified data export template; and/or the presence of a gas in the gas,
receiving a third processing instruction aiming at a data monitoring rule, and performing corresponding operation according to the third processing instruction; the third processing instruction comprises one of: adding a data monitoring rule, deleting the data monitoring rule, modifying the data monitoring rule, inquiring the data monitoring rule, starting the data monitoring rule and stopping the data monitoring rule.
8. The method of claim 2, further comprising:
receiving a query instruction for an alarm event;
and inquiring the alarm event in the inquiry instruction, and acquiring and outputting a supervision rule expression corresponding to the alarm event.
9. A data monitoring apparatus for blockchain applications, comprising:
the original data acquisition module is used for monitoring the transaction event of the block chain and acquiring original transaction data in real time according to the transaction event;
the storage module is used for storing the acquired original data into a pre-constructed original database according to a preset rule;
the rule acquisition module is used for acquiring a corresponding data monitoring rule after receiving a data monitoring instruction;
and the monitoring module is used for monitoring the data in the original database according to the data monitoring rule.
10. The apparatus of claim 9, wherein the monitoring module comprises:
the data acquisition unit is used for acquiring the data requested to be monitored by the data monitoring instruction from the original database;
the import processing unit is used for importing a template according to the data specified in the data monitoring rule, performing templating processing on the acquired data and storing the processed data in a monitoring database;
the monitoring unit is used for monitoring the data in the monitoring database according to the monitoring rule expression in the data monitoring rule;
and the alarm event generating unit is used for generating an alarm event corresponding to the abnormal data if the abnormal data is monitored.
11. The apparatus of claim 10, further comprising:
the alarm level determining module is used for determining the alarm level of each alarm event according to the corresponding relation between the alarm event and the alarm level;
the control decision determining module is used for determining a control decision according to the alarm content and the alarm level of the alarm event;
and the management and control module is used for executing the determined management and control decision.
12. The apparatus of claim 11, wherein the governance decision comprises at least one of: stopping the blockchain node, selling the blockchain node, forbidding transaction and canceling the blockchain user certificate;
a management and control module comprising:
the first control unit is used for stopping the service of the transaction release node included in the alarm event if the control decision is determined to be the stopping of the blockchain node;
the second control unit is used for canceling the certificate of the problem block chain node included in the alarm event if the control decision is determined to be a cancellation block chain node;
the third control unit is used for locking the intelligent contract included in the alarm event and forbidding the transaction of the intelligent contract if the control decision is determined to be that the transaction is forbidden;
and the fourth management and control unit is used for logging off the certificate for transaction of the problem user included in the alarm event if the management and control decision is determined to be the logging off block chain user certificate.
13. The apparatus according to claim 9, wherein the data monitoring instruction includes a user identifier, and the rule obtaining module is configured to obtain a data monitoring rule corresponding to the user identifier.
14. The apparatus of claim 10, further comprising:
and after monitoring the data in the monitoring database according to the monitoring rule expression in the data monitoring rule, exporting a template according to the data in the data monitoring rule, and outputting the data monitored according to the monitoring rule expression after templated processing.
15. The apparatus of claim 14, further comprising:
a processing instruction processing module to:
receiving a first processing instruction aiming at a data import template, and carrying out corresponding operation according to the first processing instruction; the first processing instruction comprises one of: adding a data import template, deleting the data import template, modifying the specified data import template, inquiring a specified data import module, starting the specified data import template, and stopping the specified data import template; and/or the presence of a gas in the gas,
receiving a second processing instruction aiming at the data export template, and carrying out corresponding operation according to the second processing instruction; the second processing instruction comprises one of: adding a data export template, deleting the data export template, modifying the specified data export template, inquiring the specified data export module, starting the specified data export template, and stopping the specified data export template; and/or the presence of a gas in the gas,
receiving a third processing instruction aiming at a data monitoring rule, and performing corresponding operation according to the third processing instruction; the third processing instruction comprises one of: adding a data monitoring rule, deleting the data monitoring rule, modifying the data monitoring rule, inquiring the data monitoring rule, starting the data monitoring rule and stopping the data monitoring rule.
16. The apparatus of claim 10, further comprising:
the query instruction receiving module is used for receiving a query instruction of the alarm event;
and the query module is used for querying the alarm event in the query instruction, acquiring and outputting the supervision rule expression corresponding to the alarm event.
17. A data monitoring device for blockchain applications, comprising at least one processor and at least one memory, wherein the memory stores a computer program which, when executed by the processor, causes the processor to carry out the steps of the method according to any of claims 1 to 8.
18. A computer-readable storage medium, storing a computer program executable by a data monitoring device for a blockchain application, the program, when executed on the data monitoring device for the blockchain application, causing the data monitoring device for the blockchain application to perform the steps of the method as set forth in any one of claims 1 to 8.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201811590131.4A CN111369354A (en) | 2018-12-25 | 2018-12-25 | Data monitoring method and device for block chain application and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201811590131.4A CN111369354A (en) | 2018-12-25 | 2018-12-25 | Data monitoring method and device for block chain application and storage medium |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN111369354A true CN111369354A (en) | 2020-07-03 |
Family
ID=71207934
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201811590131.4A Pending CN111369354A (en) | 2018-12-25 | 2018-12-25 | Data monitoring method and device for block chain application and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111369354A (en) |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112911235A (en) * | 2021-01-26 | 2021-06-04 | 北京豆萌信息技术有限公司 | Monitoring rule configuration method, device, server and storage medium |
| CN113010508A (en) * | 2021-03-23 | 2021-06-22 | 内蒙古电力(集团)有限责任公司内蒙古电力科学研究院分公司 | Power metering data quality monitoring method and device and big data computing platform |
| CN115858309A (en) * | 2022-12-30 | 2023-03-28 | 北京百度网讯科技有限公司 | Data monitoring method and device for distributed system and electronic equipment |
| CN117408592A (en) * | 2023-12-14 | 2024-01-16 | 上海文景信息科技有限公司 | Block chain-based multi-mode intermodal one-system logistics tracing method and system |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2007109987A1 (en) * | 2006-03-28 | 2007-10-04 | Alibaba Group Holding Limited | Method and system for making risk monitoring on the online service |
| CN106371984A (en) * | 2016-08-31 | 2017-02-01 | 广州品唯软件有限公司 | Data monitoring method, equipment and system |
| CN107067324A (en) * | 2017-04-18 | 2017-08-18 | 上海翼翎数据信息技术有限公司 | A kind of utilization network packet capturing data realize the method and system of transaction risk control |
| CN107943951A (en) * | 2017-11-24 | 2018-04-20 | 中钞信用卡产业发展有限公司杭州区块链技术研究院 | A kind of search method and system of block chain business information |
| CN108989136A (en) * | 2017-05-31 | 2018-12-11 | 中国移动通信集团公司 | Business end to end performance monitoring method and device |
-
2018
- 2018-12-25 CN CN201811590131.4A patent/CN111369354A/en active Pending
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2007109987A1 (en) * | 2006-03-28 | 2007-10-04 | Alibaba Group Holding Limited | Method and system for making risk monitoring on the online service |
| CN106371984A (en) * | 2016-08-31 | 2017-02-01 | 广州品唯软件有限公司 | Data monitoring method, equipment and system |
| CN107067324A (en) * | 2017-04-18 | 2017-08-18 | 上海翼翎数据信息技术有限公司 | A kind of utilization network packet capturing data realize the method and system of transaction risk control |
| CN108989136A (en) * | 2017-05-31 | 2018-12-11 | 中国移动通信集团公司 | Business end to end performance monitoring method and device |
| CN107943951A (en) * | 2017-11-24 | 2018-04-20 | 中钞信用卡产业发展有限公司杭州区块链技术研究院 | A kind of search method and system of block chain business information |
Non-Patent Citations (4)
| Title |
|---|
| 佚名: "以太坊交易", 《HTTPS://BLOG.CSDN.NET/MONGO_NODE/ARTICLE/DETAILS/81870000》, pages 1 * |
| 佚名: "用web3.js追踪区块链中的以太坊交易", pages 1 - 2 * |
| 张凌: "《智能时代的银行知识管理》", pages: 121 * |
| 陈明: "一体化运维监控与管理系统的研究与实现", 《中国优秀硕士学位论文全文数据库 信息科技辑》, pages 4 * |
Cited By (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112911235A (en) * | 2021-01-26 | 2021-06-04 | 北京豆萌信息技术有限公司 | Monitoring rule configuration method, device, server and storage medium |
| CN113010508A (en) * | 2021-03-23 | 2021-06-22 | 内蒙古电力(集团)有限责任公司内蒙古电力科学研究院分公司 | Power metering data quality monitoring method and device and big data computing platform |
| CN115858309A (en) * | 2022-12-30 | 2023-03-28 | 北京百度网讯科技有限公司 | Data monitoring method and device for distributed system and electronic equipment |
| CN115858309B (en) * | 2022-12-30 | 2023-12-22 | 北京百度网讯科技有限公司 | Data monitoring method and device for distributed system and electronic equipment |
| CN117408592A (en) * | 2023-12-14 | 2024-01-16 | 上海文景信息科技有限公司 | Block chain-based multi-mode intermodal one-system logistics tracing method and system |
| CN117408592B (en) * | 2023-12-14 | 2024-04-09 | 上海文景信息科技有限公司 | Block chain-based multi-mode intermodal one-system logistics tracing method and system |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN109558748B (en) | Data processing method and device, electronic equipment and storage medium | |
| CN109189367B (en) | Data processing method, device, server and storage medium | |
| US11196772B2 (en) | Data access policies | |
| CN111898360B (en) | Text similarity detection method and device based on block chain and electronic equipment | |
| CN111369354A (en) | Data monitoring method and device for block chain application and storage medium | |
| CN110489415B (en) | Data updating method and related equipment | |
| CN111756644B (en) | Hot spot current limiting method, system, equipment and storage medium | |
| CN113840012A (en) | Screen recording evidence obtaining method and system based on block chain and electronic equipment | |
| CN112104671B (en) | Interface authorization monitoring method and device, computer equipment and storage medium | |
| CN109145651B (en) | Data processing method and device | |
| CN115238247A (en) | Data processing method based on zero trust data access control system | |
| CN110443039A (en) | Detection method, device and the electronic equipment of plug-in security | |
| CN112363997B (en) | Data version management method, device and storage medium | |
| WO2022125451A1 (en) | Automatic smart contract analysis | |
| CN110489434B (en) | Information processing method and related equipment | |
| WO2024139739A1 (en) | Method for processing cross-chain request, and apparatus | |
| CN113792346A (en) | Trusted data processing method, device and equipment | |
| CN116993523A (en) | Configurable account checking method, device, equipment and storage medium | |
| US20240073290A1 (en) | Sensitive data classification for micro-service applications | |
| CN117251431A (en) | Method, device, equipment and storage medium for processing business data in throwing account | |
| CN110602051A (en) | Information processing method based on consensus protocol and related device | |
| CN116739596A (en) | Blockchain-based transaction supervision method, device, equipment, medium and product | |
| CN113673844A (en) | Information feedback method, device and equipment | |
| CN116340127A (en) | Interface testing method and device | |
| CN115220714A (en) | Development method and device of application programming interface |
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 |