CN109144735B - Method and apparatus for processing data - Google Patents
Method and apparatus for processing data Download PDFInfo
- Publication number
- CN109144735B CN109144735B CN201811146469.0A CN201811146469A CN109144735B CN 109144735 B CN109144735 B CN 109144735B CN 201811146469 A CN201811146469 A CN 201811146469A CN 109144735 B CN109144735 B CN 109144735B
- Authority
- CN
- China
- Prior art keywords
- data processing
- target
- data
- information
- processing system
- 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
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5005—Allocation of resources, e.g. of the central processing unit [CPU] to service a request
- G06F9/5027—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals
- G06F9/5038—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals considering the execution order of a plurality of tasks, e.g. taking priority or time dependency constraints into consideration
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Computer And Data Communications (AREA)
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
Abstract
The embodiment of the application discloses a method and a device for processing data. One embodiment of the above method comprises: receiving a data processing request, wherein the data processing request comprises a target user identifier, a target interface identifier and to-be-processed data; determining a target data processing system according to the target user identification and the target interface identification, wherein the target data processing system comprises a data processing node set for processing data, the data processing nodes in the data processing node set are sequentially connected, and the data processing node set comprises a data processing node as an inlet and a data processing node as an outlet; inputting data to be processed into a data processing node serving as an inlet, and obtaining a processing result output from the data processing node serving as an outlet; and sending the processing result. By the implementation mode, different processing on the data can be realized by changing the data processing nodes or the sequence between the nodes by enterprise users, and the convenience of the enterprise users for the configuration of the processing process is improved.
Description
Technical Field
The embodiment of the application relates to the technical field of computers, in particular to a method and a device for processing data.
Background
With the development of artificial intelligence technology, artificial intelligence dialogue operating systems are emerging. Because the artificial intelligence dialogue operation system can provide a plurality of interfaces, the services of a plurality of subsystems can be provided. When an enterprise user uses an artificial intelligent dialogue operating system, a technician needs to explain an interface and a subsystem for many times in the process of docking with technicians of different enterprise users. A large amount of time is consumed, and the landing progress of the artificial intelligent dialogue operating system is influenced.
Disclosure of Invention
The embodiment of the application provides a method and a device for processing data.
In a first aspect, an embodiment of the present application provides a method for processing data, including: receiving a data processing request, wherein the data processing request comprises a target user identifier, a target interface identifier and to-be-processed data; determining a target data processing system according to the target user identifier and the target interface identifier, wherein the target data processing system comprises a data processing node set for processing data, the data processing nodes in the data processing node set are sequentially connected, and the data processing node set comprises a data processing node as an inlet and a data processing node as an outlet; inputting the data to be processed into a data processing node as an entrance to obtain a processing result output from the data processing node as an exit; and sending the processing result.
In some embodiments, the determining a target data processing system according to the target user identifier and the target interface identifier includes: determining a target data processing system corresponding to the target user identifier and the target interface identifier from a preset data processing system set, wherein the data processing system set is obtained by the following steps: acquiring a data processing system from a preset position at intervals of preset time, wherein the data processing system corresponds to a user identifier and an interface identifier; and adding the acquired data processing system into the data processing system set.
In some embodiments, the data processing node comprises a data entry and a data exit, the target data processing system comprises configuration information of the data processing node, the configuration information comprising a response time and a first response message; and the above method further comprises: and for the data processing nodes in the data processing node set, in response to determining that the data is not output from the data outlet of the data processing node after the response time elapses since the data enters from the data inlet of the data processing node, returning the first response message.
In some embodiments, before the receiving the data processing request, the method further comprises: receiving registration information and forwarding the registration information to an auditing terminal; generating a user identifier in response to receiving an audit passing message aiming at the registration information sent by the audit terminal; and sending the user identification.
In some embodiments, the above method further comprises: generating verification information corresponding to the user identifier in response to receiving an audit passing message aiming at the registration information sent by the audit terminal; and returning the verification information.
In some embodiments, the data processing request further includes target verification information; and the determining a target data processing system according to the target user identifier and the target interface identifier comprises: determining verification information corresponding to the target user identification as reference verification information; and in response to determining that the target verification information is matched with the reference verification information, determining a target data processing system according to the target user identifier and the target interface identifier.
In some embodiments, the target data processing system stores information return mode configuration information, where the information return mode configuration information includes information synchronous return mode information or information asynchronous return mode information; and the sending of the processing result includes: in response to determining that the information return mode configuration information in the target data processing system is asynchronous return mode information, returning preset second response information after receiving the data processing request; and storing the processing results in a preset queue and sequentially sending the processing results in the queue.
In a second aspect, an embodiment of the present application provides an apparatus for processing data, including: the data processing device comprises a request receiving unit, a processing unit and a processing unit, wherein the request receiving unit is configured to receive a data processing request which comprises a target user identifier, a target interface identifier and data to be processed; a system determination unit configured to determine a target data processing system according to the target user identifier and the target interface identifier, where the target data processing system includes a data processing node set for processing data, and data processing nodes in the data processing node set are sequentially connected, and the data processing node set includes a data processing node as an entry and a data processing node as an exit; a result determination unit configured to input the data to be processed into a data processing node as an entry, and obtain a processing result output from the data processing node as an exit; a result transmitting unit configured to transmit the processing result.
In some embodiments, the system determination unit is further configured to: determining a target data processing system corresponding to the target user identifier and the target interface identifier from a preset data processing system set; wherein the data processing system set is obtained by the following steps: acquiring a data processing system from a preset position at intervals of preset time, wherein the data processing system corresponds to a user identifier and an interface identifier; and adding the acquired data processing system into the data processing system set.
In some embodiments, the data processing node comprises a data entry and a data exit, the target data processing system comprises configuration information of the data processing node, the configuration information comprising a response time and a first response message; and the apparatus further comprises a response message sending unit configured to: and for the data processing nodes in the data processing node set, responding to the determination that the data is not output from the data outlet of the data processing node after the response time elapses since the data enters from the data inlet of the data processing node, and sending the first response message.
In some embodiments, the above apparatus further comprises: a registration information sending unit configured to receive registration information and forward the registration information to an audit terminal before the request receiving unit receives a data processing request; a user identifier generating unit configured to generate a user identifier in response to receiving an audit pass message for the registration information sent by the audit terminal; and the user identification sending unit is configured to send the user identification.
In some embodiments, the above apparatus further comprises: a verification information generating unit configured to generate verification information corresponding to the user identifier in response to receiving an audit passing message for the registration information sent by the audit terminal; and a check information transmitting unit configured to transmit the check information.
In some embodiments, the data processing request further includes target verification information; and the system determination unit is further configured to: determining verification information corresponding to the target user identification as reference verification information; and in response to determining that the target verification information is matched with the reference verification information, determining a target data processing system according to the target user identifier and the target interface identifier.
In some embodiments, the target data processing system is associated with information return mode configuration information, the information return mode configuration information including synchronous return mode information or asynchronous return mode information; and the result sending unit is further configured to: and in response to determining that the information return mode configuration information associated with the target data processing system is asynchronous return mode information, sending preset second response information, storing the processing result in a preset queue, and sequentially sending the processing result in the queue.
In a third aspect, an embodiment of the present application provides a server, including: one or more processors; a storage device, on which one or more programs are stored, which, when executed by the one or more processors, cause the one or more processors to implement the method as described in any of the embodiments of the first aspect.
In a fourth aspect, the present application provides a computer-readable medium, on which a computer program is stored, which when executed by a processor implements the method as described in any one of the embodiments of the first aspect.
The method and the apparatus for processing data provided by the above embodiments of the present application may first receive a data processing request, where the data processing request may include a target user identifier, a target interface identifier, and data to be processed. The target data processing system may then be determined based on the target user identification and the target interface identification. And inputting the data to be processed into the data processing node as an entrance, and obtaining a processing result output from the data processing node as an exit. And finally, sending the processing result. According to the method and the device, the data to be processed can be processed by using the data processing nodes connected in series in sequence, so that a user can realize different data processing processes by changing the sequence among the data processing nodes or changing the data processing nodes, and the convenience of the user for the configuration of the processing processes is improved.
Drawings
Other features, objects and advantages of the present application will become more apparent upon reading of the following detailed description of non-limiting embodiments thereof, made with reference to the accompanying drawings in which:
FIG. 1 is an exemplary system architecture diagram in which one embodiment of the present application may be applied;
FIG. 2 is a flow diagram of one embodiment of a method for processing data according to the present application;
FIG. 3 is a schematic diagram of an application scenario of a method for processing data according to the present application;
FIG. 4 is a flow diagram of yet another embodiment of a method for processing data according to the present application;
FIG. 5 is a schematic block diagram illustrating one embodiment of an apparatus for processing data according to the present application;
FIG. 6 is a schematic block diagram of a computer system suitable for use in implementing a server according to embodiments of the present application.
Detailed Description
The present application will be described in further detail with reference to the following drawings and examples. It is to be understood that the specific embodiments described herein are merely illustrative of the relevant invention and not restrictive of the invention. It should be noted that, for convenience of description, only the portions related to the related invention are shown in the drawings.
It should be noted that the embodiments and features of the embodiments in the present application may be combined with each other without conflict. The present application will be described in detail below with reference to the embodiments with reference to the attached drawings.
Fig. 1 shows an exemplary system architecture 100 to which embodiments of the present method for processing data or apparatus for processing data may be applied.
As shown in FIG. 1, the system architecture 100 may include artificial intelligence devices 101, 102, 103, networks 104, 106, and servers 105, 107. Network 104 is the medium used to provide communication links between artificial intelligence devices 101, 102, 103 and server 105. Network 106 serves as a medium for providing communication links between server 105 and server 107. The networks 104, 106 may include various connection types, such as wired, wireless communication links, or fiber optic cables, among others.
A user using an artificial intelligence device may interact with the artificial intelligence device 101, 102, 103, for example, by talking to the artificial intelligence device 101, 102, 103. The artificial intelligence devices 101, 102, 103 may interact with the server 105 over the network 104 to receive or send messages or the like. Various communication client applications, such as a language recognition application, a speech synthesis application, an audio playing type application, etc., may be installed on the artificial intelligence devices 101, 102, 103. The artificial intelligence devices 101, 102, 103 may be employed in a variety of scenarios, such as in a hotel room, at a restaurant's table, and so forth.
The artificial intelligence devices 101, 102, 103 may be hardware or software. When the artificial intelligence devices 101, 102, 103 are hardware, they can be various electronic devices that support artificial intelligence, including but not limited to artificial intelligence speakers, artificial intelligence televisions, artificial intelligence robots, and the like. When the artificial intelligence devices 101, 102, 103 are software, they can be installed in the electronic devices listed above. It may be implemented as multiple pieces of software or software modules (e.g., to provide distributed services) or as a single piece of software or software module. And is not particularly limited herein.
The server 105 may be a server providing various services, such as a background server that processes speech or text received by the artificial intelligence devices 101, 102, 103. The backend server may perform processing such as encapsulation on the acquired data such as voice or text, and feed back a processing result (e.g., a data processing request) to the server 107. When the artificial intelligence devices 101, 102, 103 are applied in a room of a hotel, the server 105 may be a server of the hotel.
The server 107 may be a server that provides various services, such as a background server that processes data processing requests sent by the server 105. It may process data such as a received data processing request and feed back the processing result to the server 105.
The servers 105 and 107 may be hardware or software. When the servers 105 and 107 are hardware, they may be implemented as a distributed server cluster composed of a plurality of servers, or may be implemented as a single server. When the servers 105, 107 are software, they may be implemented as multiple pieces of software or software modules (e.g., to provide distributed services) or as a single piece of software or software module. And is not particularly limited herein.
It should be noted that the method for processing data provided in the embodiment of the present application is generally performed by the server 107, and accordingly, the apparatus for processing data is generally disposed in the server 107.
It should be understood that the number of artificial intelligence devices, networks, and servers in FIG. 1 is merely illustrative. There may be any number of artificial intelligence devices, networks, and servers, as desired for implementation.
With continued reference to FIG. 2, a flow 200 of one embodiment of a method for processing data in accordance with the present application is shown. The method for processing data of the embodiment comprises the following steps:
step 201, a data processing request is received.
In the present embodiment, the execution subject of the method for processing data (e.g., the server 107 shown in fig. 1) may receive the data processing request by a wired connection manner or a wireless connection manner. The data processing request can comprise a target user identifier, a target interface identifier and data to be processed. The target user identifier may be used to uniquely identify a user, where the user may be an enterprise user. An enterprise user may send a data processing request to an executing agent through a server (e.g., server 105 shown in fig. 1) that the enterprise user uses. The target interface identifier can be used for uniquely identifying one interface, and different interfaces correspond to different services in the artificial intelligence dialog operating system.
It should be noted that the wireless connection means may include, but is not limited to, a 3G/4G connection, a WiFi connection, a bluetooth connection, a WiMAX connection, a Zigbee connection, a uwb (ultra wideband) connection, and other wireless connection means now known or developed in the future.
Step 202, determining a target data processing system according to the target user identifier and the target interface identifier.
After receiving the data processing request, the execution main body can analyze the data processing request to obtain a target user identifier and a target interface identifier. The executing agent may then determine the target data processing system based on the target user identification and the target interface identification. It can be understood that the executing agent may obtain a mapping relationship between the preset data processing system and the user identifier and the interface identifier, then determine the corresponding data processing system by querying the target user identifier and the target interface identifier, and use the determined data processing system as the target data processing system. The same user identifier may correspond to a plurality of data processing systems, and the same user identifier and the same interface identifier correspond to one data processing system.
The target processing system may include a set of data processing nodes that process data. The data processing nodes in the data processing node set are connected in sequence, and the output of one data processing node can be used as the input of another data processing node. The data processing node set may include a data processing node as an entry and a data processing node as an exit. It will be appreciated that when only one data processing node is included in the set of data processing nodes, this data processing node acts as both the ingress data processing node and the egress data processing node. The data to be processed can enter the target data processing system from the data processing node as the entrance, then sequentially pass through the data processing nodes according to the connection sequence of the data processing nodes, and then are output from the data processing node as the exit. In this embodiment, the data processing node may be software, may be one function in the software, or may be a collection of multiple functions in the software. The data processing node can process the data entering the data processing node and output the obtained data after the processing is finished, so that the data can enter the next data processing node connected with the data processing node.
In this embodiment, the data processing node set may include a plurality of identical data processing nodes. In this way, the same processing can be performed on the data to be processed a plurality of times. It is understood that the above-mentioned plurality of identical data processing nodes may be connected in sequence, or may be arranged at intervals. The present embodiment does not limit the connection order between a plurality of identical data processing nodes.
In some optional implementations of this embodiment, the execution principal may discard the data processing request in response to determining that there is no data processing system corresponding to the target user identification and the target interface identification.
When the execution body can not determine the corresponding target data processing system according to the target user identification and the target interface identification, the data processing request can be considered to be in error. This data processing request may be discarded at this point.
Step 203, inputting the data to be processed into the data processing node as the entrance, and obtaining the processing result output from the data processing node as the exit.
After determining the target data processing system, the executing agent may input the data to be processed into the data processing node as an entry. And after the data to be processed is processed by each data processing node in the target data processing system, the data to be processed is output from the data processing node serving as an outlet. The output data is the processing result obtained after the target data processing system processes the data to be processed.
Step 204, the processing result is sent.
The execution main body can send the processing result after obtaining the processing result. For example, the execution agent may send the processing result to the device that sent the data processing request to the execution agent. Alternatively, the execution main body may send the processing result to a user terminal used by the technician, so that the technician can confirm the processing result through the user terminal.
With continued reference to fig. 3, fig. 3 is a schematic diagram of an application scenario of the method for processing data according to the present embodiment. In the application scenario of fig. 3, the artificial intelligence device 301 is disposed in a room of a hotel. A user living in a room sends a voice "help me turn off the light" to the above-described artificial intelligence device 301. The artificial intelligence device 301 can send the voice to the hotel server 302. The hotel server 302 may use the voice as the data to be processed, use the user identifier of the hotel as the enterprise user as the target user identifier, and use the interface identifier of the artificial intelligence dialog operating system to be called as the target interface identifier. The data to be processed, the target user identifier and the target interface identifier are encapsulated in the data processing request and then sent to the server 303. The server 303 first determines a target data processing system after receiving the data processing request. Then inputting the data to be processed into the target data processing system, and obtaining a processing result of turning off all lights except the night light. The processing result is then sent to the hotel server 302. The hotel server 302 may control the turning off of all lights in the room where the user is located except for the night lights.
The method for processing data provided by the foregoing embodiment of the present application may first receive a data processing request, where the data processing request may include a target user identifier, a target interface identifier, and data to be processed. The target data processing system may then be determined based on the target user identification and the target interface identification. And inputting the data to be processed into the data processing node as an entrance, and obtaining a processing result output from the data processing node as an exit. And finally, sending the processing result. In the method of the embodiment, the data processing nodes connected in series in sequence process the data to be processed, so that a user can realize different data processing processes by changing the sequence among the data processing nodes or changing the data processing nodes, and the convenience of the user for the configuration of the processing processes is improved.
In some optional implementations of this embodiment, the step 202 may be specifically implemented by the following steps not shown in fig. 2: and determining a target data processing system corresponding to the target user identifier and the target interface identifier from a preset data processing system set.
Wherein the execution subject may determine the set of data processing systems by: acquiring a data processing system from a preset position at intervals of preset time, wherein the data processing system corresponds to a user identifier and an interface identifier; and adding the acquired data processing system into the data processing system set.
The execution subject may retrieve the data processing system from a preset location (e.g., a database) at preset time intervals (e.g., 5 minutes). The acquired data processing system corresponds to the user identification and the interface identification. The data processing system can be preset by technicians of enterprise users, and the technicians can store the data in the database after the setting is completed. In a specific practice, a technician may set up the data processing nodes included in the data processing system through a preset interface. The preset interface can also display what processing is performed on the data by each data processing node. Technical staff can realize different processing of data by setting different data processing nodes, so that repeated explanation of functions of the artificial intelligent conversation operating system by the technical staff of the artificial intelligent conversation operating system is not needed or reduced, and the landing efficiency of the artificial intelligent conversation operating system is improved.
When storing the data processing system, the technician of the enterprise user may store the user identification and the interface identification of the enterprise user together. The execution principal may add the acquired data processing system to the collection of data processing systems. The collection of data processing systems may be stored in the memory of the executing entity or in some other storage location convenient for retrieval by the executing entity.
It is understood that the execution subject of the acquiring data processing system and the execution subject of the determining target data processing system may be the same execution subject or different execution subjects. An executing agent acquiring the data processing system may store the collection of data processing systems in a particular location for use by an executing agent determining the target data processing system.
In some optional implementations of this embodiment, each data processing node in the set of data processing nodes may include a data entry and a data exit, and the target data processing system further includes configuration information for the data processing node. The configuration information may include a response time and a first response message. The above method may further comprise the following steps not shown in fig. 2: for a data processing node in the set of data processing nodes, in response to determining that no data is output from the data processing node's data outlet after a response time has elapsed since data entered from the data processing node's data inlet, a first response message is sent.
In this implementation, for each data processing node, the execution main body may time up from the entry of the sub data from the data entry of the data processing node. When it is determined that the response time has not elapsed and is not output from the data outlet of the data processing node, a first response message may be transmitted. The first response message may be used to prompt an error in data processing. It is understood that the first response information of each data processing node may be the same or different. The first response message may be customized by a technician of the enterprise user, or may be preset in the execution subject.
In other implementations, the first response information may be stored in the execution body. The first response information may also be sent when the executing agent is unable to determine the target data processing system. The first response message may be used as a word-of-the-book operation of the execution subject and is intended to remind the user of an error in the data processing process.
In some optional implementations of this embodiment, before the executing entity receives the data processing request, the method may further include the following steps not shown in fig. 2:
first, the registration information is received and forwarded to the audit terminal.
In this implementation, the executing agent may receive registration information, which may be sent by a server of the enterprise user (e.g., server 105 shown in fig. 1). The registration information may include license information, identity information of a legal representative, and the like. After receiving the registration information, the execution subject may send the registration information to the audit terminal. Here, the audit terminal may be a terminal used by a technician who audits the registration information. The technical personnel can audit the registration information, and can send an audit passing message to the executive body after the registration information is confirmed to meet the preset requirement. The audit pass message is used to notify the executing entity, and may generate a user identifier for the registered device.
And secondly, generating a user identifier in response to receiving an audit passing message aiming at the registration information sent by the audit terminal.
The execution subject may generate a user identifier after receiving an audit pass message for the registration information sent by the audit terminal. The user identifier may be used to uniquely identify the enterprise user, and may be composed of at least one of letters, numbers, and symbols. The user identifier may be generated according to an algorithm, or may be information (e.g., an identification number of a legal representative, a unified social credit code, etc.) in the registration information that can uniquely identify the enterprise user.
And finally, sending the user identification.
After the execution subject generates the user identifier, the user identifier may be sent to a server of the enterprise user. In this way, when the server of the enterprise user sends the data processing request to the execution main body, the user identifier can be packaged in the data processing request as the target user identifier.
In some optional implementation manners of this embodiment, after receiving the audit passing message, the execution subject may further generate verification information corresponding to the user identifier. And then sending the verification information to the registration equipment.
In some optional implementation manners of this embodiment, the data processing request further includes target verification information. After receiving the data processing request, the execution main body may first determine that the verification information corresponding to the target user identifier is the reference verification information. And then comparing whether the target verification information is matched with the reference verification information, and if so, determining the target data processing system according to the target user identifier and the target interface identifier. The matching here may mean that the target verification information is the same as the reference verification information, or that the target verification information and the reference verification information satisfy a certain algorithm, and the like.
In some optional implementation manners of this embodiment, the data processing request may further include a debug tag, where the debug tag is used to indicate that the target data processing system is debugged by using the data to be processed. When the execution main body determines that the data processing request contains the debug tag, the flow consumed by the target data processing system during the processing of the data to be processed can be sent out as a processing result. In this way, a technician at the enterprise user may adjust the target data processing system through the results of the above-described processing.
In some optional implementation manners of this embodiment, when the data processing request may further include a node identifier, the node identifier may be used to uniquely determine one data processing node. When determining that the data processing request includes the debug tag and also includes the node identifier, the execution main body may determine that the target data processing system only includes one data processing node, and may quickly locate the data processing node indicated by the node identifier according to the node identifier. Then, the flow consumed by the data processing node during the processing of the data to be processed is sent out as a processing result.
With continued reference to FIG. 4, a flow 400 of another embodiment of a method for processing data according to the present application is shown. As shown in fig. 4, the target data processing system of the present embodiment is associated with information return mode configuration information. The information return mode configuration information includes synchronous return mode information or asynchronous return mode information. And the synchronous return mode information is used for indicating the execution main body to synchronously return the processing result. The asynchronous return mode information is used for indicating the execution subject to asynchronously return the processing result.
The method for processing data of the embodiment may include the following steps:
step 401, a data processing request is received.
Step 402, determining a target data processing system according to the target user identifier and the target interface identifier.
And step 403, inputting the data to be processed into the data processing node as the entrance, and obtaining the processing result output from the data processing node as the exit.
The principle of steps 401 to 403 is similar to that of steps 201 to 203, and the description is omitted here.
Step 404, in response to determining that the information return mode configuration information associated with the target data processing system is asynchronous return mode information, returning preset second response information and storing the processing result in a preset queue, and sequentially sending the processing result in the queue.
When the execution body determines that the information return mode configuration information associated with the target data processing system is asynchronous return mode information, it is determined that the processing result can be asynchronously returned. The executing agent may first transmit preset second response information after determining the target data processing system. The second response message may be used to prompt the enterprise user that a data processing request has been received or that the target data processing system has been determined. After the processing result of the data to be processed is obtained, the processing result may be stored in a preset queue, and then the processing results in the queue are sequentially sent. In this way, asynchronous return of processing results is achieved.
In some optional implementation manners of this embodiment, when the execution subject determines that the information return mode configuration information associated with the target data processing system is the synchronous return mode information, the processing result may be sent in real time.
With further reference to fig. 5, as an implementation of the methods shown in the above-mentioned figures, the present application provides an embodiment of an apparatus for processing data, which corresponds to the method embodiment shown in fig. 2, and which is particularly applicable to various electronic devices.
As shown in fig. 5, the apparatus 500 for processing data of the present embodiment includes: a request receiving unit 501, a system determining unit 502, a result determining unit 503, and a result transmitting unit 504.
A request receiving unit 501 configured to receive a data processing request. The data processing request comprises a target user identifier, a target interface identifier and data to be processed.
A system determination unit 502 configured to determine a target data processing system based on the target user identification and the target interface identification. The target data processing system comprises a data processing node set for processing data, wherein the data processing nodes in the data processing node set are sequentially connected, and the data processing node set comprises a data processing node as an inlet and a data processing node as an outlet.
The result determination unit 503 is configured to input data to be processed into the data processing node as an entry, and obtain a processing result output from the data processing node as an exit.
A result transmitting unit 504 configured to transmit the processing result.
In some optional implementations of this embodiment, the system determination unit 502 may be further configured to: and determining a target data processing system corresponding to the target user identifier and the target interface identifier from a preset data processing system set. Wherein the set of data processing systems is obtained by: acquiring a data processing system from a preset position at intervals of preset time, wherein the data processing system corresponds to a user identifier and an interface identifier; and adding the acquired data processing system into the data processing system set.
In some optional implementations of this embodiment, the data processing node includes a data entry and a data exit, and the target data processing system includes configuration information of the data processing node, the configuration information including the response time and the first response message. The apparatus 500 may further include a response message sending unit, not shown in fig. 5, configured to: for a data processing node in the set of data processing nodes, in response to determining that no data is output from the data processing node's data outlet after a response time has elapsed since data entered from the data processing node's data inlet, a first response message is sent.
In some optional implementations of this embodiment, the apparatus 500 may further include a registration information sending unit, a user identifier generating unit, and a user identifier sending unit, which are not shown in fig. 5.
And the registration information sending unit is configured to receive the registration information and forward the registration information to the auditing terminal before the request receiving unit receives the data processing request.
And the user identifier generating unit is configured to generate the user identifier in response to receiving an audit passing message aiming at the registration information, which is sent by the audit terminal.
A subscriber identity transmitting unit configured to transmit a subscriber identity.
In some optional implementations of this embodiment, the apparatus 500 may further include a verification information generating unit and a verification information sending unit, which are not shown in fig. 5.
And the verification information generating unit is configured to generate verification information corresponding to the user identification in response to receiving an audit passing message aiming at the registration information and sent by the audit terminal.
A check information transmitting unit configured to transmit the check information.
In some optional implementations of this embodiment, the data processing request further includes target verification information. The system determination unit 502 may be further configured to: determining verification information corresponding to the target user identification as reference verification information; and responding to the matching of the target verification information and the reference verification information, and determining the target data processing system according to the target user identification and the target interface identification.
In some optional implementations of this embodiment, the target data processing system has associated therewith information return mode configuration information that includes synchronous return mode information or asynchronous return mode information. The result sending unit 504 may be further configured to: and in response to the fact that the information return mode configuration information related to the target data processing system is determined to be asynchronous return mode information, sending preset second response information, storing the processing results in a preset queue, and sequentially sending the processing results in the queue.
The apparatus for processing data provided by the foregoing embodiments of the present application may first receive a data processing request, where the data processing request may include a target user identifier, a target interface identifier, and data to be processed. The target data processing system may then be determined based on the target user identification and the target interface identification. And inputting the data to be processed into the data processing node as an entrance, and obtaining a processing result output from the data processing node as an exit. And finally, sending the processing result. The device of this embodiment can utilize each data processing node to handle the data to be handled, and the order series connection can realize handling the many times of data to be handled between each data processing node in proper order for the user can know each data processing node's function more easily, has reduced technical staff's explanation time, improves artificial intelligence dialog operating system's the speed of falling to the ground.
It should be understood that the units 501 to 504, which are described in the apparatus 500 for processing data, correspond to the respective steps in the method described with reference to fig. 2, respectively. Thus, the operations and features described above for the method for processing data are equally applicable to the apparatus 500 and the units included therein and will not be described again here.
Referring now to FIG. 6, shown is a block diagram of a computer system 600 suitable for use in implementing a server according to embodiments of the present application. The server shown in fig. 6 is only an example, and should not bring any limitation to the functions and the scope of use of the embodiments of the present application.
As shown in fig. 6, the computer system 600 includes a Central Processing Unit (CPU)601 that can perform various appropriate actions and processes according to a program stored in a Read Only Memory (ROM)602 or a program loaded from a storage section 608 into a Random Access Memory (RAM) 603. In the RAM 603, various programs and data necessary for the operation of the system 600 are also stored. The CPU 601, ROM 602, and RAM 603 are connected to each other via a bus 604. An input/output (I/O) interface 605 is also connected to bus 604.
The following components are connected to the I/O interface 605: an input portion 606 including a keyboard, a mouse, and the like; an output portion 607 including a display such as a Cathode Ray Tube (CRT), a Liquid Crystal Display (LCD), and the like, and a speaker; a storage section 608 including a hard disk and the like; and a communication section 609 including a network interface card such as a LAN card, a modem, or the like. The communication section 609 performs communication processing via a network such as the internet. The driver 610 is also connected to the I/O interface 605 as needed. A removable medium 611 such as a magnetic disk, an optical disk, a magneto-optical disk, a semiconductor memory, or the like is mounted on the drive 610 as necessary, so that a computer program read out therefrom is mounted in the storage section 608 as necessary.
In particular, according to an embodiment of the present disclosure, the processes described above with reference to the flowcharts may be implemented as computer software programs. For example, embodiments of the present disclosure include a computer program product comprising a computer program embodied on a machine-readable medium, the computer program comprising program code for performing the method illustrated in the flow chart. In such an embodiment, the computer program may be downloaded and installed from a network through the communication section 609, and/or installed from the removable medium 611. The computer program performs the above-described functions defined in the method of the present application when executed by a Central Processing Unit (CPU) 601.
It should be noted that the computer readable medium described herein can be a computer readable signal medium or a computer readable storage medium or any combination of the two. A computer readable storage medium may be, for example, but not limited to, an electronic, magnetic, optical, electromagnetic, infrared, or semiconductor system, apparatus, or device, or any combination of the foregoing. More specific examples of the computer readable storage medium may include, but are not limited to: an electrical connection having one or more wires, a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), an optical fiber, a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing.
In the present application, a computer readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device. In this application, however, a computer readable signal medium may include a propagated data signal with computer readable program code embodied therein, for example, in baseband or as part of a carrier wave. Such a propagated data signal may take many forms, including, but not limited to, electro-magnetic, optical, or any suitable combination thereof. A computer readable signal medium may also be any computer readable medium that is not a computer readable storage medium and that can communicate, propagate, or transport a program for use by or in connection with an instruction execution system, apparatus, or device. Program code embodied on a computer readable medium may be transmitted using any appropriate medium, including but not limited to: wireless, wire, fiber optic cable, RF, etc., or any suitable combination of the foregoing.
Computer program code for carrying out operations for aspects of the present application may be written in any combination of one or more programming languages, including an object oriented programming language such as Java, Smalltalk, C + + or the like and conventional procedural programming languages, such as the "C" programming language or similar programming languages. The program code may execute entirely on the user's computer, partly on the user's computer, as a stand-alone software package, partly on the user's computer and partly on a remote computer or entirely on the remote computer or server. In the case of a remote computer, the remote computer may be connected to the user's computer through any type of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or the connection may be made to an external computer (for example, through the Internet using an Internet service provider).
The flowchart and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present application. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams and/or flowchart illustration, and combinations of blocks in the block diagrams and/or flowchart illustration, can be implemented by special purpose hardware-based systems which perform the specified functions or acts, or combinations of special purpose hardware and computer instructions.
The units described in the embodiments of the present application may be implemented by software or hardware. The described units may also be provided in a processor, and may be described as: a processor includes a request receiving unit, a system determining unit, a result determining unit, and a result transmitting unit. Where the names of these units do not in some cases constitute a limitation on the unit itself, for example, the request receiving unit may also be described as a "unit that receives a data processing request".
As another aspect, the present application also provides a computer-readable medium, which may be contained in the apparatus described in the above embodiments; or may be present separately and not assembled into the device. The computer readable medium carries one or more programs which, when executed by the apparatus, cause the apparatus to: receiving a data processing request, wherein the data processing request comprises a target user identifier, a target interface identifier and to-be-processed data; determining a target data processing system according to the target user identification and the target interface identification, wherein the target data processing system comprises a data processing node set for processing data, the data processing nodes in the data processing node set are sequentially connected, and the data processing node set comprises a data processing node as an inlet and a data processing node as an outlet; inputting data to be processed into a data processing node serving as an inlet, and obtaining a processing result output from the data processing node serving as an outlet; and sending the processing result.
The above description is only a preferred embodiment of the application and is illustrative of the principles of the technology employed. It will be appreciated by those skilled in the art that the scope of the invention herein disclosed is not limited to the particular combination of features described above, but also encompasses other arrangements formed by any combination of the above features or their equivalents without departing from the spirit of the invention. For example, the above features may be replaced with (but not limited to) features having similar functions disclosed in the present application.
Claims (16)
1. A method for processing data, comprising:
receiving a data processing request, wherein the data processing request comprises a target user identifier, a target interface identifier and to-be-processed data;
determining a target data processing system according to the target user identifier and the target interface identifier, wherein the target data processing system comprises a data processing node set for processing data, the data processing nodes in the data processing node set are sequentially connected, and the data processing node set comprises a data processing node as an inlet and a data processing node as an outlet;
inputting the data to be processed into a data processing node as an inlet to obtain a processing result output from the data processing node as an outlet;
and sending the processing result.
2. The method of claim 1, wherein said determining a target data processing system based on said target user identification, said target interface identification, comprises:
determining a target data processing system corresponding to the target user identifier and the target interface identifier from a preset data processing system set;
wherein the set of data processing systems is obtained by:
acquiring a data processing system from a preset position at intervals of preset time, wherein the data processing system corresponds to a user identifier and an interface identifier;
and adding the acquired data processing system into the data processing system set.
3. The method of claim 1, wherein the data processing node comprises a data ingress and a data egress, the target data processing system comprises configuration information for the data processing node, the configuration information comprising a response time and a first response message; and
the method further comprises the following steps:
and for the data processing nodes in the data processing node set, responding to the determination that the data is not output from the data outlet of the data processing node after the response time elapses since the data enters from the data inlet of the data processing node, and sending the first response message.
4. The method of claim 1, wherein prior to said receiving a data processing request, the method further comprises:
receiving registration information and forwarding the registration information to an auditing terminal;
generating a user identifier in response to receiving an audit passing message aiming at the registration information sent by the audit terminal;
and sending the user identification.
5. The method of claim 4, wherein the method further comprises:
generating verification information corresponding to the user identification in response to receiving an audit passing message aiming at the registration information sent by the audit terminal;
and sending the verification information.
6. The method of claim 5, wherein the data processing request further includes target verification information; and
the determining a target data processing system according to the target user identifier and the target interface identifier includes:
determining verification information corresponding to the target user identification as reference verification information;
and responding to the matching of the target verification information and the reference verification information, and determining a target data processing system according to the target user identification and the target interface identification.
7. The method of claim 1, wherein the target data processing system has associated therewith information return mode configuration information comprising synchronous return mode information or asynchronous return mode information; and
the sending the processing result includes:
and in response to determining that the information return mode configuration information associated with the target data processing system is asynchronous return mode information, sending preset second response information, storing the processing result in a preset queue, and sequentially sending the processing result in the queue.
8. An apparatus for processing data, comprising:
a request receiving unit configured to receive a data processing request, the data processing request including a target user identifier, a target interface identifier, and data to be processed;
a system determination unit configured to determine a target data processing system according to the target user identifier and the target interface identifier, where the target data processing system includes a data processing node set that processes data, and data processing nodes in the data processing node set are sequentially connected, and the data processing node set includes a data processing node as an entry and a data processing node as an exit;
a result determination unit configured to input the data to be processed into a data processing node as an entry, resulting in a processing result output from the data processing node as an exit;
a result transmitting unit configured to transmit the processing result.
9. The apparatus of claim 8, wherein the system determination unit is further configured to:
determining a target data processing system corresponding to the target user identifier and the target interface identifier from a preset data processing system set;
wherein the set of data processing systems is obtained by:
acquiring a data processing system from a preset position at intervals of preset time, wherein the data processing system corresponds to a user identifier and an interface identifier;
and adding the acquired data processing system into the data processing system set.
10. The apparatus of claim 8, wherein the data processing node comprises a data ingress and a data egress, the target data processing system comprises configuration information for the data processing node, the configuration information comprising a response time and a first response message; and
the apparatus further includes a response message transmitting unit configured to:
and for the data processing nodes in the data processing node set, responding to the determination that the data is not output from the data outlet of the data processing node after the response time elapses since the data enters from the data inlet of the data processing node, and sending the first response message.
11. The apparatus of claim 8, wherein the apparatus further comprises:
a registration information sending unit configured to receive registration information and forward the registration information to an audit terminal before the request receiving unit receives a data processing request;
a user identifier generating unit configured to generate a user identifier in response to receiving an audit pass message for the registration information sent by the audit terminal;
a subscriber identity transmitting unit configured to transmit the subscriber identity.
12. The apparatus of claim 11, wherein the apparatus further comprises:
a verification information generating unit configured to generate verification information corresponding to the user identifier in response to receiving an audit passing message for the registration information sent by the audit terminal;
a verification information transmitting unit configured to transmit the verification information.
13. The apparatus of claim 12, wherein the data processing request further comprises target verification information; and
the system determination unit is further configured to:
determining verification information corresponding to the target user identification as reference verification information;
and responding to the matching of the target verification information and the reference verification information, and determining a target data processing system according to the target user identification and the target interface identification.
14. The apparatus of claim 8, wherein the target data processing system has associated therewith information return mode configuration information comprising synchronous return mode information or asynchronous return mode information; and
the result sending unit is further configured to:
and in response to determining that the information return mode configuration information associated with the target data processing system is asynchronous return mode information, sending preset second response information, storing the processing result in a preset queue, and sequentially sending the processing result in the queue.
15. A server, comprising:
one or more processors;
a storage device having one or more programs stored thereon,
when executed by the one or more processors, cause the one or more processors to implement the method of any one of claims 1-7.
16. A computer-readable medium, on which a computer program is stored which, when being executed by a processor, carries out the method according to any one of claims 1-7.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201811146469.0A CN109144735B (en) | 2018-09-29 | 2018-09-29 | Method and apparatus for processing data |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201811146469.0A CN109144735B (en) | 2018-09-29 | 2018-09-29 | Method and apparatus for processing data |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN109144735A CN109144735A (en) | 2019-01-04 |
| CN109144735B true CN109144735B (en) | 2019-12-27 |
Family
ID=64813404
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201811146469.0A Active CN109144735B (en) | 2018-09-29 | 2018-09-29 | Method and apparatus for processing data |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN109144735B (en) |
Families Citing this family (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111435938B (en) * | 2019-01-14 | 2022-11-29 | 阿里巴巴集团控股有限公司 | Data request processing method, device and equipment |
| CN111866069B (en) * | 2020-06-04 | 2024-07-26 | 西安万像电子科技有限公司 | Data processing method and device |
| CN112835655B (en) * | 2021-02-26 | 2024-05-10 | 深圳市晨北科技有限公司 | Transparent data transmission method, system, transmission terminal and storage medium |
| CN113076082B (en) * | 2021-06-03 | 2021-09-03 | 杭州星犀科技有限公司 | Method, system, electronic device and storage medium for audio source processing |
| CN114490916B (en) * | 2022-04-14 | 2022-07-26 | 广州城市信息研究所有限公司 | GIS data processing model customization method |
| CN115002209A (en) * | 2022-06-23 | 2022-09-02 | 京东方科技集团股份有限公司 | Data processing method, device and system |
| CN115357309B (en) * | 2022-10-24 | 2023-07-14 | 深信服科技股份有限公司 | Data processing method, device, system and computer readable storage medium |
Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101287018A (en) * | 2008-05-09 | 2008-10-15 | 金蝶软件（中国）有限公司 | Integrated data-handling method and device based on multi-system user |
| CN102253837A (en) * | 2011-07-25 | 2011-11-23 | 深圳市极限网络科技有限公司 | Object tree-based software framework designing technology |
| CN103501326A (en) * | 2013-09-26 | 2014-01-08 | 中国银行股份有限公司 | Data processing method and system based on middleware |
| CN104092652A (en) * | 2013-12-25 | 2014-10-08 | 腾讯数码（天津）有限公司 | Data processing system and method |
| CN104580534A (en) * | 2015-02-06 | 2015-04-29 | 联想(北京)有限公司 | Information processing method, information processing device and electronic equipment |
| CN105760395A (en) * | 2014-12-18 | 2016-07-13 | 华为技术有限公司 | Data processing method, device and system |
| CN106610871A (en) * | 2016-12-30 | 2017-05-03 | 郑州云海信息技术有限公司 | Cloud operating system architecture |
Family Cites Families (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US7574711B2 (en) * | 2001-12-14 | 2009-08-11 | Nvidia International, Inc. | System for replaying and synchronizing patterns on a client and external data source devices |
| CN100384155C (en) * | 2006-01-14 | 2008-04-23 | 华为技术有限公司 | Client layer chain-link automatic finding method and apparatus |
| CN101242553B (en) * | 2007-02-05 | 2011-01-05 | 华为技术有限公司 | User data transmission method and device |
| US9053576B2 (en) * | 2010-12-21 | 2015-06-09 | International Business Machines Corporation | Identifying reroutable data columns in an ETL process |
| CN103095819A (en) * | 2013-01-04 | 2013-05-08 | 微梦创科网络科技（中国）有限公司 | Data information pushing method and data information pushing system |
| CN104754003B (en) * | 2013-12-30 | 2019-01-08 | 腾讯科技（深圳）有限公司 | Transmit the method and system of data |
| EP3089544B1 (en) * | 2013-12-31 | 2020-04-08 | Huawei Technologies Co., Ltd. | Service processing method and device |
-
2018
- 2018-09-29 CN CN201811146469.0A patent/CN109144735B/en active Active
Patent Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101287018A (en) * | 2008-05-09 | 2008-10-15 | 金蝶软件（中国）有限公司 | Integrated data-handling method and device based on multi-system user |
| CN102253837A (en) * | 2011-07-25 | 2011-11-23 | 深圳市极限网络科技有限公司 | Object tree-based software framework designing technology |
| CN103501326A (en) * | 2013-09-26 | 2014-01-08 | 中国银行股份有限公司 | Data processing method and system based on middleware |
| CN104092652A (en) * | 2013-12-25 | 2014-10-08 | 腾讯数码（天津）有限公司 | Data processing system and method |
| CN105760395A (en) * | 2014-12-18 | 2016-07-13 | 华为技术有限公司 | Data processing method, device and system |
| CN104580534A (en) * | 2015-02-06 | 2015-04-29 | 联想(北京)有限公司 | Information processing method, information processing device and electronic equipment |
| CN106610871A (en) * | 2016-12-30 | 2017-05-03 | 郑州云海信息技术有限公司 | Cloud operating system architecture |
Also Published As
| Publication number | Publication date |
|---|---|
| CN109144735A (en) | 2019-01-04 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN109144735B (en) | Method and apparatus for processing data | |
| US10565442B2 (en) | Picture recognition method and apparatus, computer device and computer- readable medium | |
| US11322138B2 (en) | Voice awakening method and device | |
| CN109190114B (en) | Method and device for generating reply information | |
| CN109117378B (en) | Method and apparatus for displaying information | |
| CN109460652B (en) | Method, apparatus and computer readable medium for annotating image samples | |
| CN110555451A (en) | information identification method and device | |
| CN110288995A (en) | Exchange method, device, storage medium and electronic equipment based on speech recognition | |
| CN112349428A (en) | Family health code query method and equipment | |
| CN111629063A (en) | Block chain based distributed file downloading method and electronic equipment | |
| CN110737655B (en) | Method and device for reporting data | |
| CN111581356A (en) | User behavior path analysis method and device | |
| CN109903759B (en) | Interaction management device and non-transitory computer-readable recording medium | |
| CN111160002B (en) | Method and device for analyzing abnormal information in output spoken language understanding | |
| CN114817347A (en) | Business approval method and device, electronic equipment and storage medium | |
| CN111125503A (en) | Method and apparatus for generating information | |
| CN109194567B (en) | Method and apparatus for retransmitting information | |
| CN112084114A (en) | Method and apparatus for testing an interface | |
| CN109388684B (en) | Method and apparatus for generating information | |
| CN113763008A (en) | Application promotion tracking method, device, server, equipment and medium | |
| CN110110032B (en) | Method and device for updating index file | |
| CN110730109A (en) | Method and apparatus for generating information | |
| CN113194109A (en) | Method and device for pushing information | |
| US20220311766A1 (en) | Sensor-based authentication, notification, and assistance systems | |
| CN115632994A (en) | Message processing method and device, electronic equipment and computer readable 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 | ||
| TR01 | Transfer of patent right |
Effective date of registration: 20210510 Address after: 100085 Baidu Building, 10 Shangdi Tenth Street, Haidian District, Beijing Patentee after: BEIJING BAIDU NETCOM SCIENCE AND TECHNOLOGY Co.,Ltd. Patentee after: Shanghai Xiaodu Technology Co.,Ltd. Address before: 100085 Baidu Building, 10 Shangdi Tenth Street, Haidian District, Beijing Patentee before: BEIJING BAIDU NETCOM SCIENCE AND TECHNOLOGY Co.,Ltd. |
|
| TR01 | Transfer of patent right |