[發明專利]一種企業管理數據分析處理系統及其方法

在審

• 申請號: 201711218525.2
• 申請日: 2017-11-28
• 公開（公告）號: CN109840138A
• 公開（公告）日: 2019-06-04
• 發明（設計）人: 黃建;黃翔;黃東
• 申請（專利權）人: 廣州市東宏軟件科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種企業管理數據分析處理系統，其特征在于，包括：

待調度任務生成模塊，用于根據預先定義的任務參數將收集的數據生成待調度的任務；

待調度任務存儲模塊，用于存儲所述待調度任務生成模塊生成的待調度的任務；

任務調度模塊和任務處理模塊，所述任務調度模塊從所述待調度任務存儲模塊加載待調度的任務，并根據加載的任務的任務類型調用相應的任務處理模塊；

所述任務處理模塊根據所述任務中的分析需求生成相應的類結構化查詢語言HiveSQL語句向基于分布式計算Hadoop的數據倉庫服務器發送；在接收到所述服務器返回的數據后完成對所述任務的數據分析。

2.根據權利要求1所述的企業管理數據分析處理系統，其特征在于，所述任務調度模塊具體包括：主任務調度組件和從任務調度組件；

所述主任務調度組件用于從所述待調度任務存儲模塊加載待調度的任務，并根據加載的任務的任務類型調用相應的任務處理模塊；

所述從任務調度組件用于在所述主任務調度組件退出運行或者無法正常運行后，從所述待調度任務存儲模塊加載待調度的任務，并根據加載的任務的任務類型調用相應的任務處理模塊。

3.根據權利要求2所述的企業管理數據分析處理系統，其特征在于，還包括優先級隊列模塊，其中：

所述任務調度模塊還用于加載待調度的任務到調度棧后，將所述調度棧中任務執行時間到達的任務封裝到優先級對象中，將所述優先級對象發送到優先級隊列模塊；

所述優先級隊列模塊用于接收到優先級對象后，將該優先級對象的優先級與所述優先級隊列模塊中其它優先級對象的優先級進行比較，根據比較結果對該優先級對象進行排序；

所述任務調度模塊還用于從所述優先級隊列模塊中獲取優先級最高的優先級對象，并根據獲取的優先級對象中的任務的任務類型調用相應的任務處理模塊進行數據分析。

4.根據權利要求3所述的企業管理數據分析處理系統，其特征在于，所述優先級隊列模塊具體包括：主優先級隊列單元和從優先級隊列單元；以及

所述主任務調度組件還用于加載待調度的任務到調度棧后，將所述調度棧中任務執行時間到達的任務封裝到優先級對象中，并將所述優先級對象發送到所述主優先級隊列單元；

所述主優先級隊列單元用于接收到優先級對象后，將該優先級對象的優先級與所述主優先級隊列單元中其它優先級對象的優先級進行比較，根據比較結果對該優先級對象進行排序；

所述主任務調度組件還用于從所述主優先級隊列單元中獲取優先級最高的優先級對象，并根據獲取的優先級對象中的任務的任務類型調用相應的任務處理模塊進行數據分析；

所述從優先級隊列單元用于定時保持其數據與所述主優先級隊列單元中的數據的一致。

5.根據權利要求4所述的企業管理數據分析處理系統，其特征在于，

所述從任務調度組件還用于在所述主任務調度組件退出運行或者無法正常運行后，加載待調度的任務到調度棧，將所述調度棧中任務執行時間到達的任務封裝到優先級對象中，并將所述優先級對象發送到所述從優先級隊列單元；并從所述從優先級隊列單元中獲取優先級最高的優先級對象，并根據獲取的優先級對象中的任務的任務類型調用相應的任務處理模塊進行數據分析；

所述從優先級隊列單元還用于接收到優先級對象后，將該優先級對象的優先級與所述從優先級隊列單元中其它優先級對象的優先級進行比較，根據比較結果對該優先級對象進行排序。

6.根據權利要求5所述的企業管理數據分析處理系統，其特征在于，還包括：

任務管理模塊，用于接收定義的任務參數，并將所述任務參數發送給所述待調度任務生成模塊。