[發明專利]一種多域數據融合的方法、裝置和存儲介質

在審

• 申請號: 202210573368.1
• 申請日: 2022-05-25
• 公開（公告）號: CN115033590A
• 公開（公告）日: 2022-09-09
• 發明（設計）人: 林文楷;周成祖;魏超;吳文;朱海勇
• 申請（專利權）人: 廈門市美亞柏科信息股份有限公司
• 主分類號: G06F16/242
• 分類號: G06F16/242;G06F16/2455;G06F16/25
• 代理公司: 廈門市精誠新創知識產權代理有限公司 35218
• 代理人: 汪萬龍

1.一種多域數據融合的方法，用于使用多個域的數據來執行處理任務，其特征在于，包括：

S1，在預先設置的多域調度融合區建立任務規則庫，所述任務規則庫包括：待處理任務的標識、與所述待處理任務相關的數據源、與各數據源相關的多個數據域、與各數據域對應的執行引擎；

S2，提取所述任務規則庫中選定的所有任務，針對選定的每一任務確定對應的數據域組及對應的執行引擎組，并獲得與同一數據域相關的任務集合；

S3，根據預先設置的任務優先級對與所述同一數據域相關的任務集合中的任務進行調度，優先調用與優先級較高的任務對應的執行引擎；

S4，針對選定的所述每一任務，將對應的執行引擎組中的各執行引擎從對應數據域返回的任務結果存儲到所述多域調度融合區，并在所述多域調度融合區進行融合，獲得融合結果。

2.根據權利要求1的方法，其特征在于，所述步驟S2包括：

提取所述任務規則庫中所述選定的所有任務，形成待處理任務數據集Sn，并新建歸一任務數據集合Tn；

遍歷所述Sn，獲得與各任務相關的數據源所對應的數據域組及對應的執行引擎組list(clyc)，并根據所述執行引擎組list(clyc)將所述Sn拆分存儲到Tn，其中Tn＝{Sn,list(clyc)}；

遍歷所述Tn，根據執行引擎對所述Tn中的記錄進行聚合，將同一數據域的任務進行合并，獲得與同一數據域相關的任務集合。

3.根據權利要求1的方法，其特征在于，所述S3包括：

根據所述多域調度融合區分配的硬件資源確定最大的處理線程數m，m為大于0的自然數；

根據預先設置的優先級，對所述與同一數據域相關的任務集合中的任務進行排序，依次取優先級較高的m條任務；

調用與所述m條任務對應的執行引擎進行數據處理。

4.根據權利要求1的方法，其特征在于，在所述S2之后、所述S3之前，還包括：

對所述與同一數據域相關的任務集合中的任務進行驗證；如果驗證通過，將對應任務的任務狀態設置為可用；否則，將對應任務的任務狀態設置為不可用；

所述S3中，參與任務調度的任務為所述與同一數據域相關的任務集合中任務狀態可用的任務。

5.根據權利要求4的方法，其特征在于，對任務進行驗證的步驟包括：

調用待驗證任務對應的執行引擎，如果執行引擎返回結果的為0，則進行重試，且重試次數加1；如果重試次數達到預定閾值時，返回結果仍為0，則將任務狀態設置為不可用；如果執行引擎返回結果的為1，則驗證通過，將任務狀態設置為可用。

6.根據權利要求1的方法，其特征在于，返回的任務結果的格式由對應的執行引擎動態定義。

7.根據權利要求1的方法，其特征在于，根據預先設置的數據分類設置所述融合結果的保存時限。

8.根據權利要求1的方法，其特征在于，還包括根據任務來源和任務分級對所述融合結果進行過濾，并將過濾后的結果分發給任務來源方。

9.根據權利要求1的方法，其特征在于，還包括：在分發完成后，將對應任務銷毀的步驟。

10.一種多域數據融合的裝置，其特征在于，包括存儲器和處理器，存儲器存儲有至少一段程序，至少一段程序由處理器執行以實現如權利要求1至9中任一項所述的多域數據融合的方法。

11.一種計算機可讀存儲介質，其特征在于，存儲介質中存儲有至少一段程序，至少一段程序由處理器執行以實現如權利要求1至9中任一項所述的多域數據融合的方法。