CN-122001931-A - Task data migration method, device, equipment, storage medium and program product

CN122001931ACN 122001931 ACN122001931 ACN 122001931ACN-122001931-A

Abstract

The application relates to the technical field of computers, and provides a task data migration method, a device, equipment, a storage medium and a program product, wherein the task data migration method applied to a first computing node comprises the steps of responding to a task data migration instruction, determining a task context of an appointed task in the task data migration instruction; the task context comprises at least one of an operation state, a data state, external dependence and a task identifier, generates a network watermark according to a global unique identifier of an appointed task, signature information of a first computing node and summary information based on the task context, modulates the task context based on the network watermark to obtain modulated data, and transmits the modulated data to a second computing node appointed in a task data migration instruction. According to the application, when the cross-node migration of the task data of the computing power network is completed, the migration information can be traced through the network watermark, and the security of the task data migration of the computing power network is effectively improved.

Inventors

Xu Tianni
ZHANG FENG
QIU QIN
SUN HONGJU
CHEN LINGHU

Assignees

中国移动通信集团有限公司
卓望数码技术（深圳）有限公司

Dates

Publication Date: 20260508
Application Date: 20260123

Claims (14)

1. A task data migration method, applied to a first computing node, the task data migration method comprising: Determining a task context of a designated task in a task data migration instruction in response to the task data migration instruction, wherein the task context comprises at least one of an operation state, a data state, external dependence and a task identifier; Generating a network watermark according to the global unique identifier of the appointed task, the signature information of the first computing node and the abstract information based on the task context; Modulating the task context based on the network watermark to obtain modulated data; And transmitting the modulated data to a second computing power node appointed in the task data migration instruction.
2. The task data migration method of claim 1, wherein the generating a network watermark from the globally unique identifier of the specified task, the signature information of the first computing node, and the digest information based on the task context comprises: generating a data identifier according to the global unique identifier of the appointed task, the signature information of the first computing node and the abstract information based on the task context; And generating a network watermark based on the data identifier.
3. The task data migration method of claim 1, wherein said transmitting said modulated data to a second computing node specified in said task data migration instruction comprises: Setting forward error correction codes, check codes, adding serial numbers and embedding synchronous beacons on the modulated data to obtain data to be transmitted; and transmitting the data to be transmitted to a second computing power node appointed in the task data migration instruction.
4. A task data migration method according to claim 3, wherein said transmitting said data to be transmitted to a second computing node specified in said task data migration instruction comprises: based on the network watermark, determining the data packet transmission sequence of each group of data in the data to be transmitted respectively; And transmitting the data packets of each group of data to a second computing node appointed in the task data migration instruction according to the corresponding data packet transmission sequence.
5. The task data migration method according to claim 1, wherein modulating the task context based on the network watermark to obtain modulated data comprises: Performing segmentation processing on the task context to obtain at least two task contexts Wen Pianduan; Performing sequence division on the network watermark to obtain watermark sequences with the same number as the task context fragments; and modulating each task context segment through one watermark sequence to obtain modulation data.
6. The task data migration method of claim 5, wherein said performing segmentation processing on the task context to obtain at least two task context segments comprises: packaging the task context into a data container; and carrying out segmentation processing on the data container to obtain at least two task context fragments.
7. A task data migration method, applied to a second computing node, the task data migration method comprising: receiving modulated data transmitted by a first computing node; performing data verification based on the modulation data to obtain a verification result; performing task recovery based on the modulation data under the condition that the verification result is passing verification; Wherein the modulation data is transmitted by the first computing node by: Determining a task context of a designated task in a task data migration instruction in response to the task data migration instruction, wherein the task context comprises at least one of an operation state, a data state, external dependence and a task identifier; Generating a network watermark according to the global unique identifier of the appointed task, the signature information of the first computing node and the abstract information based on the task context; Modulating the task context based on the network watermark to obtain modulated data; And transmitting the modulated data to a second computing power node appointed in the task data migration instruction.
8. A task data migration method, applied to a computing power network control node, the task data migration method comprising: acquiring resource state data of a first computing node, wherein the resource state data comprises at least one of CPU (Central processing Unit) idle rate, memory utilization rate and node load; determining a node availability score for the first computing node based on the resource status data; Issuing a task data migration instruction to the first computing node under the condition that the node availability score is lower than a preset score threshold value, wherein the task data migration instruction is used for indicating the first computing node to transmit a task context to a second computing node; after receiving the task data migration instruction, the first computing node executes the following steps: Determining a task context of a designated task in a task data migration instruction in response to the task data migration instruction, wherein the task context comprises at least one of an operation state, a data state, external dependence and a task identifier; Generating a network watermark according to the global unique identifier of the appointed task, the signature information of the first computing node and the abstract information based on the task context; Modulating the task context based on the network watermark to obtain modulated data; And transmitting the modulated data to a second computing power node appointed in the task data migration instruction.
9. A task data migration apparatus, comprising: the first determining module is used for responding to the task data migration instruction and determining a task context of a designated task in the task data migration instruction, wherein the task context comprises at least one of an operation state, a data state, an external dependency and a task identifier; the generation module is used for generating a network watermark according to the global unique identifier of the appointed task, the signature information of the first computing node and the abstract information based on the task context; The modulation module is used for modulating the task context based on the network watermark to obtain modulation data; and the transmission module is used for transmitting the modulated data to a second computing power node appointed in the task data migration instruction.
10. A task data migration apparatus, comprising: the receiving module is used for receiving the modulated data transmitted by the first computing node; the verification module is used for carrying out data verification based on the modulation data to obtain a verification result; the task recovery module is used for carrying out task recovery based on the modulation data under the condition that the verification result is passing verification; Wherein the modulation data is transmitted by the first computing node by: Determining a task context of a designated task in a task data migration instruction in response to the task data migration instruction, wherein the task context comprises at least one of an operation state, a data state, external dependence and a task identifier; Generating a network watermark according to the global unique identifier of the appointed task, the signature information of the first computing node and the abstract information based on the task context; Modulating the task context based on the network watermark to obtain modulated data; And transmitting the modulated data to a second computing power node appointed in the task data migration instruction.
11. A task data migration apparatus, comprising: the acquisition module is used for acquiring the resource state data of the first computing node; a second determining module configured to determine a node availability score for the first computing node based on the resource status data; The system comprises a first computing node, a sending module, a task data migration instruction, a second computing node and a task context management module, wherein the first computing node is used for acquiring a task context from the first computing node; after receiving the task data migration instruction, the first computing node executes the following steps: Determining a task context of a designated task in a task data migration instruction in response to the task data migration instruction, wherein the task context comprises at least one of an operation state, a data state, external dependence and a task identifier; Generating a network watermark according to the global unique identifier of the appointed task, the signature information of the first computing node and the abstract information based on the task context; Modulating the task context based on the network watermark to obtain modulated data; And transmitting the modulated data to a second computing power node appointed in the task data migration instruction.
12. An electronic device comprising a memory, a processor and a computer program stored on the memory and executable on the processor, wherein the processor implements the task data migration method of any one of claims 1 to 8 when the computer program is executed by the processor.
13. A storage medium being a non-transitory computer readable storage medium having stored thereon a computer program, which when executed by a processor implements a task data migration method according to any one of claims 1 to 8.
14. A computer program product comprising a computer program, characterized in that the computer program, when executed by a processor, implements the task data migration method of any one of claims 1 to 8.

Description

Task data migration method, device, equipment, storage medium and program product Technical Field The present application relates to the field of computer technologies, and in particular, to a task data migration method, apparatus, device, storage medium, and program product. Background With gradual deployment of a computing power network (Computing Force Network, CFN) as a novel infrastructure, computing power resources realize cross-regional and cross-node dynamic distribution, and computing tasks and data are frequently migrated among heterogeneous nodes, so that new challenges of data security and responsibility identification are brought. The traditional data tracing mechanism depends on log records, link signatures or static labels, and is difficult to adapt to a complex dynamic environment for real-time migration of computing tasks. Although the network watermarking technology can embed identification information in a data stream by a concealing means, the stream-level data tracking and tracing are realized. However, the existing watermarking technology is mainly oriented to fixed network topology and static flow scenes, and cannot effectively support challenges brought by dynamic migration of computing tasks, node isomerism and resource volatility. Therefore, the traditional data watermarking mechanism cannot be used for realizing the whole process credible tracing of the data transfer of the power network, and the security is low when the task data of the power network is transferred. Disclosure of Invention The present application is directed to solving at least one of the technical problems existing in the related art. Therefore, the application provides a task data migration method, device, equipment, storage medium and program product, which are used for solving the problem that the traditional data watermarking mechanism cannot be used for realizing the whole process credible tracing of the data stream of the computing power network, thereby improving the security of task data migration of the computing power network. According to an embodiment of the first aspect of the present application, a task data migration method is applied to a first computing node, and the task data migration method includes: Determining a task context of a designated task in a task data migration instruction in response to the task data migration instruction, wherein the task context comprises at least one of an operation state, a data state, external dependence and a task identifier; Generating a network watermark according to the global unique identifier of the appointed task, the signature information of the first computing node and the abstract information based on the task context; Modulating the task context based on the network watermark to obtain modulated data; And transmitting the modulated data to a second computing power node appointed in the task data migration instruction. According to one embodiment of the present application, the generating a network watermark according to the globally unique identifier of the specified task, the signature information of the first computing node, and the digest information based on the task context includes: generating a data identifier according to the global unique identifier of the appointed task, the signature information of the first computing node and the abstract information based on the task context; And generating a network watermark based on the data identifier. According to one embodiment of the present application, the transmitting the modulated data to the second computing power node specified in the task data migration instruction includes: Setting forward error correction codes, check codes, adding serial numbers and embedding synchronous beacons on the modulated data to obtain data to be transmitted; and transmitting the data to be transmitted to a second computing power node appointed in the task data migration instruction. According to one embodiment of the present application, the transmitting the data to be transmitted to the second computing power node specified in the task data migration instruction includes: based on the network watermark, determining the data packet transmission sequence of each group of data in the data to be transmitted respectively; And transmitting the data packets of each group of data to a second computing node appointed in the task data migration instruction according to the corresponding data packet transmission sequence. According to an embodiment of the present application, the modulating the task context based on the network watermark to obtain modulated data includes: Performing segmentation processing on the task context to obtain at least two task contexts Wen Pianduan; Performing sequence division on the network watermark to obtain watermark sequences with the same number as the task context fragments; and modulating each task context segment through one watermark sequence to obtain modulation data. According to