Data transmission method and apparatus, device, storage medium, and computer program product

Patent metadata

Field	Value
Publication number	US-12206583-B2
Application number	US-202217902522-A
Country	US
Kind code	B2
Filing date	Sep 2, 2022
Priority date	Nov 25, 2021
Publication date	Jan 21, 2025
Grant date	Jan 21, 2025

Abstract

A data transmission method and apparatus, an electronic device, a computer readable storage medium, and a computer program product are provided. The method includes: receiving to-be-transmitted data currently transmitted from a data source node; determining an average receiving interval and an average transmitting interval based on a historical data receiving interval and a historical data transmitting interval; determining the splitting transmission number based on the average receiving interval and the average transmitting interval; obtaining a plurality of data fragments based on a data size of the to-be-transmitted data and the splitting transmission number; and sequentially and uniformly transmitting the data fragments to a next-level node within a subsequent period with a duration being the average receiving interval.

First claim

What is claimed is:

1. A data transmission method, comprising:
receiving to-be-transmitted data currently transmitted from a data source node;
determining an average receiving interval and an average transmitting interval based on a historical data receiving interval and a historical data transmitting interval;
determining a splitting transmission number based on the average receiving interval and the average transmitting interval;
obtaining a plurality of data fragments based on a data size of the to-be-transmitted data and the splitting transmission number; and
sequentially and uniformly transmitting the data fragments to a next-level node within a subsequent period with a duration being the average receiving interval.

2. The method according to claim 1 , wherein obtaining the plurality of data fragments based on the data size of the to-be-transmitted data and the splitting transmission number comprises:
determining, in response to determining that there remains data failing to be transmitted before transmitting the to-be-transmitted data, total to-be-transmitted data based on a data size of the to-be-transmitted data and the remaining data; and
uniformly splitting the total to-be-transmitted data based on the splitting transmission number, to obtain a plurality of data fragments, each with an identical data size.

3. The method according to claim 2 , wherein the method further comprises:
retaining, in response to a data size of each of the data fragments exceeding a preset data size threshold, excess data exceeding the data size threshold as new remaining data for a next data transmission.

4. The method according to claim 3 , wherein the method further comprises:
initiating a request for increasing the data size threshold, in response to there being remaining data for a preset number of consecutive data transmissions and a data size of the remaining data showing an increasing trend; and
increasing, in response to receiving a feedback of granting the request for increasing the data size threshold, a current data size threshold by a preset increase amount to obtain a new data size threshold, such that subsequent data transmissions are performed based on the new data size threshold as an upper limit of data size of a data fragment.

5. The method according to claim 1 , wherein determining the average receiving interval and the average transmitting interval based on the historical data receiving interval and the historical data transmitting interval comprises:
acquiring actual data receiving intervals and actual data transmitting intervals of a preset number of data transmission tasks closest to a current moment;
computing an average value of receiving intervals corresponding to the preset number of actual data receiving intervals, to obtain the average receiving interval; and
computing an average value of transmitting intervals corresponding to the preset number of actual data transmitting intervals, to obtain the average transmitting interval.

6. The method according to claim 2 , wherein determining the average receiving interval and the average transmitting interval based on the historical data receiving interval and the historical data transmitting interval comprises:
acquiring actual data receiving intervals and actual data transmitting intervals of a preset number of data transmission tasks closest to a current moment;
computing an average value of receiving intervals corresponding to the preset number of actual data receiving intervals, to obtain the average receiving interval; and
computing an average value of transmitting intervals corresponding to the preset number of actual data transmitting intervals, to obtain the average transmitting interval.

7. The method according to claim 3 , wherein determining the average receiving interval and the average transmitting interval based on the historical data receiving interval and the historical data transmitting interval comprises:
acquiring actual data receiving intervals and actual data transmitting intervals of a preset number of data transmission tasks closest to a current moment;
computing an average value of receiving intervals corresponding to the preset number of actual data receiving intervals, to obtain the average receiving interval; and
computing an average value of transmitting intervals corresponding to the preset number of actual data transmitting intervals, to obtain the average transmitting interval.

8. The method according to claim 4 , wherein determining the average receiving interval and the average transmitting interval based on the historical data receiving interval and the historical data transmitting interval comprises:
acquiring actual data receiving intervals and actual data transmitting intervals of a preset number of data transmission tasks closest to a current moment;
computing an average value of receiving intervals corresponding to the preset number of actual data receiving intervals, to obtain the average receiving interval; and
computing an average value of transmitting intervals corresponding to the preset number of actual data transmitting intervals, to obtain the average transmitting interval.

9. A data transmission apparatus, comprising:
at least one processor; and
a memory storing instructions, wherein the instructions when executed by the at least one processor, cause the at least one processor to perform operations, the operations comprising:
receiving to-be-transmitted data currently transmitted from a data source node;
determining an average receiving interval and an average transmitting interval based on a historical data receiving interval and a historical data transmitting interval;
determining a splitting transmission number based on the average receiving interval and the average transmitting interval;
obtaining a plurality of data fragments based on a data size of the to-be-transmitted data and the splitting transmission number; and
sequentially and uniformly transmitting the data fragments to a next-level node in a subsequent period with a duration being the average receiving interval.

10. The apparatus according to claim 9 , wherein obtaining the plurality of data fragments based on the data size of the to-be-transmitted data and the splitting transmission number comprises:
determining, in response to determining that there remains data failing to be transmitted before transmitting the to-be-transmitted data, total to-be-transmitted data based on a data size of the to-be-transmitted data and the remaining data; and
uniformly splitting the total to-be-transmitted data based on the splitting transmission number, to obtain a plurality of data fragments, each with an identical data size.

11. The apparatus according to claim 10 , wherein the operations further comprise:
retaining, in response to a data size of each of the data fragments exceeding a preset data size threshold, excess data exceeding the data size threshold as new remaining data for a next data transmission.

12. The apparatus according to claim 11 , wherein the operations further comprise:
initiating a request for increasing the data size threshold, in response to there being remaining data for a preset number of consecutive data transmissions and a data size of the remaining data showing an increasing trend; and
increasing, in response to receiving a feedback of granting the request for increasing the data size threshold, a current data size threshold by a preset increase amount to obtain a new data size threshold, such that subsequent data transmissions are performed based on the new data size threshold as an upper limit of data size of a data fragment.

Assignees

• Beijing Baidu Netcom Sci & Tech Co Ltd

Inventors

• Wang Chenfei

Classifications

• H04L47/50

  Queue scheduling · CPC title

• H04L47/12 Primary

  Avoiding congestion; Recovering from congestion · CPC title