[發(fā)明專利]一種業(yè)務(wù)數(shù)據(jù)監(jiān)控警告裝置及方法

在審

• 申請?zhí)枺?/td>: 202010006684.1
• 申請日: 2020-01-03
• 公開（公告）號: CN111190798A
• 公開（公告）日: 2020-05-22
• 發(fā)明（設(shè)計）人: 印躍根;司孝波;楊濤;王鑫;林仁山
• 申請（專利權(quán)）人: 蘇寧云計算有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30;G06F11/32
• 代理公司: 北京市萬慧達(dá)律師事務(wù)所 11111
• 代理人: 趙然

本發(fā)明公開了一種業(yè)務(wù)數(shù)據(jù)監(jiān)控警告裝置及方法，屬于大數(shù)據(jù)處理技術(shù)領(lǐng)域。所述裝置包括：告任務(wù)調(diào)度模塊，用于任務(wù)調(diào)度以及對任務(wù)運(yùn)行情況進(jìn)行監(jiān)控，生成任務(wù)隊列；隊列管理模塊，用于所述任務(wù)隊列的加載及并發(fā)控制；執(zhí)行管理模塊，用于根據(jù)預(yù)置的告警規(guī)則返回告警任務(wù)及告警信息，所述執(zhí)行管理模塊包括執(zhí)行確定子模塊和執(zhí)行子模塊，所述執(zhí)行確定子模塊用于beanname獲取Spring容器，并從Spring容器中確定代理對象，獲取代理對象的相應(yīng)執(zhí)行子模塊；所述執(zhí)行子模塊用于根據(jù)任務(wù)執(zhí)行情況和告警規(guī)則獲取告警任務(wù)及其告警所需信息；警規(guī)則管理模塊，用于所述告警任務(wù)觸發(fā)的所述告警規(guī)則配置及管理；消息管理模塊，用于接收所述告警任務(wù)及告警信息，并對所述告警信息進(jìn)行數(shù)據(jù)處理之后下發(fā)。

技術(shù)領(lǐng)域

本發(fā)明涉及大數(shù)據(jù)技術(shù)領(lǐng)域，特別涉及一種業(yè)務(wù)數(shù)據(jù)監(jiān)控警告裝置及方法。

背景技術(shù)

隨著業(yè)務(wù)的不斷豐富，為了提高系統(tǒng)的性能，大量的采用異步處理的形式，使得產(chǎn)生了較多的待處理數(shù)據(jù)，準(zhǔn)確而又及時的監(jiān)控這些龐大復(fù)雜業(yè)務(wù)場景產(chǎn)生的業(yè)務(wù)數(shù)據(jù)便成了重要的任務(wù)。

針對每個業(yè)務(wù)場景或者異步待處理表，都需要使用JOB定時去監(jiān)控并及時告警通知到相關(guān)人員處理，而這種任務(wù)需要有開發(fā)工作量并且不同表之間只有少量的區(qū)別，重復(fù)而又繁雜的監(jiān)控流程，導(dǎo)致監(jiān)控告警效率低，系統(tǒng)代碼量和代碼重復(fù)度上升，而大量JOB又增加了調(diào)度平臺任務(wù)的維護(hù)成本。

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

為了解決現(xiàn)有技術(shù)的問題，本發(fā)明實施例提供了業(yè)務(wù)數(shù)據(jù)監(jiān)控警告裝置及方法，通過對不同業(yè)務(wù)場景的任務(wù)進(jìn)行監(jiān)控和集中調(diào)度，并采用可配置化的告警方式根據(jù)不同業(yè)務(wù)監(jiān)控要求靈活調(diào)整告警規(guī)則的配置參數(shù)，既保障了不同業(yè)務(wù)場景的高效監(jiān)控警告需求，又降低了代碼開發(fā)量及后期維護(hù)成本。所述技術(shù)方案如下：

一方面，提供了一種業(yè)務(wù)數(shù)據(jù)監(jiān)控警告裝置，所述裝置包括：

任務(wù)調(diào)度模塊，用于任務(wù)調(diào)度以及對任務(wù)運(yùn)行情況進(jìn)行監(jiān)控，生成任務(wù)隊列；隊列管理模塊，用于所述任務(wù)隊列的加載及并發(fā)控制；執(zhí)行管理模塊，用于根據(jù)預(yù)置的告警規(guī)則返回告警任務(wù)及告警信息，所述執(zhí)行管理模塊包括執(zhí)行確定子模塊和執(zhí)行子模塊，所述執(zhí)行確定子模塊用于通過bean方法獲取Spring容器，并從Spring容器中確定代理對象，獲取代理對象的相應(yīng)執(zhí)行子模塊；所述執(zhí)行子模塊用于根據(jù)任務(wù)執(zhí)行情況和告警規(guī)則獲取告警任務(wù)及其告警所需信息；告警規(guī)則管理模塊，用于所述告警任務(wù)觸發(fā)的所述告警規(guī)則配置及管理；消息管理模塊，用于接收所述告警任務(wù)及告警信息，并對所述告警信息進(jìn)行數(shù)據(jù)處理之后下發(fā)。

進(jìn)一步地，所述告警規(guī)則至少包括告警執(zhí)行頻率策略、告警閾值策略、告警頻率策略、模板動態(tài)配置策略、人員配置策略構(gòu)成的組中的至少一個或多個。

進(jìn)一步地，通過bean方法進(jìn)行所述告警規(guī)則配置及管理；和/或，所述告警執(zhí)行頻率策略采用cron表達(dá)式；和/或，所述告警閾值策略包括異常告警閾值和積壓告警閾值。

進(jìn)一步地，所述任務(wù)調(diào)度模塊包括調(diào)度控制子模塊、任務(wù)監(jiān)控子模塊、異常機(jī)制配置子模塊和異常機(jī)制執(zhí)行子模塊，所述調(diào)度控制子模塊用于對集群環(huán)境下任務(wù)并發(fā)執(zhí)行進(jìn)行調(diào)度和控制；所述任務(wù)監(jiān)控子模塊用于對任務(wù)調(diào)度情況及任務(wù)運(yùn)行情況進(jìn)行監(jiān)控，對所述任務(wù)進(jìn)行分組并生成任務(wù)隊列；所述異常機(jī)制配置子模塊用于包括錯誤重試機(jī)制和異常提醒機(jī)制在內(nèi)的異常機(jī)制進(jìn)行配置，所述異常機(jī)制執(zhí)行子模塊用于根據(jù)任務(wù)調(diào)度執(zhí)行情況進(jìn)行相應(yīng)異常機(jī)制執(zhí)行。

進(jìn)一步地，所述調(diào)度控制子模塊還用于跨業(yè)務(wù)系統(tǒng)的后繼任務(wù)調(diào)度和控制。

進(jìn)一步地，所述隊列管理模塊包括任務(wù)數(shù)據(jù)查詢子模塊、任務(wù)分組規(guī)則管理子模塊和任務(wù)狀態(tài)管理子模塊，所述任務(wù)數(shù)據(jù)查詢子模塊用于從存儲業(yè)務(wù)數(shù)據(jù)的數(shù)據(jù)庫查詢?nèi)蝿?wù)數(shù)據(jù)；所述任務(wù)分組規(guī)則管理子模塊用于對任務(wù)分組規(guī)則進(jìn)行配置和管理；所述任務(wù)狀態(tài)管理子模塊用于對任務(wù)狀態(tài)進(jìn)行記錄和管理。

進(jìn)一步地，所述數(shù)據(jù)庫包括Redis數(shù)據(jù)庫和/或MySQL數(shù)據(jù)庫。