WO2018113789A1 - Data processing method and apparatus - Google Patents

Abstract

A data processing method, applied to a first big data transaction centre unit, comprising: a big data demand side unit sending a first data request message to a first big data transaction centre unit (S201); the first big data transaction centre unit searching locally, in response to the first data request message, to find whether there is data of a first attribute (S202); if not, the first big data transaction centre unit sending a second data request message to a second big data transaction centre unit interconnected with the first big data transaction centre unit (S203); the second big data transaction centre unit sending, in response to the second data request message, the data of the first attribute to the first big data transaction centre unit (S204); and the first big data transaction centre unit sending the data of the first attribute to the big data demand side unit (S205).

Description

Data processing method and device Technical field

The present application relates to the field of data processing, such as a data processing method and apparatus.

Background technique

At present, big data has become a hotspot of technology in the industry. Especially with the deployment of cloud computing services, big data is expected to be its most important business application.

The main characteristics of big data are the large volume, the variety of Variety, the speed of Velocity and the high value of Value, accompanied by multi-source, heterogeneous and massive data features. The types of data involved in big data include types such as Structured, Semi-Structured, and Un-Structured. The data objects involved in big data include text, voice, video, image, web page, sensor data, etc. Accordingly, this also requires that the big data transaction system can specifically distinguish and process the data bearing format corresponding to different data objects. For example, text files, audio files, adaptation files, image files, web files, sensor data files, and corresponding real-time/quasi-live streaming media data.

Although big data is gradually being applied to various industries, with the gradual increase of data volume, the variety of data involved is increasing, the speed of generation is rapidly increasing, and the demand for data fusion and its potential value utilization in the cross-domain is huge. There is an increasing demand for data exchange, data sharing, and especially data exchange. At this stage, the data transaction centers built in the industry are still in their own independent stages, and they cannot be interconnected. If the data demanders need to obtain data that can be provided by data providers that are contracted by each data transaction center. , you need to sign commercial contracts with each data transaction center and each data provider separately, and need to configure multiple different data transaction software, even using different data transaction protocols, in order to obtain the required data from multiple data transaction centers. Business data, in this way, on the one hand, it is not convenient for the data demand side to obtain the target transaction data in a timely and effective manner (need to traverse all data transaction centers to query the best target transaction data that meets the demand), on the other hand, it wastes the data demand side. Resources (including human resources, software resources, computing resources, storage resources, etc.), and more importantly, large amounts of large-scale, high-speed changes in big data centers that are independent of each other cannot be used to pass data. The great value that can be reflected by the aggregation, the great waves Data resources.

Summary of the invention

The following is an overview of the topics detailed in this document. This Summary is not intended to limit the scope of the claims.

Embodiments of the present disclosure provide a data processing method and apparatus, thereby implementing openness, interconnectivity, and sharing of a big data transaction center.

In a first aspect, an embodiment of the present disclosure provides a data processing method, applicable to a first big data transaction center unit, including: receiving a first data request message from a big data demander unit, where the first data request message And a data requesting to deliver the first attribute, where the first big data transaction center unit is a subscription server of the big data demander unit; and in response to the first data request message, locally searching for whether the first Data of the attribute; in response to the absence of the first attribute data, transmitting a second data request message to a second large data transaction center unit interconnected with the first big data transaction center unit, wherein the second data request a message for requesting return of data of the first attribute; receiving data of the first attribute from the second big data transaction center unit, and transmitting data of the first attribute to the big data demander unit.

In a second aspect, an embodiment of the present disclosure provides a data processing apparatus, which is applied to a first big data transaction center unit, including: an interconnection data transaction module and an interconnection data module, wherein the interconnection data transaction module is configured to receive from a large a first data request message of the data requestor unit, and the data of the first attribute is sent to the big data demander unit, wherein the first data request message is used to request to deliver data of the first attribute, The first big data transaction center unit is a subscription server of the big data demander unit; the interconnection data module is configured to locally search for data of the first attribute in response to the first data request message; And if the data of the first attribute does not exist, sending a second data request message to the second big data transaction center unit interconnected with the first big data transaction center unit through the interconnected data interface, and receiving from the interconnected data interface Data of the first attribute of the second big data transaction center unit; wherein the second data The request message is for requesting to return data of the first attribute.

In a third aspect, an embodiment of the present disclosure further provides a computer readable storage medium storing computer executable instructions configured to perform the above method.

Embodiments of the present disclosure provide a data processing method, apparatus, and computer readable storage medium. After a big data transaction center unit receives a data request from a big data demander unit, the big data demand side unit may not exist locally. When the target data is needed, the target data is obtained through other interconnected big data transaction center units, and the target data is received and sent to the big data demander unit. In this way, the integration and sharing of the data resources of each big data transaction center unit is realized, and the data utilization rate is improved, so that the big data demand side unit can acquire the target data in time and efficiently without traversing all the data transaction center units. Query the target data that meets the demand. Further, the user's resource waste is reduced, the user time is saved, and the user experience is improved.

Other aspects will be apparent upon reading and understanding the drawings and detailed description.

BRIEF abstract

1-1 is a schematic structural diagram of a big data transaction center interconnection system in an embodiment of the present disclosure.

1-2 is a schematic structural diagram of a big data transaction center interconnection unit in an embodiment of the present disclosure.

1-3 are schematic diagrams showing the connection of a big data transaction center interconnection unit in the embodiment of the present disclosure.

2-1 is a schematic diagram of a first flow of a data processing method in an embodiment of the present disclosure.

2-2 is a second schematic flowchart of a data processing method in an embodiment of the present disclosure.

FIG. 3 is a schematic structural diagram of a data processing apparatus according to an embodiment of the present disclosure.

detailed description

The technical solutions in the embodiments of the present disclosure will be clearly and completely described below in conjunction with the drawings in the embodiments of the present disclosure.

1-1 is a schematic structural diagram of a big data transaction center interconnection system in an embodiment of the present disclosure. Referring to FIG. 1-1, the big data transaction center interconnection system 100 may include: a big data provider unit 101, a big data transaction center interconnection unit 102, and a big data demand side unit 103.

Here, the big data transaction center interconnection unit is composed of at least two big data transaction center units interconnected. For example, still referring to FIG. 1-1, the big data transaction center interconnection unit 102 may include a big data transaction center unit 102a, big data. The transaction center unit 102b and the big data transaction center unit 102c.

A big data provider unit configured to collect data from a data source and import the data into a big data transaction center interconnection unit; a big data transaction center interconnection unit configured to import data from a big data provider unit and to trade according to big data The request of the central unit derives the corresponding data to the big data demander unit; the big data demand side unit is configured to receive data from the interconnect unit of the big data transaction center.

In a specific implementation process, each big data transaction center unit in the big data transaction center interconnection unit may include: an interconnection data transaction module, an interconnection data module, an interconnection control module, an interconnection security module, and an interconnection management module. In practical applications, the interconnected data transaction module is configured to implement data transactions between the big data transaction center interconnection unit and the big data demand side unit, and can transmit the required target data to the big data demand side unit; the interconnected data module is configured to implement Data integration, sharing, processing, storage, distribution, etc. between the various big data transaction center units; the interconnection control module is configured to control the establishment and disconnection of interconnections between the various big data transaction center units; the interconnection security module is configured to When each big data transaction center unit is connected, perform security authentication, access control, and data copyright management authentication to ensure the security of interconnection between big data transaction center units to achieve security protection between data sharing; interconnection management The module is configured to realize the management and maintenance of the interconnection between the various big data transaction center units, and also realize the management of data connection, supervisory connection, secure connection, transaction connection and other functions on the basis of the interconnection connection.

Illustratively, FIG. 1-2 is a schematic structural diagram of a big data transaction center interconnection unit in an embodiment of the present disclosure. Referring to FIG. 1-2, the big data transaction center interconnection unit includes three big data transaction center units, and the big data transaction center unit 102a includes: an interconnection data transaction module 1021a, an interconnection data module 1022a, an interconnection control module 1023a, and an interconnection security module. 1024a, interconnection management module 1025a and interconnection information supervision module 1026a; big data transaction center unit 102b includes: interconnection data transaction module 1021b, interconnection data module 1022b, interconnection control module 1023b, interconnection security module 1024b, interconnection management module 1025b, and interconnection information supervision The module 1026b; the big data transaction center unit 102c includes: an interconnection data transaction module 1021c, an interconnection data module 1022c, an interconnection control module 1023c, an interconnection security module 1024c, an interconnection management module 1025c, and an interconnection information supervision module 1026c.

In practical applications, as shown in FIG. 1-2 and FIG. 1-3, the big data transaction center interconnection unit 102 further includes an interconnection data transaction interface 1041, an interconnection data interface 1042, an interconnection control interface 1043, an interconnection security interface 1044, and interconnection management. The interface 1045 and the interconnection information supervision interface 1046. The interconnection data transaction interface is configured to connect the respective interconnection data transaction modules to each other and to the big data demand side unit; the interconnection data interface is configured to connect the respective interconnection data modules; the interconnection control interface is configured to connect the respective interconnection control modules; and the interconnection security interface It is configured to connect to each interconnected security module; the interconnect management interface is configured to connect to each interconnected management module.

The data processing method of the embodiment of the present disclosure will be described below in conjunction with the above system.

2-1 is a schematic diagram of a first flow of a data processing method in an embodiment of the present disclosure. Referring to Figure 2-1, the method includes the steps described below.

In step S201: the big data demander unit sends a first data request message to the first big data transaction center unit.

The first data request message is used to request the data of the first attribute, and the first big data transaction center unit is a contract server of the data demand side.

Here, the big data demander unit requests the data service from the contracted big data transaction center unit to obtain the data of the first attribute, for example, a text file with a .doc format, a GIF format image, an MP3 format audio file, and the like. The embodiment of the present disclosure does not specifically limit the actual requirements of the big data demand side unit.

In step S202, the first big data transaction center unit locally searches for data of the first attribute in response to the first data request message.

Here, after receiving the first data request message, the first big data transaction center unit searches for the data of the first attribute locally, and if it is determined that the data of the first attribute exists locally, the data request unit can be Sending the data of the first attribute, if it is determined that the data of the first attribute does not exist locally, the data of the first attribute may be requested from other interconnected big data transaction center units.

In step S203: if the data of the first attribute does not exist, the first big data transaction center unit sends a second data request message to the second big data transaction center unit interconnected with the first big data transaction center unit. The second data request message is used to request to return data of the first attribute.

In other embodiments of the present disclosure, step S203 may include: the first big data transaction center unit determines, according to the pre-stored data service catalog, the second big data transaction center unit corresponding to the data of the first attribute; and the second big data transaction The central unit sends a second data request message.

Here, a data service directory of each big data transaction center unit interconnected with it is stored in each big data transaction center unit. Through the data service directory, the first big data transaction center unit can determine which big data transaction center unit stores the data of the first attribute, and then send the second data request to the big data transaction center unit, that is, the second Big data trading center unit.

Optionally, in another embodiment of the present disclosure, after the first big data transaction center unit receives the first data request message from the data requester, the data processing method further includes: the first big data transaction center unit is the second The big data transaction center unit transmits the data service directory of the first big data transaction center unit, and receives the data service directory from the second big data transaction center unit; and stores the data service directory of the second largest data transaction center unit.

In step S204: the second big data transaction center unit transmits the data of the first attribute to the first big data transaction center unit in response to the second data request message.

Here, after receiving the second data request message, the second big data transaction center unit acquires the data of the first attribute locally, and sends the data of the first attribute to the first big data transaction center unit.

In step S205, the first big data transaction center unit transmits the data of the first attribute to the big data demander unit.

Here, after receiving the data of the first attribute or locally finding the data of the first attribute, the first big data transaction center unit may send the data of the first attribute to the big data demander unit.

In other embodiments of the present disclosure, in order to realize the integration and sharing of data resources between the respective big data transaction center units, an interconnection connection may be established between the big data transaction center units. Then, before step S201, the foregoing method may further include According to the preset interconnection strategy, the first big data transaction center unit and the second big data transaction center unit establish an interconnection connection.

Here, the first big data transaction center unit can establish an interconnection connection with the second largest data transaction center unit according to the configuration of the administrator. Of course, a big data transaction center unit can establish an interconnection with at least one other big data transaction center unit.

In the specific implementation process, the first big data transaction center unit can establish an interconnection connection with other big data transaction center units in an active manner, or can establish an interconnection connection with other big data transaction center units in a passive manner. Here, the present disclosure The embodiment is not specifically limited.

2-2 is a second schematic flowchart of a data processing method in an embodiment of the present disclosure. Referring to Figure 2-2, the following explains in detail how the first big data transaction center unit uses the active mode and the passive mode to establish the interconnection.

First, the process of establishing the interconnection by the first big data transaction center unit in an active manner is described in detail.

The first big data transaction center unit can initiate an interconnection with the second largest data transaction center unit. Then, the method may further include: the first big data transaction center unit sends a second interconnection request message to the second big data transaction center unit according to the interconnection policy, where the second interconnection request message carries the first big data transaction center unit An identity identifier for indicating a second big data transaction center unit for identity authentication and access control; then, the first big data transaction center unit receives a second internet response message from the second big data transaction center unit, The second interconnection response message is used to notify that an interconnection relationship has been established with the second big data transaction center unit.

Secondly, the process of establishing the interconnection by the first big data transaction center unit in a passive manner is described in detail.

The first big data transaction center unit can listen to the first interconnection request message sent by the second largest data transaction center unit according to the preset interconnection policy, and the first interconnection request message carries the identity of the second big data transaction center unit. Identification; then, the first big data transaction center unit can perform identity authentication on the second largest data transaction center unit according to the identity information; if the authentication is passed, access control is performed on the second largest data transaction center unit; if the second largest data The transaction center unit is granted access control, and then sends a first interconnection response message to the second big data transaction center unit, and the first interconnection response message is used to notify that the second big data transaction center unit has established an interconnection relationship.

In practical applications, in order to ensure the security of data sharing, when each big data transaction center unit establishes interconnection, identity authentication can be performed through the agreed identity identification, and identity authentication can also be performed through password verification. Of course, it can also be adopted. Other manners of security authentication, the embodiments of the present disclosure are not specifically limited herein.

In the specific implementation process, in order to realize the functions of data aggregation, data transaction, interconnection supervision, or interconnection management of big data, the first big data transaction center unit can also establish a control connection and a secure connection with the second largest data transaction center unit. Manage one or more combinations of connections, supervisory connections, data connections, and transaction connections.

Optionally, after the first big data transaction center unit receives the data of the first attribute from the second big data transaction center unit, the method may further include: the first big data transaction center unit to the second big data transaction center The unit sends an exit message and disconnects the interconnection with the second largest data transaction center unit after confirming that the data transaction is complete.

Specifically, when the data request is small, in order to save system resources, after the big data transaction center unit obtains the required target data from other big data transaction center units, an exit message may be sent to other big data transaction center units. , notifying other big data transaction center units that it has received the required data and is about to disconnect from other big data transaction center units. Of course, in order to ensure the integrity of the data transaction, it is also necessary to confirm whether the current data transaction is completed before disconnecting. For example, the normal transaction before the cooperation expires cannot be interrupted, and it is confirmed whether the transaction after the cooperation expires is still initiated. , the clearing of the data cached by the partner, the notification of all the parties involved in the transaction, etc. In this way, it is possible to disconnect from other big data transaction center units after determining that the current data transaction is completed. The connection is not made until the next time a data transaction request or an interconnection request is received.

In practical applications, after determining that all the big data transaction center units in the big data transaction center interconnection system are disconnected, the related system resources can be released, such as clearing the relevant cache data and tearing down the connection link. And the like, which is determined by a person skilled in the art in a specific implementation process.

It can be seen from the above that in other embodiments of the present disclosure, since the big data transaction center interconnection system interconnects the big data transaction center units, the data of each big data transaction center unit is integrated, thereby, big data. The demand side unit can obtain the required data from multiple big data transaction center units in the Big Data Exchange Center interconnection system. In this way, through the data processing method provided by the embodiment of the present disclosure, the openness, interconnectivity, and sharing of the big data transaction center unit can be realized, and the data utilization rate is improved, so that the user can obtain the target data in a timely and effective manner. Instead of traversing all the big data transaction center units, you can query the target data that meets your needs. Further, the user's resource waste is reduced, the user time is saved, and the user experience is improved.

Based on the same inventive concept, an embodiment of the present disclosure further provides a data processing apparatus consistent with the big data transaction center unit in one or more of the above embodiments.

FIG. 3 is a schematic structural diagram of a data processing apparatus according to an embodiment of the present disclosure. Referring to FIG. 3, the data processing apparatus 30 includes an interconnection data transaction module 301 and an interconnection data module 302. The interconnected data transaction module 301 is configured to receive the first data request message from the big data demander unit, and send the data of the first attribute to the big data demander unit, wherein the first data request message is used to request the first delivery The data of the attribute, the first big data transaction center unit is the contract server of the big data demand side unit. The interconnect data module 302 is configured to, in response to the first data request message, locally find whether there is data of the first attribute; if not, to connect to the second big data interconnected with the first big data transaction center unit through the interconnected data interface The transaction center unit transmits a second data request message and receives data of the first attribute from the second big data transaction center unit through the interconnection data interface; wherein the second data request message is used to request to return data of the first attribute.

Optionally, the interconnection data module is further configured to: determine, according to the pre-stored data service directory, a second big data transaction center unit corresponding to the data of the first attribute; and send the second to the second big data transaction center unit by using the interconnected data connection interface Data request message.

Optionally, the interconnection data module is further configured to send the data service directory of the first big data transaction center to the second big data transaction center unit through the interconnection data interface, and receive the second big data transaction center unit through the interconnection data interface. Data business directory; save the data business directory of the second largest data transaction center unit.

Optionally, the data processing apparatus further includes: an interconnection control module configured to establish an interconnection connection with the second big data transaction center unit through the interconnection control interface according to the preset interconnection policy.

Optionally, the interconnection control module is further configured to listen to the first interconnection request message sent by the second big data transaction center unit according to the interconnection policy, where the first interconnection request message carries the identity of the second big data transaction center unit Logo. The data processing apparatus further includes: an interconnection security module configured to perform identity authentication on the second largest data transaction center unit according to the identity identifier; if the authentication is passed, perform access control on the second largest data transaction center unit; if the second largest The data transaction center unit is granted access control, and then sends a first interconnection response message to the second big data transaction center unit, wherein the first interconnection response message is used to notify that the second big data transaction center unit has established an interconnection relationship.

Optionally, the interconnection control module is further configured to: send, according to the interconnection policy, the second interconnection request message to the second big data transaction center unit by using the interconnection control interface, where the second interconnection request message carries the first big data An identity of the transaction center, the identifier is used to indicate that the second largest data transaction center unit performs identity authentication and access control; and the second interconnection response message from the second big data transaction center unit is received through the interconnection control interface, wherein the second interconnection The response message is used to notify that an interconnection relationship has been established with the second big data transaction center unit.

Optionally, the data processing apparatus further includes: an interconnection management module, configured to establish, by using an interconnection management interface, one of a control connection, a secure connection, a management connection, a supervisory connection, a data connection, and a transaction connection with the second big data transaction center unit. One or more combinations.

Optionally, the interconnection control module is configured to send an exit message to the second big data transaction center unit through the interconnection control interface, and disconnect the interconnection with the second big data transaction center unit after confirming that the data transaction is completed. .

It should be noted that the description of the above device embodiments is similar to the description of the foregoing method embodiments, and has similar advantages to the method embodiments, and thus will not be described again. For the technical details that are not disclosed in the device embodiments of the present disclosure, please refer to the description of the method embodiments of the present disclosure, and the details are not described herein.

It is to be understood that the phrase "one embodiment" or "an embodiment" or "an" or "an" Thus, "in one embodiment" or "in an embodiment" or "an" In addition, these particular features, structures, or characteristics may be combined in any suitable manner in one or more embodiments. It should be understood that, in various embodiments of the present disclosure, the size of the sequence numbers of the above processes does not mean the order of execution order, and the order of execution of each process should be determined by its function and internal logic, and should not be directed to the embodiments of the present disclosure. The implementation process constitutes any limitation. The above-mentioned serial numbers of the embodiments of the present disclosure are merely for the description, and do not represent the advantages and disadvantages of the embodiments.

It is to be understood that the term "comprises", "comprising", or any other variants thereof, is intended to encompass a non-exclusive inclusion, such that a process, method, article, or device comprising a series of elements includes those elements. It also includes other elements not explicitly listed, or elements that are inherent to such a process, method, article, or device. An element that is defined by the phrase "comprising a ..." does not exclude the presence of additional equivalent elements in the process, method, item, or device that comprises the element.

In the several embodiments provided by the present application, it should be understood that the disclosed apparatus and method may be implemented in other manners. The device embodiments described above are merely illustrative. For example, the division of the unit is only a logical function division. In actual implementation, there may be another division manner, such as: multiple units or components may be combined, or Can be integrated into another system, or some features can be ignored or not executed. In addition, the coupling, or direct coupling, or communication connection of the components shown or discussed may be indirect coupling or communication connection through some interfaces, devices or units, and may be electrical, mechanical or other forms. of.

The units described above as separate components may or may not be physically separated, and the components displayed as the unit may or may not be physical units; they may be located in one place or distributed on multiple network units; Some or all of the units may be selected according to actual needs to achieve the purpose of the solution of the embodiment.

In addition, each functional unit in each embodiment of the present disclosure may be integrated into one processing unit, or each unit may be separately used as one unit, or two or more units may be integrated into one unit; the above integration The unit can be implemented in the form of hardware or in the form of hardware plus software functional units.

It will be understood by those skilled in the art that all or part of the steps of implementing the foregoing method embodiments may be performed by hardware related to program instructions. The foregoing program may be stored in a computer readable storage medium, and when executed, the program includes The foregoing steps of the method embodiment; and the foregoing storage medium includes: a removable storage device, a read only memory (ROM), a magnetic disk, or an optical disk, and the like, which can store program codes.

Alternatively, the above-described integrated unit of the present disclosure may be stored in a computer readable storage medium if it is implemented in the form of a software function module and sold or used as a standalone product. Based on such understanding, the technical solution of the embodiments of the present disclosure may be embodied in the form of a software product in essence or in the form of a software product stored in a storage medium, including a plurality of instructions. A computer device (which may be a personal computer, server, or network device, etc.) is caused to perform all or part of the methods described in various embodiments of the present disclosure. The foregoing storage medium includes various media that can store program codes, such as a mobile storage device, a ROM, a magnetic disk, or an optical disk.

The above is only the specific embodiment of the present disclosure, but the scope of the present disclosure is not limited thereto, therefore, the scope of the present disclosure should be determined by the scope of the appended claims.

Industrial applicability

Embodiments of the present disclosure provide a data processing method, apparatus, and computer readable storage medium. After a big data transaction center unit receives a data request from a big data demander unit, the big data demand side unit may not exist locally. When the target data is needed, the target data is obtained through other interconnected big data transaction center units, and the target data is received and sent to the big data demander unit. In this way, the integration and sharing of the data resources of each big data transaction center unit is realized, and the data utilization rate is improved, so that the big data demand side unit can acquire the target data in time and efficiently without traversing all the data transaction center units. Query the target data that meets the demand. Further, the user's resource waste is reduced, the user time is saved, and the user experience is improved.

Claims (17)

A data processing method applied to a first big data transaction center unit, including: Receiving a first data request message from a big data demander unit, wherein the first data request message is used to request to deliver data of a first attribute, where the first big data transaction center unit is the big data demand side The contract server of the unit; Retrieving locally whether data of the first attribute exists locally in response to the first data request message; Transmitting, to the second big data transaction center unit interconnected with the first big data transaction center unit, a second data request message in response to the absence of the first attribute data, and receiving from the second big data transaction center unit The data of the first attribute, wherein the second data request message is used to request to return data of the first attribute; Transmitting the data of the first attribute to the big data demander unit. The method of claim 1, wherein the transmitting the second data request message to the second big data transaction center unit interconnected with the first big data transaction center unit comprises: Determining, according to the pre-stored data service directory, the second big data transaction center unit corresponding to the data of the first attribute; Sending the second data request message to the second big data transaction center unit. The method of claim 1, wherein before the transmitting the second data request message to the second big data transaction center unit interconnected with the first big data transaction center unit, the method further comprises: Transmitting, to the second big data transaction center unit, a data service catalog of the first big data transaction center unit, and receiving a data service catalog from the second big data transaction center unit; Saving the data service directory of the second big data transaction center unit. The method of claim 1, wherein before the receiving the first data request from the big data demander unit, the method further comprises: Establishing an interconnection with the second big data transaction center unit according to a preset interconnection strategy. The method according to claim 4, wherein the establishing an interconnection connection with the second big data transaction center unit according to a preset interconnection policy comprises: Listening to the first interconnection request message sent by the second big data transaction center unit according to the interconnection policy, wherein the first interconnection request message carries an identity of the second big data transaction center unit; Performing identity authentication on the second big data transaction center unit according to the identity identifier; And performing access control on the second big data transaction center unit in response to the identity authentication passing; Responding to determining that the second big data transaction center unit is granted access control, transmitting a first internet response message to the second big data transaction center unit, wherein the first internet response message is used to notify that the The second largest data transaction center unit establishes an interconnection relationship. The method according to claim 4, wherein the establishing an interconnection connection with the second big data transaction center unit according to a preset interconnection policy comprises: Transmitting, according to the interconnection policy, a second interconnection request message to the second big data transaction center unit, where the second interconnection request message carries an identity of the first big data transaction center unit, where the identity The identifier is used to indicate that the second big data transaction center unit performs identity authentication and access control; Receiving a second internetworking response message from the second big data transaction center unit, wherein the second internetworking response message is used to notify that an interconnection relationship has been established with the second big data transaction center unit. The method of claim 1, wherein after the receiving the first data request message from the big data demander unit, the method further comprises: Establishing one or more combinations of control connections, secure connections, management connections, supervisory connections, data connections, and transaction connections with the second big data transaction center unit. The method of claim 1, wherein after the receiving data from the first attribute of the second big data transaction center unit, the method further comprises: Sending an exit message to the second big data transaction center unit and disconnecting the interconnection with the second big data transaction center unit after confirming that the data transaction is completed. A data processing device is applied to a first big data transaction center unit, including: an interconnection data transaction module and an interconnection data module, wherein The interconnected data transaction module is configured to receive a first data request message from a big data demander unit, and send data of the first attribute to the big data demander unit, wherein the first data request message is And sending, by the request, the data of the first attribute, where the first big data transaction center unit is a subscription server of the big data demand side unit; The interconnecting data module is configured to, in response to the first data request message, locally search for whether the data of the first attribute exists; if the data of the first attribute does not exist, access to the device through the interconnected data interface Transmitting, by the second largest data transaction center unit of the first big data transaction center unit, a second data request message, and receiving data of the first attribute from the second big data transaction center unit through the interconnected data interface The second data request message is used to request to return data of the first attribute. The apparatus according to claim 9, wherein the interconnection data module is further configured to determine, according to a pre-stored data service directory, the second big data transaction center unit corresponding to the data of the first attribute; The interconnect data connection interface sends the second data request message to the second big data transaction center unit. The apparatus of claim 9, wherein the interconnected data module is further configured to transmit, by the interconnected data interface, a data service catalog of the first big data transaction center unit to the second big data transaction center unit And receiving, by the interconnected data interface, a data service directory from the second big data transaction center unit; and storing a data service directory of the second big data transaction center unit. The apparatus according to claim 9, wherein the apparatus further comprises: an interconnection control module configured to establish an interconnection connection with the second big data transaction center unit through the interconnection control interface according to a preset interconnection policy. The apparatus of claim 12, wherein the interconnection control module is further configured to listen to a first interconnection request message sent by the second big data transaction center unit according to the interconnection policy, wherein the An interconnection request message carries an identity of the second big data transaction center unit; The device further includes: an interconnection security module, configured to perform identity authentication on the second big data transaction center unit according to the identity identifier; and if the identity authentication passes, access the second big data transaction center unit Controlling; if the second big data transaction center unit is granted access control, sending a first internet response message to the second big data transaction center unit, wherein the first internet response message is used to notify that The second big data transaction center unit establishes an interconnection relationship. The apparatus according to claim 12, wherein the interconnection control module is further configured to send a second interconnection request message to the second big data transaction center unit through the interconnection control interface according to the interconnection policy, wherein The second interconnection request message carries an identity of the first big data transaction center unit, where the identity identifier is used to indicate that the second big data transaction center unit performs identity authentication and access control, and is configured to Receiving, by the interconnection control interface, a second interconnection response message from the second big data transaction center unit, wherein the second interconnection response message is used to notify that an interconnection relationship has been established with the second big data transaction center unit . The device according to claim 9, wherein the device further comprises: an interconnection management module configured to establish a control connection, a secure connection, a management connection, a supervisory connection, and the second big data transaction center unit through the interconnection management interface, One or more combinations of data connections and transaction connections. The apparatus of claim 9, wherein the interconnection control module is further configured to send an exit message to the second big data transaction center unit through the interconnection control interface, and disconnect after confirming that the data transaction is completed An interconnection connection with the second big data transaction center unit. A computer readable storage medium storing computer executable instructions configured to perform the method of any of claims 1-8.

Images