[發(fā)明專利]一種基于數(shù)據(jù)庫分區(qū)的數(shù)據(jù)更新方法、裝置及系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202010762855.3
• 申請日: 2020-07-31
• 公開（公告）號: CN113297232A
• 公開（公告）日: 2021-08-24
• 發(fā)明（設(shè)計）人: 張浩然;潘岳
• 申請（專利權(quán)）人: 阿里巴巴集團(tuán)控股有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/22
• 代理公司: 北京博思佳知識產(chǎn)權(quán)代理有限公司 11415
• 代理人: 周嗣勇

1.一種基于數(shù)據(jù)庫分區(qū)的數(shù)據(jù)更新方法，應(yīng)用于包括數(shù)據(jù)接收單元和數(shù)據(jù)更新單元的系統(tǒng)，所述方法包括：

數(shù)據(jù)接收單元，持續(xù)性接收待更新數(shù)據(jù)，將接收到的待更新數(shù)據(jù)寫入臨時存儲位置，并確定每條待更新數(shù)據(jù)所對應(yīng)的更新目標(biāo)分區(qū)；

數(shù)據(jù)更新單元，針對任一更新目標(biāo)分區(qū)，在預(yù)設(shè)的更新時間點(diǎn)執(zhí)行以下操作：

確定對應(yīng)于該分區(qū)的待更新數(shù)據(jù)量；

判斷所述待更新數(shù)據(jù)量是否達(dá)到對應(yīng)于該分區(qū)的預(yù)設(shè)閾值；

若待更新數(shù)據(jù)量達(dá)到預(yù)設(shè)閾值，則在當(dāng)前時間點(diǎn)執(zhí)行針對該分區(qū)的數(shù)據(jù)更新操作。

2.根據(jù)權(quán)利要求1所述的方法，所述針對該分區(qū)的數(shù)據(jù)更新操作，包括：

讀取該分區(qū)內(nèi)的全量數(shù)據(jù)，利用對應(yīng)于該分區(qū)的待更新數(shù)據(jù)對讀取到的全量數(shù)據(jù)進(jìn)行更新，得到更新結(jié)果；將更新結(jié)果以替換方式寫入該分區(qū)；刪除臨時存儲位置中對應(yīng)于該分區(qū)的待更新數(shù)據(jù)。

3.根據(jù)權(quán)利要求1所述的方法，還包括：

若所述待更新數(shù)據(jù)量未達(dá)到預(yù)設(shè)閾值，則在當(dāng)前時間點(diǎn)不執(zhí)行針對該分區(qū)的數(shù)據(jù)更新操作。

4.根據(jù)權(quán)利要求1所述的方法，還包括：

所述數(shù)據(jù)更新單元，針對任一分區(qū)，根據(jù)該分區(qū)中全量數(shù)據(jù)的數(shù)據(jù)量動態(tài)調(diào)整對應(yīng)于該分區(qū)預(yù)設(shè)閾值。

5.根據(jù)權(quán)利要求1所述的方法，還包括：

所述數(shù)據(jù)更新單元，在待更新數(shù)據(jù)量未達(dá)到預(yù)設(shè)閾值的情況下，進(jìn)一步確定臨時存儲位置中，對應(yīng)于該分區(qū)的待更新數(shù)據(jù)存儲時長是否超時；

在確定超時的情況下，在當(dāng)前時間點(diǎn)執(zhí)行針對該分區(qū)的數(shù)據(jù)更新操作。

6.根據(jù)權(quán)利要求1所述的方法，還包括：

所述數(shù)據(jù)更新單元，為不同的分區(qū)配置統(tǒng)一的更新時間點(diǎn)、或者為不同的分區(qū)分別配置更新時間點(diǎn)。

7.根據(jù)權(quán)利要求6所述的方法，在為不同的分區(qū)配置統(tǒng)一的更新時間點(diǎn)的情況下，所述方法還包括：

所述數(shù)據(jù)更新單元，在待更新數(shù)據(jù)量未達(dá)到預(yù)設(shè)閾值的情況下，進(jìn)一步確定當(dāng)前時間點(diǎn)需要讀取的分區(qū)數(shù)量是否達(dá)到預(yù)設(shè)數(shù)量；

在未達(dá)到預(yù)設(shè)數(shù)量的情況下，則在當(dāng)前時間點(diǎn)執(zhí)行針對該分區(qū)的數(shù)據(jù)更新操作。

8.一種基于數(shù)據(jù)庫分區(qū)的數(shù)據(jù)更新裝置，包括：

數(shù)據(jù)接收單元，用于持續(xù)性接收待更新數(shù)據(jù)，將接收到的待更新數(shù)據(jù)寫入臨時存儲位置，并確定每條待更新數(shù)據(jù)所對應(yīng)的更新目標(biāo)分區(qū)；

數(shù)據(jù)更新單元，用于針對任一更新目標(biāo)分區(qū)，在預(yù)設(shè)的更新時間點(diǎn)執(zhí)行以下操作：

確定對應(yīng)于該分區(qū)的待更新數(shù)據(jù)量；

判斷所述待更新數(shù)據(jù)量是否達(dá)到對應(yīng)于該分區(qū)的預(yù)設(shè)閾值；

在待更新數(shù)據(jù)量達(dá)到預(yù)設(shè)閾值的情況下，在當(dāng)前時間點(diǎn)執(zhí)行針對該分區(qū)的數(shù)據(jù)更新操作。

9.根據(jù)權(quán)利要求8所述的裝置，

所述數(shù)據(jù)更新單元，具體用于在待更新數(shù)據(jù)量達(dá)到預(yù)設(shè)閾值的情況下，讀取該分區(qū)內(nèi)的全量數(shù)據(jù)，利用對應(yīng)于該分區(qū)的待更新數(shù)據(jù)對讀取到的全量數(shù)據(jù)進(jìn)行更新，得到更新結(jié)果；將更新結(jié)果以替換方式寫入該分區(qū)；刪除臨時存儲位置中對應(yīng)于該分區(qū)的待更新數(shù)據(jù)。

10.根據(jù)權(quán)利要求8所述的裝置，

所述數(shù)據(jù)更新單元，還用于在待更新數(shù)據(jù)量未達(dá)到預(yù)設(shè)閾值的情況下，在當(dāng)前時間點(diǎn)不執(zhí)行針對該分區(qū)的數(shù)據(jù)更新操作。

11.根據(jù)權(quán)利要求8所述的裝置，

所述數(shù)據(jù)更新單元，還用于針對任一分區(qū)，根據(jù)該分區(qū)中全量數(shù)據(jù)的數(shù)據(jù)量動態(tài)調(diào)整對應(yīng)于該分區(qū)預(yù)設(shè)閾值。

12.根據(jù)權(quán)利要求8所述的裝置，

所述數(shù)據(jù)更新單元，還用于在待更新數(shù)據(jù)量未達(dá)到預(yù)設(shè)閾值的情況下，進(jìn)一步確定臨時存儲位置中，對應(yīng)于該分區(qū)的待更新數(shù)據(jù)存儲時長是否超時；

在確定超時的情況下，在當(dāng)前時間點(diǎn)執(zhí)行針對該分區(qū)的數(shù)據(jù)更新操作。