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

在審

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

本申請公開了一種基于流式計算的告警方法、裝置及介質，其中方法包括，預先根據用戶需求構建基于Flink構架的計算模型，獲取待計算數據后，利用計算模型計算與待計算數據對應的關鍵指標數據，在關鍵指標數據不符合預設要求的情況下，發送告警信號。由于計算模型是基于Flink構架搭建的，且Flink本身具有高吞吐、低延遲、高可靠以及精準計算等優點，因此基于Flink構架搭建的計算模型其計算速度快、計算結果的可靠性高，從而提高了線上電商告警系統的響應速度和可靠性。此外，本申請提供的一種基于流式計算的告警裝置及介質，與上述基于流式計算的告警方法對應，效果同上。

技術領域

本申請涉及電子信息技術領域，特別是涉及一種基于流式計算的告警方法、裝置及介質。

背景技術

隨著科技的發展和網絡的發展，網絡已成為人類生活中必不可少的一部分，尤其是近年來快速發展的線上電商，不斷豐富著人們的物質生活。但是在線上電商快速發展的同時，店家為了快速獲取消費者的信任，會采用刷單行為進行惡意競爭，嚴重影響了線上電商的買賣環境。

目前，告警系統主要是基于數據流處理構架(Strom)建立Strom模型，利用Strom模型進行告警。由于Strom其本身底層基建依賴多、容錯機制不完善、延遲較高、可靠性較差以及計算準確率較低，導致基于Strom建立的告警系統的告警速度慢，以及可靠性低的問題。

因此，如何提高線上電商告警系統的響應速度和可靠性是本領域技術人員亟待解決的問題。

發明內容

本申請的目的是提供一種基于流式計算的告警方法，用以提高線上電商告警系統的響應速度和可靠性。本申請的目的是還提供一種基于流式計算的告警裝置及介質。

為解決上述技術問題，本申請提供一種基于流式計算的告警方法，包括：

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

獲取待計算數據；

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

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

優選的，所述獲取待計算數據具體為：

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

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

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

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

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

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

優選的，所述獲取待計算數據前，還包括：

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

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

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

優選的，所述獲取待計算數據前，還包括：

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

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

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