[發明專利]基于云計算和醫療大數據的任務處理優化系統

在審

• 申請號: 202010556625.1
• 申請日: 2020-06-17
• 公開（公告）號: CN111694651A
• 公開（公告）日: 2020-09-22
• 發明（設計）人: 孔德貴
• 申請（專利權）人: 孔德貴
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種基于云計算和醫療大數據的任務處理優化系統，所述任務處理優化系統包括多個任務接收終端、任務屬性分析引擎、任務分發組件；

其特征在于：

所述多個任務接收終端接收多個包含醫療數據流的并發數據處理任務，并將所述并發數據處理任務以數據流為單位存儲到任務接收隊列中，每個單位的數據流包含時間上連續的數據處理任務；

所述任務屬性分析引擎，從所述任務接收隊列中以數據流為單位獲取單位數據流處理任務，并分析得到所述數單位數據流處理任務的屬性，所述屬性包括所述單位數據流處理任務的數據量大小、處理時限以及失效時限；

所述任務處理優化系統還包括多個邊緣計算終端以及通過局域網連接至所述多個邊緣計算終端的多個霧計算處理設備；

所述任務分發組件基于所述任務屬性分析引擎分析得到的所述數據處理任務的屬性，將所述并發數據處理任務分發給所述多個邊緣計算終端以及通過局域網連接至所述多個邊緣計算終端的多個霧計算處理設備；

其中，所述任務接收隊列設置任務隊列接受上限值；

當所述并發數據處理任務的數據流單位超過所述上限值時，所述任務接收終端接收所述并發數據處理任務之后，直接將其轉發給遠端云數據處理系統。

2.如權利要求1所述的一種基于云計算和醫療大數據的任務處理優化系統，其特征在于：

所述多個任務接收終端接收多個包含醫療數據流的并發數據處理任務，并將所述并發數據處理任務以數據流為單位存儲到任務接收隊列中，具體包括：

對于在時間段[t_a,t_z]內接收的第i個并發數據處理任務A_i，將所述時間段[t_a,t_z]劃分為n個相鄰的子時間段T_n；其中，對于n1的子時間段每一個子時間段，T_n的時間結束點與T_n+1的時間開始點之差大于預定時間長度值；

將所述發數據處理任務A_i按照所述每個子時間段T_n為單位進行切分，得到n個單位數據流處理任務A_i1，A_i2，…，A_in；

將所述n個單位數據流處理任務A_i1，A_i2，…，A_in存儲到所述任務接收隊列中。

3.如權利要求2所述的一種基于云計算和醫療大數據的任務處理優化系統，其特征在于：

所述任務分發組件基于所述任務屬性分析引擎分析得到的所述數據處理任務的屬性，將所述并發數據處理任務分發給所述多個邊緣計算終端以及通過局域網連接至所述多個邊緣計算終端的多個霧計算處理設備，具體包括如下步驟：

S1：獲取當前處于空閑狀態的霧計算處理設備的數量N_fog；

S2：從所述任務接收隊列中讀取H個單位數據流處理任務，分發給所述N_fog個處于空閑狀態的霧計算處理設備；

其中，

上式中，CT_in為第n個單位數據流處理任務A_in的處理時限；LT_in為第n個單位數據流處理任務A_in的失效時限；DA_in為第n個單位數據流處理任務A_in的數據量大小；表示向下取整；

S3：計算接收所述單位數據流處理任務的每一個當前霧計算處理設備的回報值；

S4：判斷所述回報值是否滿足預定條件，如果是，則繼續從所述任務接收隊列中讀取一個單位數據流處理任務分發給所述當前霧計算設備；返回步驟S3；

如果否，則返回步驟S1。