一種大數(shù)據(jù)平臺去中心化的調(diào)度和執(zhí)行方法、裝置

基本信息

申請?zhí)?/td> CN202011631395.7 申請日 -
公開(公告)號 CN112822250A 公開(公告)日 2021-05-18
申請公布號 CN112822250A 申請公布日 2021-05-18
分類號 H04L29/08 分類 電通信技術(shù);
發(fā)明人 王晟 申請(專利權(quán))人 鯨靈科技有限責任公司
代理機構(gòu) 南京蘇高專利商標事務(wù)所(普通合伙) 代理人 吳靜波
地址 225000 江蘇省揚州市邗江區(qū)瘦西湖路195號花都匯商務(wù)中心2號樓
法律狀態(tài) -

摘要

摘要 本發(fā)明公開了一種大數(shù)據(jù)平臺去中心化的任務(wù)調(diào)度觸發(fā)和執(zhí)行方法,若干個調(diào)度觸發(fā)模塊以進程為單位分布在ZooKeeper集群中同時運行、調(diào)度觸發(fā)模塊將被調(diào)度大數(shù)據(jù)計算任務(wù)的META信息寫入ZooKeeper集群、任務(wù)執(zhí)行模塊以進程為單位,分布在ZooKeeper集群多個ZNode節(jié)點中運行、任務(wù)執(zhí)行模塊從ZooKeeper的ZNode樹上進行依次遍歷;當發(fā)現(xiàn)某個子過程具備執(zhí)行條件時,鎖定該任務(wù)、獲取任務(wù)信息,執(zhí)行該任務(wù),并將任務(wù)的子過程執(zhí)行結(jié)果和狀態(tài)信息寫入MySQL的任務(wù)歷史、用戶通過WebSocket協(xié)議建立后端WEB模塊的連接,實時掌控ZooKeeper樹中記錄的所有任務(wù)的配置和狀態(tài)信息。