[發明專利]一種任務處理方法及裝置

有效

• 申請號: 201310616600.6
• 申請日: 2013-11-27
• 公開（公告）號: CN103617493A
• 公開（公告）日: 2014-03-05
• 發明（設計）人: 王風雨;劉雪松;謝迎新;李曉珍;楊麗芳;伍亮
• 申請（專利權）人: 北京國電通網絡技術有限公司;北京中電飛華通信股份有限公司;國家電網公司
• 主分類號: G06Q10/06
• 分類號: G06Q10/06
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 王寶筠

技術領域

本申請涉及智能電網技術領域，特別是涉及一種任務處理方法及裝置。

背景技術

智能用電是構建堅強智能電網的重要支柱和六大環節之一，是實現堅強智能電網各項功能的基礎和物理載體，是建設堅強智能電網的著力點和落腳點。

智能用電根據業務場景以及時間尺度的不同分為即時處理和智能分析兩種數據處理方式，即時處理致力于對實時數據、事件流的處理，保證處理的即時性，適用于智能用電領域的在線事件監控與實時決策業務；智能分析則關注海量歷史數據的高度挖掘，由于其分析復雜性，往往需要一定時間完成分析，適用于智能用電領域的事后診斷處理和深度利用業務。

也正因為即時處理一般支持多事件信息流上復雜的在線檢測、分析和即時決策，不能充分利用歷史數據的潛在知識，而智能分析系統在進行業務處理時，由于數據量大、算法復雜，其相應分析處理時間較長，不能做到即請求即顯示，導致兩者不能進行有效調度和數據交互，進而導致不能保證智能用電在多時間尺度以及業務場景處理過程中的時效性和準確性。

發明內容

有鑒于此，本申請實施例提供一種任務處理方法及裝置，以解決現有技術智能用電過程中，即時處理與智能分析不能進行有效調度和數據交互，進而導致不能保證智能用電在多時間尺度以及業務場景處理過程中的時效性和準確性的問題。

為了實現上述目的，本申請實施例提供的技術方案如下：

一種任務處理方法，包括：

響應任務請求信號，分別在第一數據庫和/或第二數據庫中獲取與所述任務請求信號相對應的原始數據，其中，所述第一數據庫用于存儲實時數據，所述實時數據為即時處理模塊接收到的終端采集設備實時發送的數據，所述第二數據庫用于存儲所述即時處理模塊中的數據處理結果；

將所述原始數據轉換成目的數據，以控制所述智能分析模塊根據與所述任務請求信號相對應的算法對所述目的數據進行分析，得到分析結果，其中，所述目的數據符合智能分析模塊中對應任務請求信號的算法的算法要求；

將所述分析結果作為所述即時處理模塊的參考值，返回給所述即時處理模塊。

優選的，預先設置任務配置文件，所述任務配置文件中包括有至少一個任務以及分別與各個任務相關的屬性，所述屬性包括任務運行時間，

該方法還包括：

逐一判斷所述任務配置文件中的各個任務的屬性中的任務運行時間是否與系統當前運行時間相同；

當存在任務的任務運行時間與系統當前運行時間相同時，發送與所述任務相對應的任務請求信號。

優選的，所述屬性包括任務優先級，

該方法還包括：

當存在至少兩個任務的任務運行時間與系統當前運行時間相同時，發送與任務優先級高的任務相對應的任務請求信號。

優選的，將所述原始數據轉換成目的數據，其中，所述目的數據符合智能分析模塊中對應任務請求信號的算法的算法要求，包括：

根據智能分析模塊中對應所述任務請求信號的算法的算法要求，將所述原始數據進行匯總、過濾生成目的數據。

優選的，所述第一數據庫的生成過程為：

在所述任務配置文件中設定一個任務，以及與所述任務相關的屬性，所述屬性包括與即時處理模塊的存儲空間相對應的任務運行時間以及任務運行頻率；

根據所述任務運行時間以及任務運行頻率，獲取即時處理模塊中的實時數據；所述實時數據為所述即時處理模塊接收到的終端采集設備實時發送的數據；

將獲取到的所述實時數據進行存儲，生成第一數據庫。

優選的，所述第二數據庫的生成過程為：

在所述任務配置文件中設定一個任務，以及與所述任務相關的屬性，所述屬性包括任務運行時間、任務獲取范圍以及任務運行頻率，

根據所述任務運行時間以及任務運行頻率，獲取與所述任務獲取范圍相對應的即時處理模塊的數據處理結果；

將獲取到的所述數據處理結果進行存儲，生成第二數據庫。

優選的，還包括：設置有至少一個第二數據庫，所述每個數據庫分別用于存儲與不同的任務獲取范圍相對應的即時處理模塊的數據處理結果。

優選的，所述終端采集設備為可中斷終端采集設備和/或不可中斷終端采集設備。

一種任務處理裝置，包括：原始數據獲取模塊、控制分析模塊以及結果返回模塊，其中，