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

在審

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

1.一種數(shù)據(jù)預(yù)警方法，其特征在于，所述方法包括：

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

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

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

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

2.根據(jù)權(quán)利要求1所述數(shù)據(jù)預(yù)警方法，其特征在于，所述預(yù)警規(guī)則是通過如下方式建立的：

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

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

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

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

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

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

3.根據(jù)權(quán)利要求2所述數(shù)據(jù)預(yù)警方法，其特征在于，所述獲取與所述第一數(shù)據(jù)流對應(yīng)的預(yù)先構(gòu)建的預(yù)警規(guī)則，包括：

按照所述第一數(shù)據(jù)流對應(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)測所述第一數(shù)據(jù)流，在所述第一數(shù)據(jù)流不符合所述預(yù)警規(guī)則時(shí)，發(fā)出預(yù)警消息，包括：

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

4.根據(jù)權(quán)利要求3所述數(shù)據(jù)預(yù)警方法，其特征在于，所述監(jiān)測所述第一數(shù)據(jù)流，在所述第一數(shù)據(jù)流不符合所述邏輯組合表達(dá)式時(shí)，發(fā)出預(yù)警消息之前，所述方法還包括：

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

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

5.根據(jù)權(quán)利要求2所述數(shù)據(jù)預(yù)警方法，其特征在于，所述預(yù)警規(guī)則包括多個(gè)邏輯組合表達(dá)式；所述監(jiān)測所述第一數(shù)據(jù)流，在所述第一數(shù)據(jù)流不符合所述預(yù)警規(guī)則時(shí)，發(fā)出預(yù)警消息，包括：

基于預(yù)先構(gòu)建的filter函數(shù)、window函數(shù)和aggregate函數(shù)對所述第一數(shù)據(jù)流進(jìn)行提取，得到各個(gè)邏輯組合表達(dá)式的第二數(shù)據(jù)流；

基于union函數(shù)返回在所述第二數(shù)據(jù)流中計(jì)算的、由表達(dá)式指定的所有非Null數(shù)值的聯(lián)合，得到第三數(shù)據(jù)流；

在各個(gè)所述第三數(shù)據(jù)流不符合對應(yīng)的所述預(yù)警規(guī)則時(shí)，發(fā)出預(yù)警消息。

6.一種數(shù)據(jù)預(yù)警裝置，其特征在于，所述裝置包括：

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

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

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

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