CN107944461B - Data processing method, device and equipment - Google Patents

Abstract

The invention provides a data processing method, a device and equipment, wherein the method comprises the following steps: and transmitting data carrying classification identification in the network, wherein the classification identification is generated according to the classification information of the data. The data forwarding mechanism is realized by the data center based on the subscription relationship between the classification identification and the subscriber equipment. The same classification identification mechanism can conveniently realize data interaction among all devices.

Description

A data processing method, device and equipment

【Technical field】

The present invention relates to the technical field of computer applications, and in particular, to a data processing method, apparatus and device.

【Background technique】

With the continuous development of the Internet of Things, hundreds of millions of devices need to be connected to the network, which means that there will be various data transmissions in the network. For example, the media server needs to push data to smart TVs, smart phones, etc. that subscribe to the corresponding data, the smart camera sends the collected data to the user's smart phone, and each device in the network handshakes through signaling data, and so on. These data are complex, and each manufacturer often defines the data transmitted by the equipment produced by the manufacturer. The inconsistency of such data will cause difficulties in data interaction between equipment of different manufacturers because the meaning of their respective data is not clear. , it is often necessary to install additional third-party applications to use third-party protocols for data interaction, which is troublesome to implement.

[Content of the invention]

In view of this, the present invention provides a data processing method, apparatus and device, so as to facilitate the realization of data interaction between various devices.

The specific technical solutions are as follows:

The present invention provides a data processing method, the method includes:

The data carrying the classification identification is transmitted in the network, and the classification identification is generated according to the classification information to which the data belongs.

The present invention also provides a data processing method, the method comprising:

The data-side device registers the classification identification with the data center, so as to transmit the data carrying the registered classification identification in the network;

The classification identifier is generated according to the classification information to which the data belongs.

The present invention also provides a data processing method, the method comprising:

The data center stores the classification identifier registered by the data-side device, so as to process the data carrying the classification identifier, wherein the classification identifier is generated according to the classification information to which the data belongs.

The present invention also provides a data processing method, the method comprising:

The subscriber device subscribes the classification identifier to the data center, so as to receive the data carrying the classification identifier forwarded by the data center, wherein the classification identifier is generated according to the classification information to which the data belongs.

The present invention also provides a data processing method, the method comprising:

The signaling data carrying the classification identifier is transmitted between devices, wherein the classification identifier is generated according to the classification information to which the signaling data belongs, and the signaling data adopts the data format corresponding to the classification identifier.

The present invention also provides a device comprising

memory, including one or more programs;

One or more processors, coupled to the memory, execute the one or more programs to:

The data carrying the classification identification is transmitted in the network, and the classification identification is generated according to the classification information to which the data belongs.

The present invention also provides a data party device, comprising:

memory, including one or more programs;

One or more processors, coupled to the memory, execute the one or more programs to:

Register the classification identification with the data center to transmit data carrying the registered classification identification in the network;

The classification identifier is generated according to the classification information to which the data belongs.

The present invention also provides a data center device, comprising:

memory, including one or more programs;

One or more processors, coupled to the memory, execute the one or more programs to:

The classification identification registered by the data-side device is stored, so as to process the data carrying the classification identification, wherein the classification identification is generated according to the classification information to which the data belongs.

The present invention also provides a subscriber device, comprising:

memory, including one or more programs;

One or more processors, coupled to the memory, execute the one or more programs to:

Subscribing a classification identifier to the data center, so as to receive the data carrying the classification identifier forwarded by the data center, wherein the classification identifier is generated according to the classification information to which the data belongs.

The present invention also provides a device comprising

memory, including one or more programs;

One or more processors, coupled to the memory, execute the one or more programs to:

The signaling data carrying the classification identifier is transmitted with other devices, wherein the classification identifier is generated according to the classification information to which the signaling data belongs, and the signaling data adopts the data format corresponding to the classification identifier.

The present invention also provides a data processing device comprising:

The transmission unit is configured to transmit the data carrying the classification identification in the network, and the classification identification is generated according to the classification information to which the data belongs.

The present invention also provides a data processing device, which is arranged on the data side equipment, and the device includes:

A registration unit, used to register the classification identification with the data center, so as to transmit the data carrying the registered classification identification in the network;

The classification identifier is generated according to the classification information to which the data belongs.

The present invention also provides a data processing device comprising:

The registration unit is configured to store the classification identifier registered by the data-side device, so as to process the data carrying the classification identifier, wherein the classification identifier is generated according to the classification information to which the data belongs.

The present invention also provides a data processing device comprising:

The subscription unit is used to subscribe the classification identifier to the data center;

A receiving unit, configured to receive the data carrying the classification identifier forwarded by the data center, wherein the classification identifier is generated according to the classification information to which the data belongs.

The present invention also provides a data processing device comprising:

A transmission unit, configured to transmit signaling data carrying a classification identifier with other devices, wherein the classification identifier is generated according to the classification information to which the signaling data belongs, and the signaling data adopts a data format corresponding to the classification identifier.

It can be seen from the above technical solutions that the present invention uniformly adopts the classification identification in the transmitted data to clarify the data type, that is, the classification identification is generated according to the classification information to which the data belongs. Data interaction can also be performed directly between them, avoiding the need for additional installation of third-party applications to use third-party protocols for data interaction, which is more convenient to implement.

【Description of drawings】

Fig. 1 is the registration flow chart of IDSU provided by the embodiment of the present invention;

2 is a schematic diagram of an IDSU mechanism provided by an embodiment of the present invention applied to the Internet of Things;

3 is a system structure diagram of an IDSU mechanism provided by an embodiment of the present invention;

4 is a flowchart of a method for subscribing to IDSU data provided by an embodiment of the present invention;

5 is a schematic diagram of an application framework of an IDSU mechanism provided by an embodiment of the present invention;

6 is a structural diagram of an apparatus provided in a data-side device provided by an embodiment of the present invention;

7 is a structural diagram of a device provided in a data center according to an embodiment of the present invention;

8 is a structural diagram of an apparatus provided in a subscriber device provided by an embodiment of the present invention;

9 is a structural diagram of an apparatus for transmitting signaling provided by an embodiment of the present invention;

FIG. 10 is a structural diagram of a device provided by an embodiment of the present invention.

【Detailed ways】

In order to make the objectives, technical solutions and advantages of the present invention clearer, the present invention will be described in detail below with reference to the accompanying drawings and specific embodiments.

The terms used in the embodiments of the present invention are only for the purpose of describing specific embodiments, and are not intended to limit the present invention. As used in the embodiments of the present invention and the appended claims, the singular forms "a," "the," and "the" are intended to include the plural forms as well, unless the context clearly dictates otherwise.

It should be understood that the term "and/or" used in this document is only an association relationship to describe the associated objects, indicating that there may be three kinds of relationships, for example, A and/or B, which may indicate that A exists alone, and A and B exist at the same time. B, there are three cases of B alone. In addition, the character "/" in this document generally indicates that the related objects are an "or" relationship.

Depending on the context, the word "if" as used herein can be interpreted as "at" or "when" or "in response to determining" or "in response to detecting." Similarly, the phrases "if determined" or "if detected (the stated condition or event)" can be interpreted as "when determined" or "in response to determining" or "when detected (the stated condition or event)," depending on the context )" or "in response to detection (a stated condition or event)".

The core idea of the present invention is that the data transmitted in the network all carry the classification identification, and the classification identification adopts a unified generation mechanism, at least generated according to the classification information to which the data belongs. In the embodiment of the present invention, the classification identifier is used as a unique identification unit of data, which is called IDSU (IoT Data Storage Unit, Internet of Things Data Standard Storage Unit) in the embodiment of the present invention.

In order to facilitate understanding, the generation method of IDSU is described first. As described above, the IDSU is generated from at least classification information to which the data belongs, where the classification information may include N-level classifications, where N is a positive integer. In addition to the classification information, it can also be generated according to at least one of security level information, data source information, version information corresponding to the classification to which the data belongs, and data format version information corresponding to the classification described in the data.

The IDSU can be generated by encoding the above-mentioned information according to a predetermined encoding rule, and each information is encoded into a specific number of digits according to a preset sequence, and finally an IDSU with a uniform number of digits is formed. Among the above information, classification information is necessary, and preferably, security level information and data source information may also be included. It may further include version information corresponding to the classification and data format version information corresponding to the classification.

Taking all the above information as an example, a preferred IDSU generation method is provided below. As shown in Table 1, IDSU can be composed of three-level classification information, security level information, data source identification, data format version number and classification version number according to A predetermined encoding rule is used for encoding generation. The coding rules can also be as shown in Table 1, in which the first-level classification code occupies 10 bits, the second-level classification code occupies 14 bits, the third-level classification code occupies 21 bits, the security level occupies 2 bits, the data source identifier occupies 2 bits, and the data The format version number occupies 6 digits, and the classification version number occupies 8 digits. The symbol code is optional, occupying 1 bit, and the fixed value is 1.

Table 1

Among them, the first-level category is a higher-level category, the second-level category is subordinate to the first-level category, and the level is second, and the third-level category is subordinate to the second-level category and has a lower level. For example, for the data collected by the sports bracelet, the classification information used is: "Sports" belongs to the first-level category, "running" belongs to the second-level category, and "100 meters" belongs to the third-level category.

The security level can use 4 values between 0 and 3 to represent four security levels, for example: 0 represents shared data, the security level is the lowest; 1 represents data that requires authorization from the data party; 2 represents data that requires authorization from the data source; 3 Represents private data, prohibits disclosure, and has the highest security level.

The data source identifier can use 4 values between 0 and 3 to represent the 4 data sources, for example: 0 represents the original data generated by the terminal device, 1 represents the processed analysis data, and 2 represents the interconnection signaling between the terminal devices. data, 3 represents server data.

The data format version number is used to record the format version associated with the same classification, in order to describe the data in various fields more professionally. For example, when the classification code is "sports-running-100 meters", data party A specifies the data format corresponding to the classification and uses it on its sports equipment. Later, although the B data party adopts the same classification code, but proposes a more comprehensive data format description, then its corresponding data format can use another version number to distinguish it from the previous version.

The classification version number is mainly used to mark the classification system, that is, after the existing classification system is upgraded, it will not affect the existence of the existing classification system, but another version number is used to identify the upgraded classification system. This will not affect the IDSU that has been generated before.

The above coding scheme can have the following advantages:

1) Enable data parties to generate IDSUs by themselves.

2) The 64-bit long integer encoding method is adopted, and the supported classifications theoretically reach 2 ¹⁵ × 2 ¹⁸ × 2 ²⁰ = 2 ⁵³ .

3) Compared with string encoding, integer encoding can save a certain amount of space on low-power IoT devices, and bit operations are relatively faster than string operations.

4) The IDSU code carries certain identification information, such as data source identification, security level, etc., to facilitate some specific data processing.

When transmitting data in the network, IDSUs generated by using unified rules according to the classification information can be used respectively. However, as a preferred implementation manner, each data party can perform IDSU registration in a unified data center, thereby ensuring the uniformity of IDSU generation rules. The registration process of the IDSU is described below with reference to the embodiment shown in FIG. 1 . In this embodiment, two devices are mainly involved: a data party device and a data center. The data-side device may be any terminal device, or may be a server or a server cluster. A data center can usually be a server or a cluster of servers.

The execution flow of the embodiment shown in FIG. 1 is executed at the data center side. As shown in FIG. 1 , the method may include the following steps:

In 101, the classification information sent by the data party device is obtained.

In this embodiment of the present invention, the data party can customize the classification information, for example, the data party provides information of primary classification, secondary classification and tertiary classification; the data platform can also provide optional classification information to the data party equipment , for example, provide the data party with optional first-level classification, second-level classification and third-level classification information for the data party to choose from; The information of the first-level classification, the second-level classification, and the third-level classification information. If the data party feels that the optional certain-level classification information does not meet the requirements, it can define the certain-level classification information in a self-defined way.

If the classification information sent by the data party is the existing classification information of the data platform, the corresponding classification code can be obtained directly. If it is not the existing classification information of the data platform, for example, a new classification information is added to a certain level of classification, the data platform can record the newly added classification information after the approval of the newly added classification information, and determine the type of the newly added classification information. Classification code, and upgrade the classification version number. Among them, the approval may be performed by the data platform according to predetermined rules, or may be provided to the management personnel for approval by the management personnel.

Among them, if the data party applies for a new first-level classification, after the first-level classification is added, it may continue to apply for adding a second-level classification and a third-level classification based on the first-level classification. If the data party applies for a new second-level classification under a certain first-level classification, the second-level classification is subordinate to the first-level classification, and it may continue to apply for a new third-level classification based on the second-level classification. No matter which level of classification is added, the final classification information is new classification information, so the classification version number needs to be updated, for example, based on the highest existing classification version number plus 1.

In 102, it is judged whether there is an IDSU generated for the classification information, if yes, go to 103; otherwise, go to 106.

In 103, it is judged whether a format version change request is received, if yes, go to 104; otherwise, go to 107, return the existing IDSU generated for the classification information to the data party device to complete the registration.

For each category, there is a corresponding data format. The data center can provide the data format to the data-side equipment, either actively, or at the request of the data-side equipment. After viewing the data format, if the data party believes that the data format can meet its needs, it can accept the data format; if it thinks that it cannot meet its needs, it can send a format version change request to the data center through the data party's equipment. For example, you can set the required data format on the format version setting interface, and then click the "Confirm" component to send a format version change request, where the format version change request includes the requested format information after the change.

In 104, the format information after the requested modification is saved, and the format version number corresponding to the classification information is updated.

In this step, each classification can correspond to multiple data formats, so as to meet the needs of different data parties. In order to distinguish each data format, different format version numbers can be used. For example, every time a new data format is added to a category, the current largest format version number corresponding to the category is incremented by 1.

In 105, an IDSU is generated and returned to the data party device to complete this registration.

In this step, the classification information, security level, data source identifier, data format version number, classification version number, etc. can be encoded according to the rules in Table 1 above, and then the IDSU is obtained. In addition, it should be noted that, in this embodiment, after the data party sets the classification information, the security level and the data source identification may be further set, that is, the security level information and the data source identification are sent to the data center through the data party's equipment for use. The data center generates the IDSU, a process not shown in Figure 1.

In 106 , obtain the data format information sent by the data-side device, set the format version number, and go to execution 105 .

For the newly added category, the data party needs to set the data format for the category, so that the data belonging to the category can adopt the corresponding data format. In this step, the data side device can display the data format setting interface provided by the data center to the data side, the data side can set the data format on the format setting interface, and send the data format to the data center.

As an example of a data format, suppose the defined data format is:

"description rule": "primitive type"_["value range"]_"unit"

Taking physical fitness data as an example, the corresponding data format is:

When transmitting data, the data can be as follows according to the above data format:

In this way, for the receiver who receives the data, after parsing the data format corresponding to the IDSU carried in the data, the content of the data can be known as follows: the gender is the gender indicated by 0, the height is 172cm, and the weight is 66.5cm.

In addition, since different data parties may use the same type of data in different ways, there will be individual differences in the usage methods. These differences can be realized by setting extended configuration information in the data center. The data center can receive and store the extended configuration information sent by the data party to the registered IDSU, such as whether the data is stored in the data center, subscriber constraint information, whether to filter sensitive words, and so on. These extended configuration information is not encoded in the IDSU, but is additionally recorded in the data center, for example, can be recorded in the extended configuration table.

The above IDSU mechanism can be widely applied to the Internet of Things. As shown in FIG. 2 , the Internet of Things device can transmit IDSU data (that is, data carrying IDSU) in the network, thereby realizing the data flow of IDSU. In addition to the above-mentioned IDSU registration, IDSU data authorization can also be performed in the data center through the interface with the cloud server (YunIO), for example, the subscriber device that subscribes to a certain IDSU data can be authorized. In addition, signaling data can also be defined by a specific classified IDSU, so as to realize event distribution, such as status event reporting, control event delivery, and so on. These can be applied to various fields such as smart home, smart city, smart sports, and Internet of Vehicles through various open platforms. It can also be applied to data sharing platforms, data mining engines, data real-time computing platforms, and so on. The implementation schemes of some typical application scenarios are described in detail below.

A typical application scenario is that, for an IDSU registered by a data party, data subscription for the IDSU can be implemented. The system composition involved in this application scenario may be as shown in FIG. 3 , including: a data source device, a data source device, a data center, and a subscriber device. The data source device and the data source device have been mentioned in the above embodiments, and the subscriber device refers to a device that subscribes to a certain IDSU data, which may be a terminal device or a server. The data source device refers to the source device that sends IDSU data, which can be a terminal device or a server.

The main implementation of this application scenario is shown in Figure 3:

In 301, the data party device and the data center implement the IDSU registration by using the process shown in FIG. 1 .

In 302, the subscriber device subscribes data carrying the IDSU in the data center, referred to as IDSU data.

The process of subscribing to IDSU data will be described in detail in the embodiment shown in FIG. 4 later.

After the subscription is successful, in 303, the IDSU data sent by the data source device is sent to the data center.

In 304, the data center forwards the received IDSU data to a subscriber device that subscribes to the IDSU data.

After IDSU registration is successful, the data source device can send IDSU data. To ensure that IDSU data is forwarded through the data center, when the data source device sends IDSU data, the destination address of the data is the address of the data center. The destination address can be an IP address or an identity of a data center, such as ID ² . ID ² is uniformly allocated by the identity server and provided to the device, and is written into the device's safe storage area at the delivery stage of the device. The type of the destination address is determined according to the specific network protocol type, which is not limited in the present invention. For the data center, after receiving the IDSU data, it searches for the subscriber device that subscribes to the IDSU, and when forwarding the IDSU data, replaces the destination address of the IDSU data with the address of each subscriber device.

That is to say, IDSU data is reported to the data center layer by layer from the data source device, and then the data center forwards it to the subscribers uniformly.

It should be noted that, the data source device and the data source device may be the same device or different devices.

FIG. 4 is a flowchart of a method for subscribing IDSU data provided by an embodiment of the present invention. The process is performed by a data center. As shown in FIG. 4 , the method includes:

In 401, the data center receives a subscription request sent by a subscriber device.

The data center can send a subscription interface to the subscriber device. On the subscription interface, the subscriber can view the IDSU available for subscription, and can also see the relevant description of the IDSU, such as data party information, classification information, etc. After the subscriber selects the IDSU to be subscribed, the subscriber device sends a subscription request to the data center, and the subscription request carries the IDSU to be subscribed.

It should be noted that, in addition to the above method of acquiring the IDSU to be subscribed, the subscriber device may also acquire the IDSU from the data party device. For example, after the data party device completes the IDSU registration, it can provide the successfully registered IDSU to the data party device. There may be various ways provided, for example, the data-side device can generate a QR code from the registered IDSU for the data-side device to scan.

In 402, the data center records the correspondence between the IDSU and the subscriber device, and marks the status of the subscriber device as pending review.

In 403, the authorization information sent by the data-side device whether to allow the subscriber device to subscribe to the IDSU is received.

The data party can regularly check the information of the subscriber's device that subscribes to the IDSU from the data center, and then perform authorization management. If a subscriber's device is allowed to subscribe, it can send the data center the authorization information that allows the subscriber's device to subscribe. Alternatively, the data center may also actively push the information of the subscriber's device that subscribes to the IDSU to the data-side device on a regular basis, for the device-side to perform authorization management.

In 404, if the data party device allows the subscriber device to subscribe to the IDSU, the status of the subscriber device is marked as subscribed successfully.

The above process is a preferred implementation provided to ensure the security of the subscription, that is, the authorization of the subscription is completed by the data party. In addition to this implementation, there may be other ways, such as authorization to be implemented by the administrator of the data center. Alternatively, without authorization management, any subscriber device can subscribe, that is, after the data center receives the subscription request, it directly marks the status of the subscriber device as subscribed successfully. and many more.

When the subsequent data center forwards the IDSU data, it will only forward it to the subscriber device in the subscribed state.

The framework corresponding to the process shown in the foregoing embodiment may be as shown in FIG. 5 . The data center can provide external registration/subscription pages for data parties to register with IDSU and for subscribers to subscribe to IDSU. By default, the subscriber is in the pending review state. In addition, an authorization mechanism is provided externally, so that the data party can authorize the subscribers who subscribe to the IDSU, and only the authorized subscribers are set to the subscription success state. The subscription relationship between IDSU and subscribers is cached in the subscription relationship list.

The main thread is responsible for the distribution of data packets, where the data packets refer to the received IDSU data, Tlog recording and Big Data Computing Service (ODPS).

The received IDSU data is stored in the subscription asynchronous message queue-IN (inbound direction), and the existence of IDSU is checked through the YunIO interface.

Subscription processing and data forwarding processing can be performed by a subscription processor in the data center, and the subscription processor pulls IDSU data from the subscription message asynchronous message queue. Extensible filtering refers to extensible filtering of the received data based on the expansion setting information provided by the data party to the data center during the registration process. For example, for IDSUs that are set to not be subscribed, no forwarding is done. For the IDSU set to need to filter sensitive information, the received IDSU data is filtered for sensitive information, and so on.

IDSU data can be distributed to subscriber devices that subscribe through various subscription mechanisms. Usually, for internal subscribers, subscriptions such as HSF (High Performance Service Framework), CMNS (connection mode network service, connection mode network service) subscription, etc. . For external subscribers, Metag subscription, HTTP subscription, etc. can be used. IDSU data is first sent to the subscription asynchronous message queue - OUT (outbound), and then sent through the gateway to the external subscriber via the HSF service that handles the subscription.

Here is an example for this application scenario:

A news service provider registered the classification of "News-Sports-NBA" in the data center, and generated an IDSU with the data source identified as the news service provider. Users who want to read the news of the news service provider's category through their mobile phones can subscribe to the IDSU through the data center. When the news server of the news service provider has news data under the category, the data carrying the IDSU is sent. These IDSU data are forwarded to the data center, via the data center, to the subscriber devices subscribed to the IDSU. Corresponding to the embodiment shown in FIG. 3 .

Another typical application scenario is that signaling data carrying IDSU is transmitted between devices, so as to achieve the purpose of handshake between devices, or control between devices.

Corresponding classification information may exist for each type of signaling, and further IDSU may exist, that is, the signaling type may be indicated by the IDSU carried in the signaling data.

Each device can send signaling data corresponding to the IDSU according to the current state and requirements, and the device that receives the signaling data can learn what kind of signaling it is from the IDSU carried in the signaling data. In addition, the corresponding relationship between the IDSU and the processing logic can be stored in the device in advance. After the device receiving the signaling data parses the signaling data according to the data format corresponding to the IDSU, it can perform the processing corresponding to the IDSU according to the analysis result. logic.

Here is an example for this application scenario:

There is a new node, assuming that the node 1 wants to join the network, the node 1 obtains the node list after scanning the existing nodes in the network. One node 2 is selected from the node list to send signaling, and the IDSU1 carried in the signaling indicates that the type of the signaling is a signaling requesting to join the network. The node 2 that receives the signaling parses the signaling according to the data format corresponding to the IDSU1, and obtains the identity information of the node, such as the ID ² of the node 1, from the signaling. It is assumed that the processing logic corresponding to the IDSU1 is to authenticate the identity of the node. If the authentication is passed, it returns a response message that allows to join the network, and if the authentication fails, it returns a response message that refuses to join the network. Then the node 2 that has received the above signaling executes the processing logic of identity authentication according to the ID ² of the node 1 . Assuming that the authentication is passed, the signaling carrying IDSU2 is returned, and the IDSU2 indicates that the type of the signaling is a response message for whether or not to allow to join the network, and then the information about allowing to join the network is included in the signaling according to the data format corresponding to the IDSU2 . Node 1 completes a handshake after receiving the signaling carrying IDSU2. There may also be other handshake processes in the follow-up, all of which may use IDSU to identify the signaling type, and will not be exhaustive.

To give another example, in many application scenarios, each node in the network needs to conduct negotiation and election. For example, if the root node in the network is selected according to the device capability, then each node in the network can broadcast the signaling carrying IDSU3 in the network. And the signaling carries its own capability information. Wherein, IDSU3 indicates that the type of the signaling is a broadcast message carrying capability information.

The above is a detailed description of the method provided by the present invention, and the device provided by the present invention is described in detail below.

The apparatus provided by the embodiment of the present invention mainly includes a transmission unit capable of transmitting data carrying a classification identifier in the network, and the classification identifier is generated according to the classification information to which the data belongs, and may be further generated according to at least one of the following information: security level information , data source information, version information corresponding to the category to which the data belongs, and data format version information corresponding to the category to which the data belongs.

The apparatus may be set on data center equipment, data source equipment, and subscriber equipment. In addition, in order to cooperate with the registration of data classification, the embodiment of the present invention also provides a device set on data side equipment. These devices will be described in detail below with reference to the embodiments.

FIG. 6 is a structural diagram of an apparatus provided in a data party device according to an embodiment of the present invention. As shown in FIG. 6 , the apparatus may include a registration unit 01 , an authorization unit 02 and an identification providing unit 03 . The main functions of each constituent unit are as follows:

The registration unit 01 is responsible for registering the classification identifier with the data center, so that the device of the data party transmits the data carrying the registered classification identifier in the network, wherein the classification identifier is generated according to the classification information to which the data belongs.

Specifically, the registration unit 01 may send the classification information to the data center, and obtain the classification identifier returned by the data center for the classification information. The registration unit 01 can select from the optional classification information provided by the data center, and can also customize the classification information, or adopt a combination of the two. Wherein, after the registration unit 01 determines the classification information, if the current classification does not have corresponding data format information, or the data format information corresponding to the current classification cannot meet the requirements, it can further send a format version change request to the data center, and the request carries Request the changed data format. In this case, the classification ID returned by the data center for the classification information is the classification ID generated according to the classification information and the format version after the requested change.

Further, the registration unit 01 may also send extended configuration information to the data center for the registered classification identifier, wherein the extended configuration information may include but is not limited to: whether the data is stored in the data center, subscriber constraint information, and whether filtering is required. Sensitive information, etc.

The authorization unit 02 is responsible for acquiring the subscriber device information of the subscription classification identifier from the data center; and sending the authorization information of whether the subscriber device is allowed to subscribe to the classification identifier to the data center.

The identification providing unit 03 is responsible for providing the registered category identification to the subscriber's device, for example, the category identification can be generated into a QR code for the subscriber's device to scan, or provided to the subscriber in other ways such as email and message.

FIG. 7 is a structural diagram of an apparatus provided in a data center according to an embodiment of the present invention. As shown in FIG. 7 , the apparatus includes a registration unit 11 , a forwarding unit 12 and a subscription unit 13 , and the main functions of each constituent unit are as follows :

The registration unit 11 is responsible for storing the classification identifier registered by the data-side device, so as to process the data carrying the classification identifier, wherein the classification identifier is generated according to the classification information to which the data belongs.

Specifically, after receiving the classification information sent by the data-side device, the registration unit 11 determines whether there is already a classification identifier generated for the classification information, and if so, returns the existing classification identifier generated for the classification information to the data-side device. ; otherwise, upgrade the version information corresponding to the classification information, generate a classification identification for the classification information, and return it to the data source device.

Wherein, when the judgment result is yes, if a format version change request sent by the data source device for the classification information is received, the format information after the request change is saved, the version information corresponding to the classification information is updated, and then a classification identifier is generated. Return to the data party device; otherwise, return the existing classification identifier generated for the classification information to the data party device.

Further, when the registration unit 11 determines that there is no classification identifier generated for the classification information, it will also receive the format information sent by the data source device for the classification information, save the format information and record the corresponding format version information.

In addition, the registration unit 11 may also receive and store the extended configuration information sent by the data object for the registered classification identifier. The extended configuration information includes: whether data is stored in the data center, subscriber constraint information, and whether sensitive information needs to be filtered.

The forwarding unit 12 is responsible for sending the data carrying the registered classification identifier to the subscriber device that subscribes to the classification identifier after receiving the data.

The subscription unit 13 is responsible for storing the subscriber information of the subscription classification identifier and the authorization information sent by the data party device whether to allow the subscriber device to subscribe to the classification identifier. The forwarding unit 12 sends the data to the subscriber device that is allowed to subscribe to the classification identifier.

The subscribing unit 13 may, after receiving the subscription request from the subscriber device, first mark the subscriber device as a pending review state when storing the correspondence between the subscriber device and the classification identifier. After knowing that the receiving device allows the subscriber device to subscribe to the authorization information of the classification identifier, the subscriber device is marked as a status of successful subscription. When forwarding the data, the forwarding unit 12 only forwards the data to the subscriber device in the subscription success state.

FIG. 8 is a structural diagram of an apparatus provided in a subscriber device according to an embodiment of the present invention. As shown in FIG. 8 , the apparatus may include: a subscription unit 21 and a receiving unit 22 , and may also include an identification obtaining unit 23 . The main functions of each constituent unit are as follows:

The subscribing unit 21 is responsible for subscribing the classification identifier to the data center.

The receiving unit 22 is responsible for receiving the data carrying the classification identifier forwarded by the data center, wherein the classification identifier is generated according to the classification information to which the data belongs.

The identification obtaining unit 23 may obtain the subscribing category identification from the data center, or obtain the subscribing category identification from the data source device.

FIG. 9 is a structural diagram of an apparatus for transmitting signaling according to an embodiment of the present invention. As shown in FIG. 9 , the apparatus may include a transmission unit 31 and a parsing processing unit 32 . The main functions of each constituent unit are as follows:

The transmission unit 31 is responsible for transmitting the signaling data carrying the classification identification with other devices, wherein the classification identification is generated according to the classification information to which the signaling data belongs, and the signaling data adopts the data format corresponding to the classification identification.

The parsing processing unit 32 is responsible for parsing the signaling data according to the data format corresponding to the classification identifier after the transmission unit 31 receives the signaling data carrying the classification identifier, and executes processing logic corresponding to the classification identifier according to the parsing result.

The above-mentioned method and apparatus provided by the embodiments of the present invention may be embodied by a computer program set and running in a device. The apparatus may include one or more processors, as well as memory and one or more programs, as shown in FIG. 10 . The one or more programs are stored in the memory and executed by the above-mentioned one or more processors to implement the method process and/or the apparatus operation shown in the above-mentioned embodiments of the present invention. For example, the method process executed by the above-mentioned one or more processors may include:

The data carrying the classification identification is transmitted in the network, and the classification identification is generated according to the classification information to which the data belongs.

For another example, the method process executed by the above-mentioned one or more processors may include:

Register the classification identification with the data center to transmit data carrying the registered classification identification in the network;

The classification identifier is generated according to the classification information to which the data belongs.

For another example, the method process executed by the above-mentioned one or more processors may include:

The classification identification registered by the data-side device is stored, so as to process the data carrying the classification identification, wherein the classification identification is generated according to the classification information to which the data belongs.

For another example, the method process executed by the above-mentioned one or more processors may include:

Subscribing a classification identifier to the data center, so as to receive the data carrying the classification identifier forwarded by the data center, wherein the classification identifier is generated according to the classification information to which the data belongs.

For another example, the method process executed by the above-mentioned one or more processors may include:

The signaling data carrying the classification identifier is transmitted with other devices, wherein the classification identifier is generated according to the classification information to which the signaling data belongs, and the signaling data adopts the data format corresponding to the classification identifier.

The devices involved in the embodiments of the present invention may include, but are not limited to, such as: smart mobile terminals, smart home devices, network devices, wearable devices, smart medical devices, PCs (personal computers), and the like. The smart mobile devices may include mobile phones, tablet computers, notebook computers, PDAs (personal digital assistants), Internet cars, and the like. Smart home devices may include smart home appliances, such as smart TVs, smart air conditioners, smart water heaters, smart refrigerators, smart air purifiers, and the like, and smart home devices may also include smart door locks, smart sockets, smart lights, smart cameras, and the like. Network devices may include, for example, switches, wireless APs, servers, and the like. Wearable devices may include, for example, smart watches, smart glasses, smart bracelets, virtual reality devices, augmented reality devices, mixed reality devices (ie, devices that can support both virtual reality and augmented reality), and the like. Smart medical devices may include, for example, smart thermometers, smart blood pressure meters, smart blood glucose meters, and the like.

As can be seen from the above description, the above method, device and device provided by the present invention can have the following advantages:

1) The present invention uniformly adopts the classification identification to clarify the data type in the transmitted data, that is, the classification identification is generated according to the classification information to which the data belongs. Data interaction avoids additional installation of third-party applications to use third-party protocols for data interaction, which is more convenient to implement.

2) The classification identification carried by the data carries certain information, such as classification information, data source identification, security level, etc., which can provide an information basis for subsequent big data analysis and mining.

3) The registration mechanism of the classification identification provided by the present invention enables the data party to customize the classification identification according to its own needs, and define the minimum segmentation granularity of the data type through the classification identification.

4) The subscription mechanism of the classification identification provided by the present invention enables the subscriber to conveniently subscribe the classification identification in the data center, and after the corresponding data source generates the data carrying the classification identification, the data center can promptly forward the data to the data center. Subscriber device that subscribes to this category identification.

In the several embodiments provided by the present invention, it should be understood that the disclosed system, apparatus and method may be implemented in other manners. For example, the apparatus embodiments described above are only illustrative. For example, the division of the units is only a logical function division, and there may be other division manners in actual implementation.

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

In addition, each functional unit in each embodiment of the present invention may be integrated into one processing unit, or each unit may exist physically alone, or two or more units may be integrated into one unit. The above-mentioned integrated unit may be implemented in the form of hardware, or may be implemented in the form of hardware plus software functional units.

The above-mentioned integrated units implemented in the form of software functional units can be stored in a computer-readable storage medium. The above-mentioned software functional unit is stored in a storage medium, and includes several instructions to cause a computer device (which may be a personal computer, a server, or a network device, etc.) or a processor (processor) to execute the methods described in the various embodiments of the present invention. some steps. The aforementioned storage medium includes: U disk, mobile hard disk, read-only memory (Read-Only Memory, ROM), random access memory (Random Access Memory, RAM), magnetic disk or optical disk and other media that can store program codes .

The above descriptions are only preferred embodiments of the present invention, and are not intended to limit the present invention. Any modifications, equivalent replacements, improvements, etc. made within the spirit and principles of the present invention shall be included in the present invention. within the scope of protection.

Claims (15)

1. A method of data processing, the method comprising:

transmitting data carrying a classification identifier in a network, the classification identifier being generated based on classification information to which the data belongs, wherein,

the classification identification is further generated according to the security level information and the data source information;

the data center stores the classification identification registered by the data side equipment and stores the subscriber equipment information subscribing the classification identification;

wherein, the transmitting the data carrying the classification identifier in the network includes: after receiving the data carrying the registered classification identifier, the data center forwards the data to a subscriber device subscribing the classification identifier;

the data center stores extended configuration information corresponding to the classification identification registered by the data side equipment;

and after receiving the data carrying the registered classification identifier and before sending the data to the subscriber equipment subscribing the classification identifier, the data center further processes the data according to the extended configuration information corresponding to the classification identifier.

2. The method of claim 1, wherein the class identifier is further generated based on at least one of the following information: version information corresponding to the class to which the data belongs, and data format version information corresponding to the class to which the data belongs.

3. The method according to claim 1 or 2, characterized in that the method further comprises: the data side equipment registers classification identification with a data center in advance;

the transmitting data carrying the classification identifier in the network includes: and the data source equipment sends data carrying the registered classification identification in the network.

4. The method according to claim 1, wherein the destination address of the data carrying the registered classification identifier received by the data center is the address of the data center;

and when the data center sends the data to the subscriber equipment, replacing the destination address of the data with the address of the subscriber equipment.

5. The method of claim 1, wherein the extended configuration comprises:

whether data is stored in the data center, subscriber constraint information, and whether filtering of sensitive information is required.

6. The method according to claim 1 or 2, characterized in that the method further comprises: subscribing classification identification from the data center by the subscriber equipment;

the transmitting data carrying the classification identifier in the network includes: and the subscriber equipment receives the data which is sent by the data center and carries the subscribed classification identification.

7. The method according to claim 1 or 2, wherein the transmitting data carrying the class identifier in the network comprises:

sending the data according to the data format corresponding to the classification identification; or,

and analyzing the received data according to the data format corresponding to the classification identification.

8. An electronic device comprises

A memory including one or more programs;

one or more processors, coupled to the memory, that execute the one or more programs to:

transmitting data carrying a classification identifier in a network, the classification identifier being generated based on classification information to which the data belongs, wherein,

the classification identification is further generated according to the security level information and the data source information;

the equipment is a data center;

the operations further include: storing the classification identification registered by the data side equipment and storing the subscriber side equipment information subscribed to the classification identification;

the transmitting data carrying the classification identifier in the network includes: after receiving data carrying registered classification identification, sending the data to a subscriber device subscribing the classification identification;

the operations further include: storing extended configuration information corresponding to the classification identification registered by the data side equipment;

after receiving the data carrying the registered classification identifier and before sending the data to the subscriber device subscribing to the classification identifier, the operations further include: and processing the data according to the extended configuration information corresponding to the classification identification.

9. The apparatus of claim 8, wherein the class identifier is further generated based on at least one of: version information corresponding to the class to which the data belongs, and data format version information corresponding to the class to which the data belongs.

10. The apparatus according to claim 8 or 9, wherein the apparatus is a data source apparatus;

the transmitting data carrying the classification identifier in the network includes: and the data source equipment sends data carrying the classification identification pre-registered by the data party in the network, and the destination address of the data is the address of the data center.

11. The device according to claim 8, wherein the destination address of the data carrying the registered classification identifier received by the data center is the address of the data center;

when data is sent to a subscriber device, the destination address of the data is replaced with the address of the subscriber device.

12. The apparatus of claim 8, wherein the extended configuration comprises:

whether data is stored in the data center, subscriber constraint information, and whether filtering of sensitive information is required.

13. The device of claim 8 or 9, wherein the device is a subscriber device;

the operations further include: subscribing classification identification to a data center;

the transmitting data carrying the classification identifier in the network includes: and receiving the data which is sent by the data center and carries the subscribed classification identification.

14. The apparatus according to claim 8 or 9, wherein said transmitting data carrying a classification identifier in a network comprises:

sending the data according to the data format corresponding to the classification identification; or,

and analyzing the received data according to the data format corresponding to the classification identification.

15. A data processing apparatus, characterized in that the apparatus comprises:

a transmission unit, configured to transmit data carrying a classification identifier in a network, where the classification identifier is generated according to classification information to which the data belongs,

the classification identification is further generated according to the security level information and the data source information; the data center stores the classification identification registered by the data side equipment and stores the subscriber equipment information subscribing the classification identification;

wherein, the transmitting the data carrying the classification identifier in the network includes: after receiving the data carrying the registered classification identifier, the data center forwards the data to a subscriber device subscribing the classification identifier;

the data center stores extended configuration information corresponding to the classification identification registered by the data side equipment;

and after receiving the data carrying the registered classification identifier and before sending the data to the subscriber equipment subscribing the classification identifier, the data center further processes the data according to the extended configuration information corresponding to the classification identifier.

Images