CN116760741B - Data state monitoring method, device, equipment and medium - Google Patents
Data state monitoring method, device, equipment and medium Download PDFInfo
- Publication number
- CN116760741B CN116760741B CN202311021585.0A CN202311021585A CN116760741B CN 116760741 B CN116760741 B CN 116760741B CN 202311021585 A CN202311021585 A CN 202311021585A CN 116760741 B CN116760741 B CN 116760741B
- Authority
- CN
- China
- Prior art keywords
- data
- target
- transmission
- callback
- subsystem
- 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
- 238000000034 method Methods 0.000 title claims abstract description 48
- 238000012544 monitoring process Methods 0.000 title claims abstract description 37
- 230000005540 biological transmission Effects 0.000 claims abstract description 123
- 230000007246 mechanism Effects 0.000 claims abstract description 36
- 230000001960 triggered effect Effects 0.000 claims abstract description 13
- 238000004590 computer program Methods 0.000 claims description 16
- 238000012806 monitoring device Methods 0.000 claims description 13
- 238000013475 authorization Methods 0.000 claims description 8
- 238000012546 transfer Methods 0.000 claims description 6
- 238000012423 maintenance Methods 0.000 abstract description 25
- 230000000694 effects Effects 0.000 abstract description 11
- 238000013523 data management Methods 0.000 abstract description 2
- 238000004891 communication Methods 0.000 description 17
- 230000002452 interceptive effect Effects 0.000 description 6
- 238000012545 processing Methods 0.000 description 6
- 238000010586 diagram Methods 0.000 description 5
- 230000006870 function Effects 0.000 description 5
- 230000002159 abnormal effect Effects 0.000 description 4
- 230000008569 process Effects 0.000 description 4
- 230000003993 interaction Effects 0.000 description 3
- 230000003287 optical effect Effects 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 2
- 238000007726 management method Methods 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 230000001360 synchronised effect Effects 0.000 description 2
- 238000003491 array Methods 0.000 description 1
- 238000013473 artificial intelligence Methods 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 238000004422 calculation algorithm Methods 0.000 description 1
- 230000001413 cellular effect Effects 0.000 description 1
- 238000007405 data analysis Methods 0.000 description 1
- 230000007547 defect Effects 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 239000011521 glass Substances 0.000 description 1
- 238000002955 isolation Methods 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
- 238000010801 machine learning Methods 0.000 description 1
- 239000013307 optical fiber Substances 0.000 description 1
- 230000004044 response Effects 0.000 description 1
- 239000004065 semiconductor Substances 0.000 description 1
- 230000001953 sensory effect Effects 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
- 230000000007 visual effect Effects 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L43/00—Arrangements for monitoring or testing data switching networks
- H04L43/08—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
- H04L43/0805—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability
- H04L43/0817—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability by checking functioning
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/06—Management of faults, events, alarms or notifications
- H04L41/0631—Management of faults, events, alarms or notifications using root cause analysis; using analysis of correlation between notifications, alarms or events based on decision criteria, e.g. hierarchy, tree or time analysis
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/06—Management of faults, events, alarms or notifications
- H04L41/069—Management of faults, events, alarms or notifications using logs of notifications; Post-processing of notifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/06—Protocols specially adapted for file transfer, e.g. file transfer protocol [FTP]
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Environmental & Geological Engineering (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The invention discloses a data state monitoring method, a device, equipment and a medium, and relates to the technical field of data management. The data state monitoring method comprises the following steps: acquiring target callback data matched with a target subsystem in a transmission task callback interface under a current small station number; determining a final state of target task transmission according to the target callback data, and determining data to be retransmitted and retransmission rules of the data to be retransmitted when a service early warning mechanism is triggered by the final state of target task transmission; and retransmitting the data to be retransmitted according to the retransmission rule of the data to be retransmitted. The technical scheme of the embodiment of the invention can monitor the data state in time, improve the data monitoring effect and further improve the operation and maintenance efficiency.
Description
Technical Field
The present invention relates to the field of data management technologies, and in particular, to a method, an apparatus, a device, and a medium for monitoring a data state.
Background
Currently, most financial company business systems and external financial institution business communication transmissions use a financial data exchange platform provided by a third party. When files are transmitted among financial institutions, each file transmission task needs to pass through a plurality of network service nodes, transmission faults possibly occur among any adjacent nodes and are limited by a communication transmission mechanism, each communication data cannot be timely clear of the transmission state of each communication data, the abnormal transmission is often a business party confusion, three-party technicians are often required to check specific abnormal link problems, local service logs are often required to be manually checked, or the local service logs are checked together through a central technology and operation and maintenance of opposite-end financial institutions, and the operation and maintenance efficiency is low.
Disclosure of Invention
The invention provides a data state monitoring method, a device, equipment and a medium, which are used for solving the problems of poor data state monitoring effect and low operation and maintenance efficiency.
According to an aspect of the present invention, there is provided a data state monitoring method, including:
acquiring target callback data matched with a target subsystem in a transmission task callback interface under a current small station number;
determining a final state of target task transmission according to the target callback data, and determining data to be retransmitted and retransmission rules of the data to be retransmitted when a service early warning mechanism is triggered by the final state of target task transmission;
and retransmitting the data to be retransmitted according to the retransmission rule of the data to be retransmitted.
According to another aspect of the present invention, there is provided a data state monitoring apparatus including:
the data acquisition module is used for acquiring target callback data matched with the target subsystem in the callback interface of the transmission task under the current small station number;
the retransmission rule determining module is used for determining the final state of target task transmission according to the target callback data, and determining the data to be retransmitted and the retransmission rule of the data to be retransmitted when the final state of target task transmission triggers a service early warning mechanism;
and the data retransmission module is used for retransmitting the data to be retransmitted according to the retransmission rule of the data to be retransmitted.
According to another aspect of the present invention, there is provided an electronic apparatus including:
at least one processor; and
a memory communicatively coupled to the at least one processor; wherein,
the memory stores a computer program executable by the at least one processor to enable the at least one processor to perform the data condition monitoring method of any one of the embodiments of the present invention.
According to another aspect of the present invention, there is provided a computer readable storage medium storing computer instructions for causing a processor to execute a data state monitoring method according to any of the embodiments of the present invention.
According to the technical scheme, the target callback data matched with the target subsystem in the transmission task callback interface under the current small station number is obtained, the final state of target task transmission is determined according to the target callback data, when a service early warning mechanism is triggered by the final state of target task transmission, the data to be retransmitted and the retransmission rule of the data to be retransmitted are determined, and the data to be retransmitted is retransmitted according to the retransmission rule of the data to be retransmitted. According to the scheme, only the target callback data of the target subsystem for completing data query authorization under the current small station number can be obtained, the transmission state of service data sent by the target subsystem is timely determined through the final state of target task transmission, and data retransmission is carried out when the transmission fails, so that the operation and maintenance workload of operation and maintenance personnel is greatly reduced, the problems of poor data state monitoring effect and low operation and maintenance efficiency in the prior art are solved, the data state can be monitored in time, the data monitoring effect is improved, and further the operation and maintenance efficiency is improved.
It should be understood that the description in this section is not intended to identify key or critical features of the embodiments of the invention or to delineate the scope of the invention. Other features of the present invention will become apparent from the description that follows.
Drawings
In order to more clearly illustrate the technical solutions of the embodiments of the present invention, the drawings required for the description of the embodiments will be briefly described below, and it is apparent that the drawings in the following description are only some embodiments of the present invention, and other drawings may be obtained according to these drawings without inventive effort for a person skilled in the art.
FIG. 1 is a flowchart of a data status monitoring method according to a first embodiment of the present invention;
FIG. 2 is a flowchart of a data status monitoring method according to a second embodiment of the present invention;
fig. 3 is a file sending timing chart of a third party financial data exchange platform according to a second embodiment of the present invention;
FIG. 4 is a flow chart of a data status monitoring according to a second embodiment of the present invention;
fig. 5 is a schematic structural diagram of a data state monitoring device according to a third embodiment of the present invention;
fig. 6 shows a schematic diagram of an electronic device that may be used to implement an embodiment of the invention.
Detailed Description
In order that those skilled in the art will better understand the present invention, a technical solution in the embodiments of the present invention will be clearly and completely described below with reference to the accompanying drawings in which it is apparent that the described embodiments are only some embodiments of the present invention, not all embodiments. All other embodiments, which can be made by those skilled in the art based on the embodiments of the present invention without making any inventive effort, shall fall within the scope of the present invention.
It should be noted that the term "object" and the like in the description of the present invention and the claims and the above drawings are used for distinguishing between similar objects and not necessarily for describing a particular sequential or chronological order. It is to be understood that the data so used may be interchanged where appropriate such that the embodiments of the invention described herein may be implemented in sequences other than those illustrated or otherwise described herein. Furthermore, the terms "comprises," "comprising," and "having," and any variations thereof, are intended to cover a non-exclusive inclusion, such that a process, method, system, article, or apparatus that comprises a list of steps or elements is not necessarily limited to those steps or elements expressly listed but may include other steps or elements not expressly listed or inherent to such process, method, article, or apparatus.
Example 1
Fig. 1 is a flowchart of a data state monitoring method according to a first embodiment of the present invention, where the method may be implemented by a data state monitoring device, and the data state monitoring device may be implemented in hardware and/or software, and the data state monitoring device may be configured in an electronic device. As shown in fig. 1, the method includes:
s110, acquiring target callback data matched with a target subsystem in a transmission task callback interface under the current small station number.
The current small station number can be a login account configured for the user by the third party financial data exchange platform. The third party financial data exchange platform may be a third party platform that provides data interactive transmission functionality for different financial institutions. The transmission task callback interface may be an interface supporting transmission task callback provided by the third party financial data exchange platform for the user. The target subsystem may be a business subsystem that logs in to the current small station number and completes the authorization of the data query. The multiple service subsystems can share a small station number, namely a login account number configured by a third-party financial data exchange platform for a user, and each service subsystem can have own data query authority. The target callback data may be data associated with the target subsystem service transfer that is callback through the transfer task callback interface. The target callback data may include, but is not limited to, file transfer type, source user identification, destination user identification, task start time, original file size, send path, success or failure, etc. The user identification may be a user account or the like for distinguishing between different user indicia.
In the embodiment of the invention, the callback interface of the transmission task under the current small station number can be determined, and then the target subsystem for completing the data query authorization is determined from the service subsystem for carrying out the data callback through the callback interface of the transmission task under the current small station number, and the target callback data matched with the target subsystem is read.
Typically, the third party financial data exchange platform will assign respective small station numbers to different financial institutions, and the financial institutions may log into the third party financial data exchange platform by assigning their own small station numbers, upload data, and/or receive data. A financial institution has a plurality of service subsystems, a terminal logging in a small station number can check interactive data of each service subsystem at the same time, data security cannot be guaranteed, and when the service subsystems respectively have query rights of the system, service isolation of data query of different service subsystems can be realized, and data security is guaranteed.
And S120, determining a final state of target task transmission according to the target callback data, and determining data to be retransmitted and retransmission rules of the data to be retransmitted when a service early warning mechanism is triggered by the final state of target task transmission.
The final state of the target task transmission may be a final transmission state of the service data corresponding to the target callback data. The final state of the target task transmission may include a transmission success or a transmission failure. The service early warning mechanism can be an early warning mechanism triggered when the final state of the target task transmission is transmission failure. The data to be retransmitted may be service data corresponding to the final state of the target task transmission when the final state of the target task transmission triggers the service early warning mechanism. The retransmission rules may be a data transmission mechanism that is used when triggering a traffic alert mechanism.
In the embodiment of the invention, the data analysis can be performed on the target callback data, the transmission state of the task data corresponding to the target callback data is determined, the final transmission state of the target task is obtained, and when the final transmission state of the target task is transmission failure, a service early warning mechanism is triggered, so that the data to be retransmitted, which is matched with the final transmission state of the target task, is obtained, and a preconfigured retransmission rule, namely, the retransmission rule of the data to be retransmitted, is obtained.
S130, retransmitting the data to be retransmitted according to the retransmission rule of the data to be retransmitted.
In the embodiment of the invention, the data to be retransmitted can be retransmitted to the terminal of the destination institution through a third-party financial data exchange platform by utilizing the retransmission rule of the data to be retransmitted.
According to the technical scheme, the target callback data matched with the target subsystem in the transmission task callback interface under the current small station number is obtained, the final state of target task transmission is determined according to the target callback data, when a service early warning mechanism is triggered by the final state of target task transmission, the data to be retransmitted and the retransmission rule of the data to be retransmitted are determined, and the data to be retransmitted is retransmitted according to the retransmission rule of the data to be retransmitted. According to the scheme, only the target callback data of the target subsystem for completing data query authorization under the current small station number can be obtained, the transmission state of service data sent by the target subsystem is timely determined through the final state of target task transmission, and data retransmission is carried out when the transmission fails, so that the operation and maintenance workload of operation and maintenance personnel is greatly reduced, the problems of poor data state monitoring effect and low operation and maintenance efficiency in the prior art are solved, the data state can be monitored in time, the data monitoring effect is improved, and further the operation and maintenance efficiency is improved.
Example two
Fig. 2 is a flowchart of a data state monitoring method provided by a second embodiment of the present invention, where the embodiment is implemented based on the foregoing embodiment, and a specific optional implementation manner of displaying target callback data after obtaining target callback data matched with a target subsystem in a task callback interface transmitted under a current small station number is provided. As shown in fig. 2, the method includes:
s210, acquiring target callback data matched with a target subsystem in a transmission task callback interface under the current small station number.
S220, receiving user login data of the user login target subsystem, and displaying target callback data matched with the target subsystem when the user login data meets the login right of the target subsystem.
The user login data may be system login permission data that needs to be input when the user logs in the target subsystem. The user login data may include, but is not limited to, a user account number, a password, and the like.
In the embodiment of the invention, the user login data input when the user logs in the target subsystem can be received, so that whether the user login data meets the login permission of the target subsystem is judged, and if the user login data meets the login permission of the target subsystem, the target callback data which is called back by the target subsystem through the transmission task callback interface can be displayed by utilizing the display, so that the user can conveniently check by operation and maintenance personnel.
In an optional embodiment of the present invention, when the user login data meets the login rights of the target subsystem, the method may further include: receiving a file inquiry downloading instruction sent by a user; and displaying the user query downloading data according to the file query downloading instruction and the target callback data.
The file query downloading instruction may be an instruction sent by the user to download data in a query. The user query download data may be matched with the file query download instruction, and the user needs to query the downloaded service association data.
In the embodiment of the invention, if the user login data meets the login rights of the target subsystem, whether the user sends a file inquiry downloading instruction is detected, if the user sends the file inquiry downloading instruction, the file inquiry downloading instruction is analyzed, the target callback data is combined, the user inquiry downloading data matched with the file inquiry downloading instruction is determined, and then the user inquiry downloading data is displayed based on the display.
Optionally, the user may download relevant transmission task data, such as task date and time, small station number, file size, file name, transmission rule, transmission status, service type, etc., through multidimensional query.
In an optional embodiment of the present invention, before obtaining the target callback data matched with the target subsystem in the task callback interface transmitted under the current small station number, the method may further include: acquiring transmission rule configuration data sent by a user; and carrying out paged transmission rule configuration according to the transmission rule configuration data.
The transmission rule configuration data may be preset data for configuring a service data transmission rule. The transmission rule configuration data may include a file transceiving directory, a rule type, a rule name, a rule description, a scan type and interval, a transceiving priority, whether a file is compressed, a task validity period, and the like.
In the embodiment of the invention, the paging communication configuration function can be provided for the user according to the system user authority, and when the user is determined to have the configuration authority, the transmission rule configuration data sent by the user can be obtained, and then the paging transmission rule configuration is carried out according to the transmission rule configuration data.
In an optional embodiment of the present invention, before obtaining the target callback data matched with the target subsystem in the task callback interface transmitted under the current small station number, the method may further include: obtaining retransmission rule data sent by a user; and carrying out paged retransmission rule configuration according to the retransmission rule data.
Wherein, the retransmission rule data may be preset for configuring the data of the retransmission rule.
Correspondingly, the service interaction is limited by the current communication transmission mechanism, and a transmission failure scene often occurs, so that retransmission rule data sent by a user can be obtained when the user is determined to have configuration rights, and then the paged retransmission rule configuration is performed according to the retransmission rule data.
Optionally, whether the retransmission is automatically failed and the number of retransmissions is configured according to the file suffix type, the file size, the file name, the regular matching and the like, i.e. the configuration of the retransmission rule is completed.
S230, determining the final state of target task transmission according to the target callback data, and determining the data to be retransmitted and the retransmission rule of the data to be retransmitted when the final state of target task transmission triggers a service early warning mechanism.
In an optional embodiment of the present invention, when the target task transmission end state triggers the service early warning mechanism, the method may further include: generating target early warning data according to the final state of target task transmission; and sending the target early warning data to the target user through the warning information sending type matched with the service early warning mechanism.
The target early warning data can be early warning data which is generated and is associated with the target callback data when the early warning mechanism is triggered. The type of alert information sent may be the manner in which the targeted alert data is sent. The type of alert information transmission may include, but is not limited to, mail, text message, alarm signal, etc. The target user can be an operation and maintenance person who needs to know the service data transmission condition in time.
In the embodiment of the invention, when the service early warning mechanism is triggered in the final state of the target task transmission, the target early warning data can be generated according to the final state of the target task transmission and the target callback data, and then the warning information sending type matched with the service early warning mechanism is determined, so that the target early warning data is sent to a target user through the warning information sending type matched with the service early warning mechanism.
Optionally, the service condition of the local end of the financial institution, the transmission condition of the communication task and the like can be used as target early warning data, and the target user can be notified in an alarm mode such as a short message, a mail and the like.
S240, retransmitting the data to be retransmitted according to the retransmission rule of the data to be retransmitted.
In a specific example, a callback CMD script may be configured at the third party financial data exchange platform client, that is, a corresponding program for executing the data status monitoring method, and the callback CMD script is configured to request callback data to a background service of the financial institution end logging in the current small station number. According to the callback flow which is actually configured, all task data trigger the CMD script after transmission operation is carried out, so that the transmission final state of each transmission task is timely obtained. Callback data in the callback interface of the transmission task can be forwarded to a corresponding service subsystem, and a communication transmission mechanism and a service flow are perfected.
Optionally, the CMD script and the configuration function may be packaged into a tool, the target callback data and various configuration data may be used as a basic data source of the tool, the basic configuration data such as the transmission rule configuration data is in json format, and the data may be converted and automatically synchronized with the financial institution terminal logging in the current small station number. The tool can be independently deployed as a plug-in unit for users and operation and maintenance personnel of each system, and is switched from facing operation and maintenance to facing users, and functions of transmission rule configuration, communication task query downloading, failed retransmission rule configuration, early warning configuration and the like of each system are provided, so that the service transmission is intelligent, transparent and controllable, and service risk is prevented.
Fig. 3 is a timing chart of file transmission of a third party financial data exchange platform according to a second embodiment of the present invention. As shown in fig. 3, the target subsystem of the local end of the financial institution sends the task data to the first interactive tool of the third party and the local end, the first interactive tool of the third party and the local end (a data interactive tool of the local end and the third party) sends the task data to the third party service center, the third party service center sends the task data to the third party financial data exchange platform, and the third party financial data exchange platform sends the task data to the third party financial institution application system. The third party financial institution application may transmit the feedback file to the target subsystem in the order of transmission of fig. 3. The third party service center can send the target callback data to the target subsystem, the target subsystem forwards the target callback data to the tool configured at the local end of the financial institution through an http protocol, and the tool configured at the local end of the financial institution can send and receive response data to the target subsystem and can also send a notify signal to the target subsystem.
Fig. 4 is a flow chart of a data state monitoring process according to a second embodiment of the present invention, as shown in fig. 4, where the pension core service system, pension group risk system, investment wind control and investment advisor system and personal pension guarantee system may be a class 4 service subsystem, and the foregoing tools configured at the local end of the financial institution are used to implement file/message transmission, query downloading, retransmission, early warning and configuration. The first interactive tool and the local end of the financial institution need to configure a synchronous interface and a failed retransmission rule, and the tool can also send abnormal information to other business systems. When the local end of the financial institution is a word configuration tool, the user/operation can only find that the service is abnormal or failed, at the moment, the service is blocked, the operation and maintenance personnel inform IT personnel to process the service, and then the key service personnel log in a service interface provided by a third-party financial data exchange platform to perform data inquiry, so that data retransmission is completed, and the effects that the final state of service data transmission can not be found in time and data retransmission is automatically performed can not be realized.
After the financial institution terminal with the data state monitoring requirement is accessed to the tool, the enterprise network of the financial institution terminal can perform unified identity authentication login jump to realize inquiry and downloading of transmission tasks of related systems, functional configuration and the like, so that the transmission state of any task data can be updated in real time, the transparency of each service transmission multilink is realized, the unified management of each service subsystem of a public small station number is realized, and flexible configuration of failure retransmission rules and timely early warning of service transmission are supported.
According to the technical scheme, the target callback data matched with the target subsystem in the transmission task callback interface under the current small station number is obtained, user login data of a user login target subsystem is further received, the target callback data matched with the target subsystem is displayed when the user login data meets the login right of the target subsystem, accordingly, the final state of target task transmission is determined according to the target callback data, when a service early warning mechanism is triggered by the final state of target task transmission, data to be retransmitted and retransmission rules of the data to be retransmitted are determined, and the data to be retransmitted is retransmitted according to the retransmission rules of the data to be retransmitted. According to the scheme, only the target callback data of the target subsystem for completing data query authorization under the current small station number can be obtained, the transmission state of service data sent by the target subsystem is timely determined through the final state of target task transmission, and data retransmission is carried out when the transmission fails, so that the operation and maintenance workload of operation and maintenance personnel is greatly reduced, the problems of poor data state monitoring effect and low operation and maintenance efficiency in the prior art are solved, the data state can be monitored in time, the data monitoring effect is improved, and further the operation and maintenance efficiency is improved.
Example III
Fig. 5 is a schematic structural diagram of a data status monitoring device according to a third embodiment of the present invention. As shown in fig. 5, the apparatus includes: a data acquisition module 310, a retransmission rule determination module 320, and a data retransmission module 330, wherein,
the data acquisition module 310 is configured to acquire target callback data matched with the target subsystem in the callback interface of the transmission task under the current small station number;
the retransmission rule determining module 320 is configured to determine a final state of transmission of the target task according to the target callback data, and determine data to be retransmitted and a retransmission rule of the data to be retransmitted when the final state of transmission of the target task triggers a service early warning mechanism;
the data retransmission module 330 is configured to retransmit the data to be retransmitted according to a retransmission rule of the data to be retransmitted.
According to the technical scheme, the target callback data matched with the target subsystem in the transmission task callback interface under the current small station number is obtained, the final state of target task transmission is determined according to the target callback data, when a service early warning mechanism is triggered by the final state of target task transmission, the data to be retransmitted and the retransmission rule of the data to be retransmitted are determined, and the data to be retransmitted is retransmitted according to the retransmission rule of the data to be retransmitted. According to the scheme, only the target callback data of the target subsystem for completing data query authorization under the current small station number can be obtained, the transmission state of service data sent by the target subsystem is timely determined through the final state of target task transmission, and data retransmission is carried out when the transmission fails, so that the operation and maintenance workload of operation and maintenance personnel is greatly reduced, the problems of poor data state monitoring effect and low operation and maintenance efficiency in the prior art are solved, the data state can be monitored in time, the data monitoring effect is improved, and further the operation and maintenance efficiency is improved.
Optionally, the data state monitoring device further includes a first display module, configured to receive user login data of a user logging in the target subsystem, and display the target callback data matched with the target subsystem when the user login data meets a login right of the target subsystem.
Optionally, the data state monitoring device further includes a second display module, configured to receive a file query downloading instruction sent by a user; and displaying the user query downloading data according to the file query downloading instruction and the target callback data.
Optionally, the data state monitoring device further includes a first configuration module, configured to obtain transmission rule configuration data sent by the user; and carrying out paged transmission rule configuration according to the transmission rule configuration data.
Optionally, the data state monitoring device further includes a second configuration module, configured to obtain retransmission rule data sent by the user; and carrying out paged retransmission rule configuration according to the retransmission rule data.
Optionally, the data state monitoring device further includes a third configuration module, configured to obtain service early warning mechanism configuration data sent by the user; and configuring the service early warning mechanism according to the service early warning mechanism configuration data.
Optionally, the data state monitoring device further comprises an early warning data sending module, which is used for generating target early warning data according to the final state of the target task transmission; and transmitting the target early warning data to a target user through the warning information transmission type matched with the service early warning mechanism.
The data state monitoring device provided by the embodiment of the invention can execute the data state monitoring method provided by any embodiment of the invention, and has the corresponding functional modules and beneficial effects of the execution method.
Example IV
Fig. 6 shows a schematic diagram of an electronic device that may be used to implement an embodiment of the invention. Electronic devices are intended to represent various forms of digital computers, such as laptops, desktops, workstations, personal digital assistants, servers, blade servers, mainframes, and other appropriate computers. Electronic equipment may also represent various forms of mobile devices, such as personal digital processing, cellular telephones, smartphones, wearable devices (e.g., helmets, glasses, watches, etc.), and other similar computing devices. The components shown herein, their connections and relationships, and their functions, are meant to be exemplary only, and are not meant to limit implementations of the inventions described and/or claimed herein.
As shown in fig. 6, the electronic device 10 includes at least one processor 11, and a memory, such as a Read Only Memory (ROM) 12, a Random Access Memory (RAM) 13, etc., communicatively connected to the at least one processor 11, in which the memory stores a computer program executable by the at least one processor, and the processor 11 may perform various appropriate actions and processes according to the computer program stored in the Read Only Memory (ROM) 12 or the computer program loaded from the storage unit 18 into the Random Access Memory (RAM) 13. In the RAM 13, various programs and data required for the operation of the electronic device 10 may also be stored. The processor 11, the ROM 12 and the RAM 13 are connected to each other via a bus 14. An input/output (I/O) interface 15 is also connected to bus 14.
Various components in the electronic device 10 are connected to the I/O interface 15, including: an input unit 16 such as a keyboard, a mouse, etc.; an output unit 17 such as various types of displays, speakers, and the like; a storage unit 18 such as a magnetic disk, an optical disk, or the like; and a communication unit 19 such as a network card, modem, wireless communication transceiver, etc. The communication unit 19 allows the electronic device 10 to exchange information/data with other devices via a computer network, such as the internet, and/or various telecommunication networks.
The processor 11 may be a variety of general and/or special purpose processing components having processing and computing capabilities. Some examples of processor 11 include, but are not limited to, a Central Processing Unit (CPU), a Graphics Processing Unit (GPU), various specialized Artificial Intelligence (AI) computing chips, various processors running machine learning model algorithms, digital Signal Processors (DSPs), and any suitable processor, controller, microcontroller, etc. The processor 11 performs the various methods and processes described above, such as the data state monitoring method.
In some embodiments, the data state monitoring method may be implemented as a computer program tangibly embodied on a computer-readable storage medium, such as storage unit 18. In some embodiments, part or all of the computer program may be loaded and/or installed onto the electronic device 10 via the ROM 12 and/or the communication unit 19. One or more of the steps of the data state monitoring method described above may be performed when the computer program is loaded into RAM 13 and executed by processor 11. Alternatively, in other embodiments, the processor 11 may be configured to perform the data state monitoring method in any other suitable manner (e.g., by means of firmware).
Various implementations of the systems and techniques described here above may be implemented in digital electronic circuitry, integrated circuit systems, field Programmable Gate Arrays (FPGAs), application Specific Integrated Circuits (ASICs), application Specific Standard Products (ASSPs), systems On Chip (SOCs), load programmable logic devices (CPLDs), computer hardware, firmware, software, and/or combinations thereof. These various embodiments may include: implemented in one or more computer programs, the one or more computer programs may be executed and/or interpreted on a programmable system including at least one programmable processor, which may be a special purpose or general-purpose programmable processor, that may receive data and instructions from, and transmit data and instructions to, a storage system, at least one input device, and at least one output device.
A computer program for carrying out methods of the present invention may be written in any combination of one or more programming languages. These computer programs may be provided to a processor of a general purpose computer, special purpose computer, or other programmable data processing apparatus, such that the computer programs, when executed by the processor, cause the functions/acts specified in the flowchart and/or block diagram block or blocks to be implemented. The computer program may execute entirely on the machine, partly on the machine, as a stand-alone software package, partly on the machine and partly on a remote machine or entirely on the remote machine or server.
In the context of the present invention, a computer-readable storage medium may be a tangible medium that can contain, or store a computer program for use by or in connection with an instruction execution system, apparatus, or device. The computer readable storage medium may include, but is not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any suitable combination of the foregoing. Alternatively, the computer readable storage medium may be a machine readable signal medium. More specific examples of a machine-readable storage medium would include an electrical connection based on 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.
To provide for interaction with a user, the systems and techniques described here can be implemented on an electronic device having: a display device (e.g., a CRT (cathode ray tube) or LCD (liquid crystal display) monitor) for displaying information to a user; and a keyboard and a pointing device (e.g., a mouse or a trackball) through which a user can provide input to the electronic device. Other kinds of devices may also be used to provide for interaction with a user; for example, feedback provided to the user may be any form of sensory feedback (e.g., visual feedback, auditory feedback, or tactile feedback); and input from the user may be received in any form, including acoustic input, speech input, or tactile input.
The systems and techniques described here can be implemented in a computing system that includes a background component (e.g., as a data server), or that includes a middleware component (e.g., an application server), or that includes a front-end component (e.g., a user computer having a graphical user interface or a web browser through which a user can interact with an implementation of the systems and techniques described here), or any combination of such background, middleware, or front-end components. The components of the system can be interconnected by any form or medium of digital data communication (e.g., a communication network). Examples of communication networks include: local Area Networks (LANs), wide Area Networks (WANs), blockchain networks, and the internet.
The computing system may include clients and servers. The client and server are typically remote from each other and typically interact through a communication network. The relationship of client and server arises by virtue of computer programs running on the respective computers and having a client-server relationship to each other. The server can be a cloud server, also called a cloud computing server or a cloud host, and is a host product in a cloud computing service system, so that the defects of high management difficulty and weak service expansibility in the traditional physical hosts and VPS service are overcome.
It should be appreciated that various forms of the flows shown above may be used to reorder, add, or delete steps. For example, the steps described in the present invention may be performed in parallel, sequentially, or in a different order, so long as the desired results of the technical solution of the present invention are achieved, and the present invention is not limited herein.
The above embodiments do not limit the scope of the present invention. It will be apparent to those skilled in the art that various modifications, combinations, sub-combinations and alternatives are possible, depending on design requirements and other factors. Any modifications, equivalent substitutions and improvements made within the spirit and principles of the present invention should be included in the scope of the present invention.
Claims (9)
1. A method for monitoring a data state, comprising:
acquiring target callback data matched with a target subsystem in a transmission task callback interface under a current small station number; the target subsystem is a service subsystem which logs in the current small station number and completes data query authorization;
after the target callback data matched with the target subsystem in the task callback interface is acquired under the current small station number, the method further comprises the following steps:
receiving user login data of a user logging in the target subsystem, and displaying the target callback data matched with the target subsystem when the user login data meets the login right of the target subsystem;
determining a final state of target task transmission according to the target callback data, and determining data to be retransmitted and retransmission rules of the data to be retransmitted when a service early warning mechanism is triggered by the final state of target task transmission;
and retransmitting the data to be retransmitted according to the retransmission rule of the data to be retransmitted.
2. The method of claim 1, wherein when the user login data meets the login rights of the target subsystem, further comprising:
receiving a file inquiry downloading instruction sent by a user;
and displaying the user query downloading data according to the file query downloading instruction and the target callback data.
3. The method of claim 1, further comprising, prior to obtaining the target callback data in the transfer task callback interface matching the target subsystem under the current cell number:
acquiring transmission rule configuration data sent by a user;
and carrying out paged transmission rule configuration according to the transmission rule configuration data.
4. The method of claim 1, further comprising, prior to obtaining the target callback data in the transfer task callback interface matching the target subsystem under the current cell number:
obtaining retransmission rule data sent by a user;
and carrying out paged retransmission rule configuration according to the retransmission rule data.
5. The method of claim 1, further comprising, prior to obtaining the target callback data in the transfer task callback interface matching the target subsystem under the current cell number:
acquiring service early warning mechanism configuration data sent by a user;
and configuring the service early warning mechanism according to the service early warning mechanism configuration data.
6. The method of claim 1, further comprising, when the target task transmission end state triggers a traffic alert mechanism:
generating target early warning data according to the final state of the target task transmission;
and transmitting the target early warning data to a target user through the warning information transmission type matched with the service early warning mechanism.
7. A data condition monitoring apparatus, comprising:
the data acquisition module is used for acquiring target callback data matched with the target subsystem in the callback interface of the transmission task under the current small station number; the target subsystem is a service subsystem which logs in the current small station number and completes data query authorization;
the retransmission rule determining module is used for determining a target task transmission final state according to the target callback data, and determining data to be retransmitted and a retransmission rule of the data to be retransmitted when a service early warning mechanism is triggered by the target task transmission final state;
the data retransmission module is used for retransmitting the data to be retransmitted according to the retransmission rule of the data to be retransmitted;
the data state monitoring device further comprises a first display module, wherein the first display module is used for receiving user login data of a user logging in the target subsystem, and displaying the target callback data matched with the target subsystem when the user login data meets the login right of the target subsystem.
8. An electronic device, the electronic device comprising:
at least one processor; and
a memory communicatively coupled to the at least one processor; wherein,
the memory stores a computer program executable by the at least one processor to enable the at least one processor to perform the data condition monitoring method of any one of claims 1-6.
9. A computer readable storage medium storing computer instructions for causing a processor to perform the data condition monitoring method of any one of claims 1-6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202311021585.0A CN116760741B (en) | 2023-08-15 | 2023-08-15 | Data state monitoring method, device, equipment and medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202311021585.0A CN116760741B (en) | 2023-08-15 | 2023-08-15 | Data state monitoring method, device, equipment and medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN116760741A CN116760741A (en) | 2023-09-15 |
| CN116760741B true CN116760741B (en) | 2023-11-07 |
Family
ID=87961174
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202311021585.0A Active CN116760741B (en) | 2023-08-15 | 2023-08-15 | Data state monitoring method, device, equipment and medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN116760741B (en) |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109672583A (en) * | 2018-09-25 | 2019-04-23 | 平安科技（深圳）有限公司 | Method for monitoring network, equipment, storage medium and device |
| CN109743390A (en) * | 2019-01-04 | 2019-05-10 | 深圳壹账通智能科技有限公司 | Method for scheduling task, device, computer equipment and storage medium |
| CN112308537A (en) * | 2020-11-27 | 2021-02-02 | 五八到家有限公司 | System, method, device and medium for processing position data |
| CN114358515A (en) * | 2021-12-13 | 2022-04-15 | 石化盈科信息技术有限责任公司 | Monitoring alarm method, system, storage medium and electronic equipment |
| CN116015561A (en) * | 2022-12-02 | 2023-04-25 | 平安银行股份有限公司 | Data reissue method, device, equipment and storage medium |
Family Cites Families (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US9106800B2 (en) * | 2007-08-31 | 2015-08-11 | At&T Intellectual Property I, L.P. | System and method of monitoring video data packet delivery |
-
2023
- 2023-08-15 CN CN202311021585.0A patent/CN116760741B/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN109672583A (en) * | 2018-09-25 | 2019-04-23 | 平安科技（深圳）有限公司 | Method for monitoring network, equipment, storage medium and device |
| CN109743390A (en) * | 2019-01-04 | 2019-05-10 | 深圳壹账通智能科技有限公司 | Method for scheduling task, device, computer equipment and storage medium |
| CN112308537A (en) * | 2020-11-27 | 2021-02-02 | 五八到家有限公司 | System, method, device and medium for processing position data |
| CN114358515A (en) * | 2021-12-13 | 2022-04-15 | 石化盈科信息技术有限责任公司 | Monitoring alarm method, system, storage medium and electronic equipment |
| CN116015561A (en) * | 2022-12-02 | 2023-04-25 | 平安银行股份有限公司 | Data reissue method, device, equipment and storage medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN116760741A (en) | 2023-09-15 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US9774697B2 (en) | Method, apparatus, and system for pushing notification | |
| CN103259684A (en) | Internet service monitoring method and system | |
| CN112911013A (en) | Cloud application processing method and device, computer equipment and storage medium | |
| CN112035344A (en) | Multi-scenario test method, device, equipment and computer readable storage medium | |
| CN112087475B (en) | Message pushing method and device for cloud platform component application and message server | |
| CN111131382A (en) | Message monitoring method and device | |
| CN116760741B (en) | Data state monitoring method, device, equipment and medium | |
| CN115883647B (en) | Service log recording method, system, device, terminal, server and medium | |
| CN115529186B (en) | SSL certificate unloading method, device and system based on soft load balancing | |
| CN115396523A (en) | Internet of things data processing method, device, equipment, medium and internet of things soft gateway | |
| CN112306791B (en) | Performance monitoring method and device | |
| CN110958148A (en) | Deployment system of distributed access equipment | |
| CN114615168B (en) | Application level monitoring method and device, electronic equipment, storage medium and product | |
| CN114465996B (en) | Interface authority control system and method and electronic equipment | |
| CN112162868B (en) | Data communication method, device and storage medium applied to cluster processing | |
| CN116260855B (en) | Communication method, communication device, electronic equipment and storage medium | |
| CN111371602B (en) | Alarm information processing method and equipment | |
| CN118784332A (en) | Cross-cluster password-free login method and device, electronic equipment and storage medium | |
| CN115695288A (en) | Login control method and device, electronic equipment and storage medium | |
| CN116501968A (en) | Method, device, electronic equipment and medium for subscribing internet of things data | |
| CN117596288A (en) | Message transmission method and device, electronic equipment and storage medium | |
| CN117519753A (en) | Remote upgrading method, device and equipment of terminal equipment and storage medium | |
| CN115134237A (en) | Data updating method, heartbeat detection method, device, equipment and medium | |
| CN115801357A (en) | Global exception handling method, device, equipment and storage medium | |
| CN117914893A (en) | Information collaboration method, device, equipment and medium |
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 |