[發(fā)明專利]異常日志寫入方法、裝置、設(shè)備及介質(zhì)

在審

• 申請?zhí)枺?/td>: 202111439444.1
• 申請日: 2021-11-30
• 公開（公告）號: CN114116427A
• 公開（公告）日: 2022-03-01
• 發(fā)明（設(shè)計）人: 路洋
• 申請（專利權(quán)）人: 平安養(yǎng)老保險股份有限公司
• 主分類號: G06F11/34
• 分類號: G06F11/34;G06F16/172;G06F16/178;G06F16/18;G06F9/54
• 代理公司: 深圳市精英專利事務(wù)所 44242
• 代理人: 涂年影

1.一種異常日志寫入方法，其特征在于，所述異常日志寫入方法包括：

獲取目標(biāo)系統(tǒng)，及與所述目標(biāo)系統(tǒng)相通信的Kafka系統(tǒng)，其中，所述Kafka系統(tǒng)包括一級Kafka、二級Kafka及三級Kafka；

將所述目標(biāo)系統(tǒng)產(chǎn)生的日志實(shí)時寫入所述一級Kafka；

響應(yīng)于異常日志寫入指令，從所述一級Kafka存儲的日志中篩選出異常日志，并將所述異常日志寫入所述二級Kafka；

從本地緩存中讀取關(guān)鍵字模板，并利用所述關(guān)鍵字模板對所述二級Kafka中的所述異常日志進(jìn)行異常等級劃分；

將具有預(yù)設(shè)異常等級的所述異常日志確定為目標(biāo)日志，并將所述目標(biāo)日志寫入所述三級Kafka；

響應(yīng)于對所述目標(biāo)日志的消費(fèi)請求，從所述三級Kafka中讀取所述目標(biāo)日志至配置數(shù)據(jù)庫。

2.如權(quán)利要求1所述的異常日志寫入方法，其特征在于，所述從所述一級Kafka存儲的日志中篩選出異常日志包括：

從所述一級Kafka存儲的日志中獲取帶有預(yù)設(shè)格式及/或預(yù)設(shè)字段的日志；

將獲取到的日志確定為所述異常日志。

3.如權(quán)利要求1所述的異常日志寫入方法，其特征在于，在所述從本地緩存中讀取關(guān)鍵字模板前，所述方法還包括：

獲取關(guān)鍵字，并根據(jù)所述關(guān)鍵字建立所述關(guān)鍵字模板；

將所述關(guān)鍵字模板同步存儲至所述本地緩存及非關(guān)系型數(shù)據(jù)庫中。

4.如權(quán)利要求3所述的異常日志寫入方法，其特征在于，在所述從本地緩存中讀取關(guān)鍵字模板時，所述方法還包括：

當(dāng)所述本地緩存重啟時，從所述非關(guān)系型數(shù)據(jù)庫中讀取所述關(guān)鍵字模板，并利用所述關(guān)鍵字模板對所述二級Kafka中的所述異常日志進(jìn)行異常等級劃分；

將所述關(guān)鍵字模板同步至所述本地緩存；

在預(yù)先配置的空閑時段，將所述非關(guān)系型數(shù)據(jù)庫中存儲的所有模板增量同步至所述本地緩存。

5.如權(quán)利要求3所述的異常日志寫入方法，其特征在于，所述方法還包括：

當(dāng)所述本地緩存及所述非關(guān)系型數(shù)據(jù)庫都失效時，調(diào)用關(guān)系型數(shù)據(jù)庫，其中，所述關(guān)系型數(shù)據(jù)庫中存儲著所有關(guān)鍵字；

從所述關(guān)系型數(shù)據(jù)庫中抓取所述關(guān)鍵字模板；

將所述關(guān)鍵字模板同步至所述本地緩存及所述非關(guān)系型數(shù)據(jù)庫；

在同步完成后，在所述非關(guān)系型數(shù)據(jù)庫中為所述關(guān)鍵字模板配置預(yù)設(shè)標(biāo)記，其中，所述預(yù)設(shè)標(biāo)記表示已從所述關(guān)系型數(shù)據(jù)庫中抓取過。

6.如權(quán)利要求5所述的異常日志寫入方法，其特征在于，所述方法還包括：

在從所述關(guān)系型數(shù)據(jù)庫中抓取任意關(guān)鍵字模板時，根據(jù)所述預(yù)設(shè)標(biāo)記確定所述非關(guān)系型數(shù)據(jù)庫中是否存儲有所述任意關(guān)鍵字模板；

當(dāng)所述非關(guān)系型數(shù)據(jù)庫中存儲有所述任意關(guān)鍵字模板時，停止從所述關(guān)系型數(shù)據(jù)庫中抓取所述任意關(guān)鍵字模板。

7.如權(quán)利要求1所述的異常日志寫入方法，其特征在于，所述利用所述關(guān)鍵字模板對所述二級Kafka中的所述異常日志進(jìn)行異常等級劃分包括：

獲取所述異常日志中每條日志的字段；

利用每條日志的字段在所述關(guān)鍵字模板所包括的關(guān)鍵字中進(jìn)行查詢，得到每條日志的關(guān)鍵字；

從所述關(guān)鍵字模板中獲取關(guān)鍵字與異常等級的對應(yīng)關(guān)系；

根據(jù)獲取的關(guān)鍵字與異常等級的對應(yīng)關(guān)系確定每條日志的關(guān)鍵字對應(yīng)的異常等級；

將每條日志的關(guān)鍵字對應(yīng)的異常等級確定為每條日志的異常等級。