[發(fā)明專(zhuān)利]數(shù)據(jù)同步的監(jiān)控方法、裝置、電子設(shè)備及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 202011086521.5
• 申請(qǐng)日: 2020-10-12
• 公開(kāi)（公告）號(hào): CN112286757A
• 公開(kāi)（公告）日: 2021-01-29
• 發(fā)明（設(shè)計(jì)）人: 汪早榮;劉昊;孫林才
• 申請(qǐng)（專(zhuān)利權(quán)）人: 浙江深大智能科技有限公司
• 主分類(lèi)號(hào): G06F11/30
• 分類(lèi)號(hào): G06F11/30;G06F11/32;G06F16/13;G06F16/178;G06F16/18
• 代理公司: 杭州創(chuàng)智卓英知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 33324
• 代理人: 詹璐瑤

1.一種數(shù)據(jù)同步的監(jiān)控方法，其特征在于，所述方法包括：

采集多個(gè)業(yè)務(wù)日志，其中，所述業(yè)務(wù)日志配置有日志類(lèi)型標(biāo)識(shí)，所述日志類(lèi)型標(biāo)識(shí)用于區(qū)分所述業(yè)務(wù)日志的來(lái)源；

將多個(gè)所述業(yè)務(wù)日志基于所述日志類(lèi)型標(biāo)識(shí)進(jìn)行過(guò)濾得到第一日志，將所述第一日志存儲(chǔ)到Elasticsearch；

根據(jù)Elasticsearch中的日志索引查詢(xún)所述第一日志，根據(jù)所述第一日志中的錯(cuò)誤代碼發(fā)出預(yù)警信息或告警信息，其中，所述預(yù)警信息包括網(wǎng)絡(luò)存在異常波動(dòng)，所述告警信息包括數(shù)據(jù)傳輸存在異常。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將多個(gè)所述業(yè)務(wù)日志基于所述日志類(lèi)型標(biāo)識(shí)進(jìn)行過(guò)濾得到第一日志包括：配置grok表達(dá)式，按照所述日志類(lèi)型標(biāo)識(shí)對(duì)應(yīng)的字段對(duì)所述業(yè)務(wù)日志進(jìn)行過(guò)濾得到所述第一日志。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將多個(gè)所述業(yè)務(wù)日志基于所述日志類(lèi)型標(biāo)識(shí)進(jìn)行過(guò)濾得到第一日志，將所述第一日志存儲(chǔ)到Elasticsearch，包括：

在所述日志類(lèi)型標(biāo)識(shí)是客戶(hù)端日志的情況下，對(duì)多個(gè)所述業(yè)務(wù)日志匹配客戶(hù)端服務(wù)編碼，并抓取多個(gè)所述業(yè)務(wù)日志中數(shù)據(jù)同步的訂單編號(hào)、訂單時(shí)間、異常代碼和操作耗時(shí)，得到所述第一日志，其中，所述客戶(hù)端服務(wù)編碼是所述業(yè)務(wù)日志所屬客戶(hù)端的唯一標(biāo)識(shí)；

創(chuàng)建日志索引，基于所述日志索引將所述第一日志存儲(chǔ)到Elasticsearch。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述將多個(gè)所述業(yè)務(wù)日志基于所述日志類(lèi)型標(biāo)識(shí)進(jìn)行過(guò)濾得到第一日志，包括：

在所述日志類(lèi)型標(biāo)識(shí)是交互網(wǎng)絡(luò)日志的情況下，對(duì)多個(gè)所述業(yè)務(wù)日志匹配組件服務(wù)編碼，并抓取多個(gè)所述業(yè)務(wù)日志中的組件異常日志，得到所述第一日志。

5.根據(jù)權(quán)利要求3所述的方法，其特征在于，所述將多個(gè)所述業(yè)務(wù)日志基于所述日志類(lèi)型標(biāo)識(shí)進(jìn)行過(guò)濾得到第一日志，包括：

在所述日志類(lèi)型標(biāo)識(shí)是設(shè)備運(yùn)行日志的情況下，對(duì)多個(gè)所述業(yè)務(wù)日志匹配設(shè)備編號(hào)，并抓取多個(gè)所述業(yè)務(wù)日志中的設(shè)備運(yùn)行狀態(tài)異常日志，得到所述第一日志。

6.根據(jù)權(quán)利要求1至5任一項(xiàng)所述的方法，其特征在于，所述根據(jù)所述第一日志中的錯(cuò)誤代碼發(fā)出預(yù)警信息或告警信息，包括：

在所述第一日志中存在至少一種錯(cuò)誤代碼的數(shù)量達(dá)到預(yù)設(shè)的異常閾值的情況下，發(fā)出預(yù)警信息或告警信息。

7.根據(jù)權(quán)利權(quán)利要求6所述的方法，其特征在于，所述根據(jù)所述第一日志中的錯(cuò)誤代碼發(fā)出預(yù)警信息或告警信息，還包括：

根據(jù)所述第一日志中與所述錯(cuò)誤代碼對(duì)應(yīng)的錯(cuò)誤類(lèi)型，發(fā)出預(yù)警信息或告警信息，其中，所述第一日志包括若干種所述錯(cuò)誤代碼，每種所述錯(cuò)誤代碼對(duì)應(yīng)一種錯(cuò)誤類(lèi)型。

8.一種數(shù)據(jù)同步的監(jiān)控裝置，其特征在于，所述監(jiān)控裝置包括：日志采集模塊、日志處理模塊和查詢(xún)提示模塊；

所述日志采集模塊，用于采集多個(gè)業(yè)務(wù)日志，其中，所述業(yè)務(wù)日志配置有日志類(lèi)型標(biāo)識(shí)，所述日志類(lèi)型標(biāo)識(shí)用于區(qū)分所述業(yè)務(wù)日志的來(lái)源；

所述日志處理模塊，用于將多個(gè)所述業(yè)務(wù)日志基于所述日志類(lèi)型標(biāo)識(shí)進(jìn)行過(guò)濾得到第一日志，將所述第一日志存儲(chǔ)到Elasticsearch；

所述查詢(xún)提示模塊，用于根據(jù)Elasticsearch中的日志索引查詢(xún)所述第一日志，根據(jù)所述第一日志中的錯(cuò)誤代碼發(fā)出預(yù)警信息或告警信息，其中，所述預(yù)警信息包括網(wǎng)絡(luò)存在異常波動(dòng)，所述告警信息包括數(shù)據(jù)傳輸存在異常。

9.一種電子設(shè)備，包括存儲(chǔ)器、處理器以及存儲(chǔ)在所述存儲(chǔ)器上并在所述處理器上運(yùn)行的計(jì)算機(jī)程序，其特征在于，所述處理器執(zhí)行所述計(jì)算機(jī)程序時(shí)實(shí)現(xiàn)如權(quán)利要求1至7任一項(xiàng)所述的數(shù)據(jù)同步的監(jiān)控方法。

10.一種計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)，其上存儲(chǔ)有計(jì)算機(jī)程序，其特征在于：所述計(jì)算機(jī)程序被處理器執(zhí)行時(shí)實(shí)現(xiàn)權(quán)利要求1至7任一項(xiàng)所述的數(shù)據(jù)同步的監(jiān)控方法。