[發(fā)明專利]實時任務的數(shù)據(jù)校準方法及裝置

在審

• 申請?zhí)枺?/td>: 201711447741.4
• 申請日: 2017-12-27
• 公開（公告）號: CN108038085A
• 公開（公告）日: 2018-05-15
• 發(fā)明（設計）人: 楊鵬;黃凌染;黃曉鵬;張穎;潘浩;趙子穎;謝安濤
• 申請（專利權）人: 世紀龍信息網(wǎng)絡有限責任公司
• 主分類號: G06F17/18
• 分類號: G06F17/18;G06Q30/02
• 代理公司: 廣州華進聯(lián)合專利商標代理有限公司 44224
• 代理人: 周清華

本發(fā)明公開了一種實時任務的數(shù)據(jù)校準方法，包括步驟：對實時任務的多個歷史實時數(shù)據(jù)進行分時間段的離線計算，得到與各時間段對應的離線計算結(jié)果；根據(jù)離線計算結(jié)果，對實時任務在當前時間段內(nèi)的實時數(shù)據(jù)結(jié)果進行校準處理，得到實時任務在當前時間段內(nèi)的展示數(shù)據(jù)結(jié)果。本發(fā)明實施例還公開了一種實時任務的數(shù)據(jù)校準裝置。上述技術方案中的一個技術方案通過對實時任務在當前時間段之前的歷史實時數(shù)據(jù)進行分時間段的離線計算處理，得到對應各時間段的離線計算結(jié)果；調(diào)用離線計算結(jié)果對當前時間段內(nèi)的實時數(shù)據(jù)結(jié)果進行校準處理得到實時任務用于當前時間段的展示數(shù)據(jù)結(jié)果。從而實現(xiàn)實時展示的數(shù)據(jù)結(jié)果更準確的目的，用戶體驗更好。

技術領域

本發(fā)明涉及實時數(shù)據(jù)計算技術領域，特別是涉及一種實時任務的數(shù)據(jù)校準方法及裝置。

背景技術

隨著現(xiàn)代商業(yè)和信息化的發(fā)展，對于數(shù)據(jù)的計算處理要求，例如數(shù)據(jù)處理速度、處理規(guī)模以及處理的精度等方面，都在逐步提高。對于互聯(lián)網(wǎng)+商業(yè)的場合，例如商場或者網(wǎng)站等，通常會需要及時掌握用戶量、交易量、偏好數(shù)據(jù)或者點擊量等關鍵數(shù)據(jù)情況，以便及時進行決策調(diào)整。為了獲得及時的關鍵數(shù)據(jù)反饋，主流的技術是通過實時任務系統(tǒng)，例如Storm(分布式實時平臺)流計算框架進行實時計算，以得到所需的關鍵數(shù)據(jù)反饋。然而，傳統(tǒng)的實時任務系統(tǒng)中的數(shù)據(jù)由于存在短暫的延時性，以及計算框架可能出現(xiàn)任務崩潰的異常，從而，得到實際計算結(jié)果存在偏差。

發(fā)明內(nèi)容

基于上述分析，有必要針對傳統(tǒng)的實時任務系統(tǒng)所得實際計算結(jié)果存在偏差的問題，提供一種實時任務的數(shù)據(jù)校準方法以及一種實時任務的數(shù)據(jù)校準裝置。

本發(fā)明實施例提供一種實時任務的數(shù)據(jù)校準方法，包括步驟：

對實時任務的多個歷史實時數(shù)據(jù)進行分時間段的離線計算，得到與各時間段對應的離線計算結(jié)果；

根據(jù)所述離線計算結(jié)果，對所述實時任務在當前時間段內(nèi)的實時數(shù)據(jù)結(jié)果進行校準處理，得到所述實時任務在當前時間段內(nèi)的展示數(shù)據(jù)結(jié)果。

在其中一個實施例中，根據(jù)所述離線計算結(jié)果，對所述實時任務在當前時間段內(nèi)的實時數(shù)據(jù)結(jié)果進行校準處理，得到所述實時任務在當前時間段內(nèi)的展示數(shù)據(jù)結(jié)果的步驟前，還包括步驟：

根據(jù)所述當前時間段內(nèi)的實時數(shù)據(jù)結(jié)果，確定所述實時任務的執(zhí)行狀態(tài)；

根據(jù)所述執(zhí)行狀態(tài)確定所述校準處理的預定方案；其中，所述預定方案包括結(jié)合處理或數(shù)據(jù)預測模擬處理。

在其中一個實施例中，所述展示數(shù)據(jù)結(jié)果包括校準數(shù)據(jù)結(jié)果；

根據(jù)所述離線計算結(jié)果，對所述實時任務在當前時間段內(nèi)的實時數(shù)據(jù)結(jié)果進行校準處理，得到所述實時任務在當前時間段內(nèi)的展示數(shù)據(jù)結(jié)果的步驟中，包括：

在確定所述實時任務的執(zhí)行狀態(tài)為正常狀態(tài)時，對上一時間段的所述離線計算結(jié)果與所述當前時間段內(nèi)的實時數(shù)據(jù)結(jié)果進行結(jié)合處理，得到所述校準數(shù)據(jù)結(jié)果。

在其中一個實施例中，所述結(jié)合處理包括指標直接加和處理或指標凈值加和處理。

在其中一個實施例中，所述展示數(shù)據(jù)結(jié)果包括模擬數(shù)據(jù)結(jié)果；

根據(jù)所述離線計算結(jié)果，對所述實時任務在當前時間段內(nèi)的實時數(shù)據(jù)結(jié)果進行校準處理，得到所述實時任務在當前時間段內(nèi)的展示數(shù)據(jù)結(jié)果的步驟中，還包括：

獲取所述當前時間段前的各時間段校準后的所述實時數(shù)據(jù)結(jié)果；其中，校準后的所述實時數(shù)據(jù)結(jié)果為根據(jù)所述各時間段對應的離線計算結(jié)果，對對應的所述各時間段內(nèi)的所述實時數(shù)據(jù)結(jié)果進行校準，得到校準后的所述實時數(shù)據(jù)結(jié)果；

在確定所述實時任務的執(zhí)行狀態(tài)為異常狀態(tài)時，根據(jù)各校準后的所述實時數(shù)據(jù)結(jié)果進行數(shù)據(jù)預測模擬處理，得到所述模擬數(shù)據(jù)結(jié)果。

在其中一個實施例中，所述時間段的時長大于或等于15分鐘。