[發明專利]一種基于流式計算的告警方法、裝置及介質

在審

• 申請號: 202110069962.2
• 申請日: 2021-01-19
• 公開（公告）號: CN112767080A
• 公開（公告）日: 2021-05-07
• 發明（設計）人: 林茂青;劉暢
• 申請（專利權）人: 上海微盟企業發展有限公司
• 主分類號: G06Q30/06
• 分類號: G06Q30/06
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 王曉坤

1.一種基于流式計算的告警方法，其特征在于，包括：

根據用戶需求構建基于Flink構架的計算模型；

獲取待計算數據；

利用所述計算模型計算與所述待計算數據對應的關鍵指標數據；

在所述關鍵指標數據不符合預設要求的情況下，發送告警信號。

2.根據權利要求1所述的基于流式計算的告警方法，其特征在于，所述獲取待計算數據具體為：

獲取預設周期內的所述待計算數據；

將所述預設周期內的所述待計算數據聚合為一個目標待計算數據；

所述利用所述計算模型計算與所述待計算數據對應的關鍵指標數據具體為：

利用所述計算模型計算與所述目標待計算數據對應的目標關鍵指標數據；

所述在所述關鍵指標數據不符合預設要求的情況下，發送告警信號具體為：

在所述目標關鍵指標數據不符合所述預設要求的情況下，發送所述告警信號。

3.根據權利要求1或2所述的基于流式計算的告警方法，其特征在于，所述獲取待計算數據前，還包括：

獲取第一樣本數據及對應的第一關鍵指標檢測值；

利用所述計算模型計算與所述第一樣本數據對應的測試結果數據；

在所述測試結果數據和所述第一關鍵指標檢測值的相似度不大于預設閾值的情況下，更新所述計算模型。

4.根據權利要求1或2所述的基于流式計算的告警方法，其特征在于，所述獲取待計算數據前，還包括：

獲取基于Strom架構的Strom模型、第二樣本數據及與所述第二樣本數據對應的第二關鍵指標檢測值；

利用所述計算模型計算與所述第二樣本數據對應的第一數據；

利用所述Strom模型計算與所述第二樣本數據對應的第二數據；

計算所述第一數據與所述第二關鍵指標檢測值之間的第一相似度值；

計算所述第二數據與所述第二關鍵指標檢測值之間的第二相似度值；

在第一相似度值不大于第二相似度值的情況下，更新所述計算模型。

5.根據權利要求1所述的基于流式計算的告警方法，其特征在于，所述利用所述計算模型計算與所述待計算數據對應的關鍵指標數據后，還包括：

將所述關鍵指標數據存入數據庫。

6.根據權利要求1所述的基于流式計算的告警方法，其特征在于，所述用戶需求具體包括：與用戶需求匹配的業務數據及業務數據對應的數據格式。

7.根據權利要求1所述的基于流式計算的告警方法，其特征在于，所述關鍵指標數據具體包括：同比、環比以及群體穩定性指數。

8.一種基于流式計算的告警裝置，其特征在于，基于如權利要求1至7任意一項所述的基于流式計算的告警方法，包括：

構建模塊，用于根據用戶需求構建基于Flink構架的計算模型；

第一獲取模塊，用于獲取待計算數據；

第一計算模塊，用于利用所述計算模型計算與所述待計算數據對應的關鍵指標數據；

第一發送模塊，用于在所述關鍵指標數據不符合預設要求的情況下，發送告警信號。

9.一種基于流式計算的告警裝置，其特征在于，包括：

存儲器，用于存儲計算機程序；

處理器，用于執行所述計算機程序時實現如權利要求1至7任意一項所述的基于流式計算的告警方法的步驟。

10.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質上存儲有計算機程序，所述計算機程序被處理器執行時實現如權利要求1至7任意一項所述的基于流式計算的告警方法的步驟。