[發明專利]一種實時任務處理方法及裝置有效
| 申請號： | 201710210712.X | 申請日： | 2017-03-31 |
| 公開（公告）號： | CN107168681B | 公開（公告）日： | 2020-11-06 |
| 發明（設計）人： | 孫琦 | 申請（專利權）人： | 北京奇藝世紀科技有限公司 |
| 主分類號： | G06F9/30 | 分類號： | G06F9/30 |
| 代理公司： | 北京柏杉松知識產權代理事務所(普通合伙) 11413 | 代理人： | 馬敬;項京 |
| 地址： | 100080 北京市海淀*** | 國省代碼： | 北京;11 |
| 權利要求書： | 查看更多 | 說明書： | 查看更多 |
| 摘要： | |||
| 搜索關鍵詞： | 一種 實時 任務 處理 方法 裝置 | ||
1.一種實時任務處理方法，其特征在于，包括：
在流式處理任務當前執行聚合函數時，加載已存儲的所述流式處理任務執行的所述聚合函數的封裝數據包，其中，所述封裝數據包包括：所述流式處理任務的所述聚合函數的操作對象、所述操作對象的函數關系；
根據所述聚合函數以及所述封裝數據包，對所述聚合函數的所述操作對象的當前數值，按照所述操作對象的函數關系、執行所述聚合函數操作。
2.根據權利要求1所述的實時任務處理方法，其特征在于，所述在流式處理任務當前執行聚合函數時，加載已存儲的所述流式處理任務執行的所述聚合函數的封裝數據包之前，所述方法還包括：
在所述流式處理任務首次執行所述聚合函數時，對所述聚合函數的所述操作對象的數值，按照所述操作對象的函數關系、執行所述流式處理任務的所述聚合函數操作；
在所述流式處理任務首次執行所述聚合函數結束時，將所述流式處理任務執行的所述聚合函數的所述操作對象、所述操作對象的函數關系，封裝在所述封裝數據包中；
存儲所述封裝數據包。
3.根據權利要求2所述的實時任務處理方法，其特征在于，在對所述聚合函數的所述操作對象的數值，按照所述操作對象的函數關系、執行所述流式處理任務的所述聚合函數操作之后，所述方法還包括：
將對所述聚合函數的所述操作對象的數值，按照所述操作對象的函數關系執行所述流式處理任務的所述聚合函數操作，得到所述操作對象的數值的結果，存儲在數據庫中。
4.根據權利要求1或2所述的實時任務處理方法，其特征在于，在所述根據所述聚合函數以及所述封裝數據包，對所述聚合函數的所述操作對象的當前數值，按照所述操作對象的函數關系、執行所述聚合函數操作之前，所述方法還包括：
累計所述流式處理任務首次執行所述聚合函數到所述流式處理任務當前執行所述聚合函數時間段的、所述操作對象的更新數據，將所述更新數據累計到所述流式處理任務首次執行所述聚合函數的所述操作對象的所述數值上，得到所述流式處理任務當前執行所述聚合函數的所述操作對象的當前數值；
加載所述流式處理任務的所述聚合函數的所述封裝數據包，以及所述操作對象的所述當前數值；
相應的，所述根據所述封裝數據包內的所述聚合函數的操作對象、所述操作對象的函數關系，對所述聚合函數的所述操作對象的當前數值，按照所述操作對象的函數關系、執行相應的操作，包括：
通過所述封裝數據包，獲取所述封裝數據包內的所述聚合函數的操作對象、所述操作對象的函數關系；
對所述聚合函數的所述操作對象的所述當前數值，按照所述操作對象的函數關系、執行所述聚合函數操作。
5.根據權利要求1所述的實時任務處理方法，其特征在于，所述根據所述聚合函數以及所述封裝數據包，對所述聚合函數的所述操作對象的當前數值，按照所述操作對象的函數關系、執行所述聚合函數操作，包括：
通過所述封裝數據包，獲取所述封裝數據包內的所述聚合函數的操作對象、所述操作對象的函數關系，以及在數據庫中獲取到所述聚合函數的操作對象的當前數值；
對所述聚合函數的所述操作對象的所述當前數值，按照所述操作對象的函數關系、執行所述聚合函數操作。
6.一種實時任務處理裝置，其特征在于，包括：
狀態加載模塊，用于在流式處理任務當前執行聚合函數時，加載已存儲的所述流式處理任務執行的所述聚合函數的封裝數據包，其中，所述封裝數據包包括：所述流式處理任務的所述聚合函數的操作對象、所述操作對象的函數關系；
執行模塊，用于根據所述聚合函數以及所述封裝數據包，對所述聚合函數的所述操作對象的當前數值，按照所述操作對象的函數關系、執行所述聚合函數操作。
該專利技術資料僅供研究查看技術是否侵權等信息，商用須獲得專利權人授權。該專利全部權利屬于北京奇藝世紀科技有限公司，未經北京奇藝世紀科技有限公司許可，擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作，請聯系【客服】
本文鏈接：http://www.szxzyx.cn/pat/books/201710210712.X/1.html，轉載請聲明來源鉆瓜專利網。
