[發(fā)明專利]數(shù)據(jù)消費(fèi)方法及裝置

在審

• 申請?zhí)枺?/td>: 202011592829.7
• 申請日: 2020-12-29
• 公開（公告）號: CN112799799A
• 公開（公告）日: 2021-05-14
• 發(fā)明（設(shè)計(jì)）人: 張普;李翔遠(yuǎn)
• 申請（專利權(quán)）人: 杭州涂鴉信息技術(shù)有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 廣東君龍律師事務(wù)所 44470
• 代理人: 丁建春

1.一種數(shù)據(jù)消費(fèi)方法，其特征在于，所述方法包括：

計(jì)算引擎獲取多個(gè)子任務(wù)；

基于所述多個(gè)子任務(wù)向協(xié)調(diào)服務(wù)模塊發(fā)起主任務(wù)選舉，以使所述協(xié)調(diào)服務(wù)模塊從所述多個(gè)子任務(wù)中選舉出主任務(wù)；

所述計(jì)算引擎基于所述主任務(wù)制定的分配方案，從消息隊(duì)列為每一個(gè)子任務(wù)獲取所述分配方案指定的消息，使每一個(gè)子任務(wù)對所述指定的消息進(jìn)行運(yùn)算處理。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述基于所述多個(gè)子任務(wù)向協(xié)調(diào)服務(wù)模塊發(fā)起主任務(wù)選舉，包括：

向所述協(xié)調(diào)服務(wù)模塊告知每個(gè)子任務(wù)的特征和所在區(qū)域；

所述方法還包括：所述主任務(wù)基于從所述協(xié)調(diào)服務(wù)模塊獲取的所述多個(gè)子任務(wù)的特征和所在區(qū)域以及消息隊(duì)列中消息的分布情況，確定每一個(gè)子任務(wù)所消費(fèi)的消息，以得到所述分配方案。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，全部子任務(wù)所在區(qū)域與其指定的消息所在區(qū)域相同。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述基于所述多個(gè)子任務(wù)向協(xié)調(diào)服務(wù)模塊發(fā)起主任務(wù)選舉，包括：

向所述協(xié)調(diào)服務(wù)模塊發(fā)送每一個(gè)子任務(wù)的注冊請求，以告知每一個(gè)子任務(wù)所屬的任務(wù)信息，使得所述協(xié)調(diào)服務(wù)模塊確認(rèn)獲取到所述任務(wù)的所有子任務(wù)的注冊請求時(shí)，從所有子任務(wù)中選舉出所述主任務(wù)。

5.一種數(shù)據(jù)消費(fèi)方法，其特征在于，所述方法包括：

響應(yīng)于所述計(jì)算引擎基于所述多個(gè)子任務(wù)向協(xié)調(diào)服務(wù)模塊發(fā)起的主任務(wù)選舉，所述協(xié)調(diào)服務(wù)模塊從所述多個(gè)子任務(wù)中選舉出主任務(wù)；

與所述計(jì)算引擎交互，以使所述主任務(wù)制定出分配方案，其中，所述分配方案為每一個(gè)子任務(wù)指定消息隊(duì)列中的消息。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述響應(yīng)于所述計(jì)算引擎基于所述多個(gè)子任務(wù)向協(xié)調(diào)服務(wù)模塊發(fā)起的主任務(wù)選舉，包括：

從所述計(jì)算引擎獲取每一個(gè)子任務(wù)的注冊請求，以獲取到每一個(gè)子任務(wù)所屬的任務(wù)的信息；

所述協(xié)調(diào)服務(wù)模塊確認(rèn)獲取到所述任務(wù)的所有子任務(wù)的注冊請求時(shí)，從所述任務(wù)的所有子任務(wù)中選舉出所述主任務(wù)。

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

從所述計(jì)算引擎獲取到所述分配方案，以使所述計(jì)算引擎上的每一個(gè)子任務(wù)能夠從所述協(xié)調(diào)服務(wù)模塊監(jiān)聽到所述分配方案，并從消息隊(duì)列中獲取所述分配方案為所述每一個(gè)子任務(wù)指定的消息。

8.一種數(shù)據(jù)處理系統(tǒng)，其特征在于，所述系統(tǒng)包括：

計(jì)算引擎，用于獲取多個(gè)子任務(wù)；基于所述多個(gè)子任務(wù)向協(xié)調(diào)服務(wù)模塊發(fā)起主任務(wù)選舉；基于主任務(wù)制定的分配方案，從消息隊(duì)列為每一個(gè)子任務(wù)獲取所述分配方案指定的消息，使每一個(gè)子任務(wù)對所述指定的消息進(jìn)行運(yùn)算處理；

所述協(xié)調(diào)服務(wù)模塊，用于響應(yīng)于所述計(jì)算引擎基于所述多個(gè)子任務(wù)向協(xié)調(diào)服務(wù)模塊發(fā)起的主任務(wù)選舉，所述協(xié)調(diào)服務(wù)模塊從所述多個(gè)子任務(wù)中選舉出主任務(wù)；與所述計(jì)算引擎交互，以使所述主任務(wù)制定出分配方案。

9.一種電子設(shè)備，其特征在于，所述電子設(shè)備包括處理器；所述處理器用于執(zhí)行指令以實(shí)現(xiàn)如權(quán)利要求1-7任一項(xiàng)所述的方法。

10.一種計(jì)算機(jī)可讀存儲介質(zhì)，其特征在于，所述計(jì)算機(jī)存儲介質(zhì)用于存儲指令/程序數(shù)據(jù)，指令/程序數(shù)據(jù)能夠被執(zhí)行以實(shí)現(xiàn)權(quán)利要求1-7中任一項(xiàng)所述的方法。