[發(fā)明專利]一種數(shù)據(jù)預(yù)警方法、裝置、介質(zhì)及設(shè)備

在審

• 申請(qǐng)?zhí)枺?/td>: 202111664779.3
• 申請(qǐng)日: 2021-12-31
• 公開（公告）號(hào): CN114356735A
• 公開（公告）日: 2022-04-15
• 發(fā)明（設(shè)計(jì)）人: 吳國(guó)挺;邱慶舉;王洋
• 申請(qǐng)（專利權(quán)）人: 浙江時(shí)空道宇科技有限公司;浙江吉利控股集團(tuán)有限公司
• 主分類號(hào): G06F11/34
• 分類號(hào): G06F11/34
• 代理公司: 廣州三環(huán)專利商標(biāo)代理有限公司 44202
• 代理人: 苗芬芬

本公開關(guān)于一種數(shù)據(jù)預(yù)警方法、裝置、介質(zhì)及設(shè)備，所述方法包括：獲取消息列隊(duì)，所述消息列隊(duì)包括多個(gè)消息主題，每個(gè)所述消息主題對(duì)應(yīng)一個(gè)輸入源，所述消息主題是所述輸入源實(shí)時(shí)上傳的數(shù)據(jù)；在所述消息列隊(duì)中獲取指定的消息主題，得到第一數(shù)據(jù)流；獲取與所述第一數(shù)據(jù)流對(duì)應(yīng)的預(yù)先構(gòu)建的預(yù)警規(guī)則；監(jiān)測(cè)所述第一數(shù)據(jù)流，在所述第一數(shù)據(jù)流不符合所述預(yù)警規(guī)則時(shí)，發(fā)出預(yù)警消息。本說(shuō)明書提供的數(shù)據(jù)預(yù)警方法可以解決多輸入源的問題，實(shí)現(xiàn)對(duì)多個(gè)輸入源數(shù)據(jù)的實(shí)時(shí)監(jiān)測(cè)，提高多個(gè)輸入源數(shù)據(jù)預(yù)警的準(zhǔn)確性，提高數(shù)據(jù)預(yù)警的應(yīng)用場(chǎng)景。

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

本公開涉及數(shù)據(jù)預(yù)警技術(shù)領(lǐng)域，尤其涉及一種數(shù)據(jù)預(yù)警方法、裝置、介質(zhì)及設(shè)備。

背景技術(shù)

數(shù)據(jù)預(yù)警即按照用戶定義的規(guī)則，對(duì)終端設(shè)備上報(bào)的數(shù)據(jù)進(jìn)行實(shí)時(shí)監(jiān)測(cè)，如果發(fā)現(xiàn)不符合的規(guī)則的數(shù)據(jù)對(duì)用戶進(jìn)行預(yù)警。現(xiàn)有數(shù)據(jù)預(yù)警的技術(shù)通常只能實(shí)現(xiàn)簡(jiǎn)單的預(yù)警規(guī)則，比如單一設(shè)備的閾值判斷。但是隨著大數(shù)據(jù)和物聯(lián)網(wǎng)的發(fā)展，系統(tǒng)中接入設(shè)備的種類和數(shù)量大幅提高，簡(jiǎn)單的數(shù)據(jù)預(yù)警規(guī)則不能完全滿足用戶的需求。因此本發(fā)明提出了一種基于流計(jì)算的海量多源數(shù)據(jù)預(yù)警方法，能夠?qū)崟r(shí)監(jiān)測(cè)多輸入源數(shù)據(jù)，同時(shí)并且結(jié)合流計(jì)算引擎支持包括邏輯計(jì)算和時(shí)間窗口聚合計(jì)算在內(nèi)的復(fù)雜規(guī)則設(shè)計(jì)。

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

第一方面，本公開提供一種數(shù)據(jù)預(yù)警方法所述方法包括：

獲取消息列隊(duì)，所述消息列隊(duì)包括多個(gè)消息主題，每個(gè)所述消息主題對(duì)應(yīng)一個(gè)輸入源，所述消息主題是所述輸入源實(shí)時(shí)上傳的數(shù)據(jù)；

在所述消息列隊(duì)中獲取指定的消息主題，得到第一數(shù)據(jù)流；

獲取與所述第一數(shù)據(jù)流對(duì)應(yīng)的預(yù)先構(gòu)建的預(yù)警規(guī)則；

監(jiān)測(cè)所述第一數(shù)據(jù)流，在所述第一數(shù)據(jù)流不符合所述預(yù)警規(guī)則時(shí)，發(fā)出預(yù)警消息。

進(jìn)一步地，所述預(yù)警規(guī)則是通過如下方式建立的：

在產(chǎn)品列表中選取目標(biāo)輸入源，所述產(chǎn)品列表中包括與所述消息主題對(duì)應(yīng)的輸入源，每個(gè)所述輸入源包括至少一個(gè)設(shè)備；

在所述目標(biāo)輸入源中選取指定數(shù)量的設(shè)備；

根據(jù)選取的設(shè)備設(shè)置各個(gè)設(shè)備對(duì)應(yīng)的指標(biāo)統(tǒng)計(jì)的時(shí)間窗口；

基于所述時(shí)間窗口建立各個(gè)設(shè)備預(yù)警規(guī)則對(duì)應(yīng)的指標(biāo)表達(dá)式；

在所述產(chǎn)品列表中選取下一個(gè)輸入源作為所述目標(biāo)輸入源；

重復(fù)執(zhí)行：在所述目標(biāo)輸入源中選取指定數(shù)量的設(shè)備；根據(jù)選取的設(shè)備設(shè)置各個(gè)設(shè)備對(duì)應(yīng)的指標(biāo)統(tǒng)計(jì)的時(shí)間窗口；基于所述時(shí)間窗口建立各個(gè)設(shè)備預(yù)警規(guī)則對(duì)應(yīng)的指標(biāo)表達(dá)式，直至所述產(chǎn)品列表中的全部輸入源完成指標(biāo)表達(dá)式的創(chuàng)建。

進(jìn)一步地，所述獲取與所述第一數(shù)據(jù)流對(duì)應(yīng)的預(yù)先構(gòu)建的預(yù)警規(guī)則，包括：

按照所述第一數(shù)據(jù)流對(duì)應(yīng)的輸入源獲取各個(gè)輸入源中各個(gè)設(shè)備的指標(biāo)表達(dá)式；

基于各個(gè)所述輸入源中各個(gè)設(shè)備的關(guān)聯(lián)關(guān)系創(chuàng)建預(yù)警指標(biāo)的邏輯組合表達(dá)式，所述預(yù)警指標(biāo)的邏輯組合表達(dá)式中包括多個(gè)設(shè)備的指標(biāo)表達(dá)式；

相應(yīng)的，所述監(jiān)測(cè)所述第一數(shù)據(jù)流，在所述第一數(shù)據(jù)流不符合所述預(yù)警規(guī)則時(shí)，發(fā)出預(yù)警消息，包括：

監(jiān)測(cè)所述第一數(shù)據(jù)流，在所述第一數(shù)據(jù)流不符合所述邏輯組合表達(dá)式時(shí)，發(fā)出預(yù)警消息。

進(jìn)一步地，所述監(jiān)測(cè)所述第一數(shù)據(jù)流，在所述第一數(shù)據(jù)流不符合所述邏輯組合表達(dá)式時(shí)，發(fā)出預(yù)警消息之前，所述方法還包括：

驗(yàn)證所述邏輯組合表達(dá)式的布爾值是否符合預(yù)設(shè)要求；

相應(yīng)的，所述監(jiān)測(cè)所述第一數(shù)據(jù)流，在所述第一數(shù)據(jù)流不符合所述邏輯組合表達(dá)式時(shí)，發(fā)出預(yù)警消息是在所述邏輯組合表達(dá)式的布爾值符合預(yù)設(shè)要求時(shí)執(zhí)行的。