[發(fā)明專利]實時數(shù)據(jù)的計算方法及裝置

有效

• 申請?zhí)枺?/td>: 201710203803.0
• 申請日: 2017-03-30
• 公開（公告）號: CN107092522B
• 公開（公告）日: 2020-07-21
• 發(fā)明（設(shè)計）人: 何凱;程磊
• 申請（專利權(quán)）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48
• 代理公司: 北京博思佳知識產(chǎn)權(quán)代理有限公司 11415
• 代理人: 林祥

1.一種實時數(shù)據(jù)的計算方法，應(yīng)用于在線業(yè)務(wù)系統(tǒng)；其中，所述在線業(yè)務(wù)系統(tǒng)搭載了基于python語言的算法運行環(huán)境以及算法庫；所述方法包括：

在線業(yè)務(wù)系統(tǒng)從對接的實時數(shù)據(jù)處理平臺中獲取實時業(yè)務(wù)數(shù)據(jù)；其中，所述在線業(yè)務(wù)系統(tǒng)為與在線業(yè)務(wù)運營相關(guān)的業(yè)務(wù)系統(tǒng)；所述實時數(shù)據(jù)處理平臺為面向所述在線業(yè)務(wù)系統(tǒng)提供數(shù)據(jù)服務(wù)的業(yè)務(wù)平臺；

基于所述算法庫中的目標(biāo)算法為所述實時業(yè)務(wù)數(shù)據(jù)生成python計算任務(wù)；

基于預(yù)設(shè)的調(diào)度策略為所述python計算任務(wù)分配計算節(jié)點設(shè)備，并將所述python計算任務(wù)下發(fā)至所述計算節(jié)點設(shè)備進行執(zhí)行；

通過可視化界面輸出所述計算節(jié)點設(shè)備返回的所述python計算任務(wù)的計算結(jié)果。

2.根據(jù)權(quán)利要求1所述的方法，

不同的python計算任務(wù)的執(zhí)行邏輯互相隔離；以及，

不同的python計算任務(wù)被下發(fā)至不同的計算節(jié)點設(shè)備進行執(zhí)行。

3.根據(jù)權(quán)利要求1所述的方法，所述在線業(yè)務(wù)系統(tǒng)從對接的實時數(shù)據(jù)處理平臺中獲取實時業(yè)務(wù)數(shù)據(jù)，包括：

在線業(yè)務(wù)系統(tǒng)調(diào)用對接的實時數(shù)據(jù)處理平臺提供的數(shù)據(jù)訪問接口，訪問所述實時數(shù)據(jù)處理平臺中的實時業(yè)務(wù)數(shù)據(jù)；或者，

在線業(yè)務(wù)系統(tǒng)對接所述實時數(shù)據(jù)處理平臺的業(yè)務(wù)數(shù)據(jù)庫，從所述業(yè)務(wù)數(shù)據(jù)庫中讀取實時業(yè)務(wù)數(shù)據(jù)。

4.根據(jù)權(quán)利要求1所述的方法，還包括：

采集所述計算節(jié)點設(shè)備發(fā)送的心跳數(shù)據(jù)；

如果在預(yù)設(shè)的超時時長內(nèi)未采集到所述計算節(jié)點設(shè)備發(fā)送的心跳數(shù)據(jù)，將所述python計算任務(wù)切換至備用計算節(jié)點設(shè)備；以及，

生成與所述python計算任務(wù)切換相關(guān)的日志文件，并將生成的日志文件發(fā)送至與所述在線業(yè)務(wù)系統(tǒng)對接的監(jiān)控系統(tǒng)，以由所述監(jiān)控系統(tǒng)對所述日志文件進行異常分析，并在分析出所述python計算任務(wù)發(fā)生切換時向系統(tǒng)管理員發(fā)送告警提示。

5.根據(jù)權(quán)利要求1所述的方法，還包括：

監(jiān)控所述python計算任務(wù)的運行狀況；

基于監(jiān)控到的所述python計算任務(wù)的運行狀況生成對應(yīng)的日志文件，并將生成的日志文件發(fā)送至與所述在線業(yè)務(wù)系統(tǒng)對接的監(jiān)控系統(tǒng)，以由所述監(jiān)控系統(tǒng)對所述日志文件進行異常分析，并在分析出所述python計算任務(wù)存在異常時向系統(tǒng)管理員發(fā)送告警提示。

6.根據(jù)權(quán)利要求1所述的方法，所述目標(biāo)算法為深度學(xué)習(xí)算法；所述計算結(jié)果為基于深度學(xué)習(xí)算法對所述實時業(yè)務(wù)數(shù)據(jù)進行預(yù)測計算得到的預(yù)估數(shù)據(jù)指標(biāo)；

所述通過可視化界面輸出所述計算節(jié)點設(shè)備返回的計算結(jié)果，包括：

獲取與所述實時業(yè)務(wù)數(shù)據(jù)對應(yīng)的真實數(shù)據(jù)指標(biāo)；

通過可視化界面將所述真實數(shù)據(jù)指標(biāo)，以及所述計算節(jié)點設(shè)備返回的所述預(yù)估數(shù)據(jù)指標(biāo)關(guān)聯(lián)輸出，以在所述可視化界面中對所述真實數(shù)據(jù)指標(biāo)以及所述預(yù)估數(shù)據(jù)指標(biāo)進行對比展示。

7.根據(jù)權(quán)利要求1所述的方法，還包括以下步驟中的至少一個：

響應(yīng)于系統(tǒng)管理員的修改操作，對所述計算結(jié)果進行修改更新；

響應(yīng)于系統(tǒng)管理員的置頂操作，將與系統(tǒng)管理員選定的目標(biāo)python計算任務(wù)設(shè)置為置頂任務(wù)，并將所述目標(biāo)python計算任務(wù)對應(yīng)的計算結(jié)果在所述可視化界面置頂展示。

8.一種實時數(shù)據(jù)的計算裝置，應(yīng)用于在線業(yè)務(wù)系統(tǒng)；其中，所述在線業(yè)務(wù)系統(tǒng)搭載了基于python語言的算法運行環(huán)境以及算法庫；所述在線業(yè)務(wù)系統(tǒng)為與在線業(yè)務(wù)運營相關(guān)的業(yè)務(wù)系統(tǒng)；所述裝置包括：

獲取模塊，從對接的實時數(shù)據(jù)處理平臺中獲取實時業(yè)務(wù)數(shù)據(jù)；其中，所述實時數(shù)據(jù)處理平臺為面向所述在線業(yè)務(wù)系統(tǒng)提供數(shù)據(jù)服務(wù)的業(yè)務(wù)平臺；

生成模塊，基于所述算法庫中的目標(biāo)算法為所述實時業(yè)務(wù)數(shù)據(jù)生成python計算任務(wù)；

下發(fā)模塊，基于預(yù)設(shè)的調(diào)度策略為所述python計算任務(wù)分配計算節(jié)點設(shè)備，并將所述python計算任務(wù)下發(fā)至所述計算節(jié)點設(shè)備進行執(zhí)行；

輸出模塊，通過可視化界面輸出所述計算節(jié)點設(shè)備返回的計算結(jié)果。