[發(fā)明專利]用于調(diào)用數(shù)據(jù)的方法和裝置

在審

• 申請?zhí)枺?/td>: 201710233433.5
• 申請日: 2017-04-11
• 公開（公告）號: CN108694084A
• 公開（公告）日: 2018-10-23
• 發(fā)明（設(shè)計）人: 劉日新;王雅瑾
• 申請（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀貿(mào)易有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F17/30
• 代理公司: 北京英賽嘉華知識產(chǎn)權(quán)代理有限責任公司 11204
• 代理人: 王達佐;馬曉亞

1.一種用于調(diào)用數(shù)據(jù)的方法，其特征在于，所述方法包括：

獲取數(shù)據(jù)調(diào)用任務(wù)；

獲取所述數(shù)據(jù)調(diào)用任務(wù)所調(diào)用的數(shù)據(jù)庫的鎖；

獲取所述數(shù)據(jù)庫中各分庫所運行的任務(wù)執(zhí)行者的數(shù)量；

將所運行的任務(wù)執(zhí)行者的數(shù)量最少的分庫，確定為執(zhí)行任務(wù)的分庫；

將所述數(shù)據(jù)調(diào)用任務(wù)添加至所述執(zhí)行任務(wù)的分庫的任務(wù)隊列中。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

若所述執(zhí)行任務(wù)的分庫執(zhí)行所述任務(wù)隊列中的任務(wù)完畢，將所述執(zhí)行任務(wù)的分庫從本地的數(shù)據(jù)庫中釋放。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述方法還包括：

執(zhí)行下一個任務(wù)隊列不為空的分庫的任務(wù)隊列中的任務(wù)。

4.根據(jù)權(quán)利要求1至3任意一項所述的方法，其特征在于，所述獲取所述數(shù)據(jù)調(diào)用任務(wù)所調(diào)用的數(shù)據(jù)庫的鎖包括：

在對應(yīng)所述數(shù)據(jù)庫的預(yù)定路徑下生成第一臨時節(jié)點；

在釋放鎖時刪除所述第一臨時節(jié)點。

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

在所述執(zhí)行任務(wù)的分庫執(zhí)行所述任務(wù)隊列中的任務(wù)時，獲取所述任務(wù)所要調(diào)用的表的鎖；

若所述任務(wù)調(diào)用所述表中的數(shù)據(jù)完畢，釋放所述表的鎖。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述獲取所述任務(wù)所要調(diào)用的表的鎖包括：

在對應(yīng)所述表的預(yù)設(shè)路徑下生成第二臨時節(jié)點；

在釋放所述表的鎖時刪除所述第二臨時節(jié)點。

7.根據(jù)權(quán)利要求1-6任意一項所述的方法，其特征在于，所述方法還包括：

采用分布式緩存記錄響應(yīng)于執(zhí)行所述任務(wù)隊列中的任務(wù)所進行的批次處理的數(shù)據(jù)記錄。

8.根據(jù)權(quán)利要求7所述的方法，其特征在于，所述方法還包括：

響應(yīng)于執(zhí)行所述任務(wù)隊列中的任務(wù)發(fā)生異常，在發(fā)生異常的任務(wù)中止后，調(diào)用所述任務(wù)隊列中的上一次任務(wù)所記錄的所述數(shù)據(jù)記錄，恢復(fù)任務(wù)運行狀態(tài)；和/或

響應(yīng)于接收對所述數(shù)據(jù)記錄的調(diào)整指令，調(diào)整所述數(shù)據(jù)記錄，執(zhí)行對應(yīng)調(diào)整后的所述數(shù)據(jù)記錄的任務(wù)。所述數(shù)據(jù)記錄的格式為：修改時間+主鍵。

9.一種用于調(diào)用數(shù)據(jù)的裝置，其特征在于，所述裝置包括：

任務(wù)獲取單元，用于獲取數(shù)據(jù)調(diào)用任務(wù)；

數(shù)據(jù)庫鎖獲取單元，用于獲取所述數(shù)據(jù)調(diào)用任務(wù)所調(diào)用的數(shù)據(jù)庫的鎖；

數(shù)量獲取單元，用于獲取所述數(shù)據(jù)庫中各分庫所運行的任務(wù)執(zhí)行者的數(shù)量；

分庫確定單元，用于將所運行的任務(wù)執(zhí)行者的數(shù)量最少的分庫，確定為執(zhí)行任務(wù)的分庫；

任務(wù)添加單元，用于將所述數(shù)據(jù)調(diào)用任務(wù)添加至所述執(zhí)行任務(wù)的分庫的任務(wù)隊列中。

10.根據(jù)權(quán)利要求9所述的裝置，其特征在于，所述裝置還包括：

數(shù)據(jù)庫釋放單元，用于若所述執(zhí)行任務(wù)的分庫執(zhí)行所述任務(wù)隊列中的任務(wù)完畢，將所述執(zhí)行任務(wù)的分庫從本地的數(shù)據(jù)庫中釋放。

11.根據(jù)權(quán)利要求10所述的裝置，其特征在于，所述裝置還包括：

任務(wù)執(zhí)行單元，用于執(zhí)行下一個任務(wù)隊列不為空的分庫的任務(wù)隊列中的任務(wù)。

12.根據(jù)權(quán)利要求9至11任意一項所述的裝置，其特征在于，所述數(shù)據(jù)庫鎖獲取單元進一步用于：

在對應(yīng)所述數(shù)據(jù)庫的預(yù)定路徑下生成第一臨時節(jié)點；

在釋放鎖時刪除所述第一臨時節(jié)點。

13.根據(jù)權(quán)利要求9所述的裝置，其特征在于，所述裝置還包括：

表的鎖獲取單元，用于在所述執(zhí)行任務(wù)的分庫執(zhí)行所述任務(wù)隊列中的任務(wù)時，獲取所述任務(wù)所要調(diào)用的表的鎖；

表的鎖釋放單元，用于若所述任務(wù)調(diào)用所述表中的數(shù)據(jù)完畢，釋放所述表的鎖。