Granted Patent B2

US 12,498,978 · App. 19/206,035 · Granted Dec 16, 2025

Inventor: Hanshu Shao (Chengdu, CN)

Assignee: CHENGDU QINCHUAN IOT TECHNOLOGY CO., LTD.

G06F9/5027

Abstract

Claims (73)

1 . A system for computation scheduling based on an Industrial Internet of Things (IIoT) data center, comprising a management platform, the IIoT data center, and a plurality of data sub-platforms, wherein the management platform, the IIoT data center, and the plurality of data sub-platforms are in communication with each other, and the management platform is configured to:

obtain operational features of the plurality of data sub-platforms;

determine a first sub-platform and one or more second sub-platforms among the plurality of data sub-platforms based on the operational features;

determine at least one service to be split based on the operational features and service features corresponding to a plurality of services of the first sub-platform;

split the at least one service to be split into a plurality of sub-services based on at least one service feature corresponding to the at least one service to be split;

determine processing resource demands corresponding to the plurality of sub-services based on the at least one service feature corresponding to the at least one service to be split, the operational features, and sub-service features corresponding to the plurality of sub-services;

determine a service adjustment parameter based on the processing resource demands and the operational features; and

generate a service adjustment instruction based on the service adjustment parameter and send the service adjustment instruction to the first sub-platform and the one or more second sub-platforms;

use the first sub-platform to:

obtain a plurality of data packages by performing data processing on the plurality of sub-services based on the service adjustment instruction; and

send the plurality of data packages to the second sub-platform; and

use the one or more second sub-platforms to:

receive the plurality of data packages;

determine data volumes of the plurality of data packages by parsing the plurality of data packages;

obtain parsed data by allocating corresponding parsing memory for the plurality of data packages based on the data volumes and parsing the plurality of data packages;

establish processes corresponding to the plurality of sub-services based on the parsed data; and

determine processing resources for executing the processes based on the service adjustment instruction.

2 . The system of claim 1 , wherein the management platform is further configured to:

for a service to be split among the at least one service to be split:

obtain a plurality of candidate splitting schemes;

determine a target splitting scheme based on a plurality of data transmission durations and a plurality of service operation efficiencies corresponding to the plurality of candidate splitting schemes; and

obtain a plurality of sub-services corresponding to the service to be split by splitting the service to be split based on the target splitting scheme.

3 . The system of claim 2 , wherein the management platform is further configured to:

obtain the plurality of candidate splitting schemes by performing a plurality of splits on the service to be split through functional-item division and data-item division.

4 . The system of claim 1 , wherein the management platform is further configured to:

determine a plurality of candidate allocation relationships based on the processing resource demands and the operational features, and determine predicted operational information corresponding to the plurality of candidate allocation relationships;

determine a target allocation relationship based on the predicted operational information; and

determine the service adjustment parameter based on the target allocation relationship.

5 . A method for computation scheduling based on an Industrial Internet of Things (IIoT) data center, the method being executed by a management platform and method comprising:

obtaining operational features of a plurality of data sub-platforms;

determining a first sub-platform and one or more second sub-platforms among the plurality of data sub-platforms based on the operational features;

determining at least one service to be split based on the operational features and service features corresponding to a plurality of services of the first sub-platform

splitting the at least one service to be split into a plurality of sub-services based on at least one service feature corresponding to the at least one service to be split;

determining processing resource demands corresponding to the plurality of sub-services based on the at least one service feature corresponding to the at least one service to be split, the operational features, and sub-service features corresponding to the plurality of sub-services;

determining a service adjustment parameter based on the processing resource demands and the operational features;

generating a service adjustment instruction based on the service adjustment parameter and sending the service adjustment instruction to the first sub-platform and the one or more second sub-platforms;

using the first sub-platform to:

obtain a plurality of data packages by performing data processing on the plurality of sub-services based on the service adjustment instruction; and

send the plurality of data packages to the second sub-platform; and

using the one or more second sub-platforms to:

receive the plurality of data packages;

determine data volumes of the plurality of data packages by parsing the plurality of data packages;

obtain parsed data by allocating corresponding parsing memory for the plurality of data packages based on the data volumes and parsing the plurality of data packages;

establish processes corresponding to the plurality of sub-services based on the parsed data; and

determine processing resources for executing the processes based on the service adjustment instruction.

6 . The method of claim 5 , wherein the splitting the at least one service to be split into a plurality of sub-services based on at least one service feature corresponding to the at least one service to be split includes:

for a service to be split among the at least one service to be split:

obtaining a plurality of candidate splitting schemes;

determining a target splitting scheme based on a plurality of data transmission durations and a plurality of service operation efficiencies corresponding to the plurality of candidate splitting schemes; and

obtaining a plurality of sub-services corresponding to the service to be split by splitting the service to be split based on the target splitting scheme.

7 . The method of claim 6 , wherein the obtaining a plurality of candidate splitting schemes includes:

obtaining the plurality of candidate splitting schemes by performing a plurality of splits on the service to be split through functional-item division and data-item division.

8 . The method of claim 5 , wherein the determining a service adjustment parameter based on the processing resource demands and the operational features includes:

determining a plurality of candidate allocation relationships based on the processing resource demands and the operational features, and determining predicted operational information corresponding to the plurality of candidate allocation relationships;

determining a target allocation relationship based on the predicted operational information; and

determining the service adjustment parameter based on the target allocation relationship.

9 . A non-transitory computer-readable storage medium storing one or more sets of computer instructions, wherein when reading the one or more sets of computer instructions in the storage medium, a computer implements a method for computation scheduling based on an Industrial Internet of Things (IIoT) data center, the method is executed by a management platform, and method comprises:

obtaining operational features of a plurality of data sub-platforms;

determining a first sub-platform and one or more second sub-platforms among the plurality of data sub-platforms based on the operational features;

determining at least one service to be split based on the operational features and service features corresponding to a plurality of services of the first sub-platform;

splitting the at least one service to be split into a plurality of sub-services based on at least one service feature corresponding to the at least one service to be split;

determining processing resource demands corresponding to the plurality of sub-services based on the at least one service feature corresponding to the at least one service to be split, the operational features, and sub-service features corresponding to the plurality of sub-services;

determining a service adjustment parameter based on the processing resource demands and the operational features;

generating a service adjustment instruction based on the service adjustment parameter and sending the service adjustment instruction to the first sub-platform and the one or more second sub-platforms;

using the first sub-platform to:

obtain a plurality of data packages by performing data processing on the plurality of sub-services based on the service adjustment instruction; and

send the plurality of data packages to the second sub-platform; and

using the one or more second sub-platforms to:

receive the plurality of data packages;

determine data volumes of the plurality of data packages by parsing the plurality of data packages;

obtain parsed data by allocating corresponding parsing memory for the plurality of data packages based on the data volumes and parsing the plurality of data packages;

establish processes corresponding to the plurality of sub-services based on the parsed data; and

determine processing resources for executing the processes based on the service adjustment instruction.

Assignments (1)

Priority Claims (1)

Continuity (1)

References Cited (29)