[發明專利]基于驅動節點的數據處理方法、系統、終端設備和存儲介質

在審

• 申請號: 201911128869.3
• 申請日: 2019-11-18
• 公開（公告）號: CN111061518A
• 公開（公告）日: 2020-04-24
• 發明（設計）人: 王海波;杜凱凱
• 申請（專利權）人: 智器云南京信息科技有限公司
• 主分類號: G06F9/445
• 分類號: G06F9/445;G06F9/448;G06F9/54
• 代理公司: 上海碩力知識產權代理事務所(普通合伙) 31251
• 代理人: 楊用玲

本發明提供了基于驅動節點的數據處理方法、系統、終端設備和存儲介質，其方法包括：根據數據分析需求在目標物理服務器上配置適配的驅動節點隊列；按照預設的驅動節點執行順序依次執行驅動節點隊列中的驅動節點；監聽驅動節點執行過程，根據數據分析任務獲取并儲存驅動節點執行任務完成后的執行結果。本發明在新增業務場景對應的業務分析需求的情景下，不需要額外編寫針對新增業務場景的程序代碼，就能夠實現快速、高效的數據分析。

技術領域

本發明涉及數據處理技術領域，尤指基于驅動節點的數據處理方法、系統、終端設備和存儲介質。

背景技術

隨著通信技術的不斷發展，需要對業務場景進行分析，業務場景包括但是不限于通話詳單分析，共同來往帳號分析，交易總額分析，同籍同旅同行分析，QQ共同好友分析，微信共同好友分析，通話次數分析，酒店伴隨分析，共同通話對象分析，交易總額分析，資金入向分析等等。

但是，往往在復雜的業務場景下，很難快速精準的分析出所期望的結果。現有技術采用的是根據客戶的業務需求，臨時編寫計算機程序代碼，然后再通過編寫好的計算機程序代碼針對該業務需求進行數據分析得到對應的分析結果。現有技術進行數據分析的方式，由于需要臨時編寫計算機程序代碼并安裝配置硬件，實時性較低，而且擴展性不高，對于不同的業務場景需要編寫配置對應的計算機程序代碼，不利于快速實現后續的數據分析。

因此，如何在新增業務場景對應的業務分析需求的情景下，不需要額外編寫針對新增業務場景的程序代碼，就能夠實現快速、高效的數據分析是亟需解決的問題。

發明內容

本發明的目的是提供基于驅動節點的數據處理方法、系統、終端設備和存儲介質，實現在新增業務場景對應的業務分析需求的情景下，不需要額外編寫針對新增業務場景的程序代碼，就能夠實現快速、高效的數據分析。

本發明提供的技術方案如下：

本發明提供一種基于驅動節點的數據處理方法，包括步驟：

根據數據分析需求在目標物理服務器上配置適配的驅動節點隊列；

按照預設的驅動節點執行順序依次執行所述驅動節點隊列中的驅動節點；

監聽驅動節點執行過程，根據數據分析任務獲取并儲存驅動節點執行任務完成后的執行結果。

進一步的，所述根據數據分析需求在目標物理服務器上配置適配的驅動節點隊列包括步驟：

在所述目標物理服務器上部署mongo數據庫；

根據預設驅動節點配置規則，在部署好所述mongo數據庫的目標物理服務器上配置適配于所述數據分析需求的驅動節點隊列；所述驅動節點隊列包括開始驅動節點、業務驅動節點和結束驅動節點。

進一步的，所述按照預設的驅動節點執行順序依次執行所述驅動節點隊列中的驅動節點包括步驟：

按照所述開始驅動節點、業務驅動節點和結束驅動節點排列所對應的先后順序依次執行所述驅動節點隊列中對應的驅動節點，且多個驅動節點隊列并行執行。

進一步的，所述監聽驅動節點執行過程，根據數據分析任務獲取并儲存驅動節點執行任務完成后的執行結果包括步驟：

獲取輸入的數據分析任務；

根據所述數據分析任務的任務類型，將所述數據分析任務調度對應的驅動節點執行監聽器監聽對應驅動節點的執行過程；

當所述數據分析任務是臨時任務時，從所述業務驅動節點處獲取其執行過程中產生的第一執行結果，并將所述第一執行結果儲存至緩存；所述第一執行結果包括圖表數據；