[發(fā)明專利]基于業(yè)務場景的實時業(yè)務監(jiān)控方法、系統(tǒng)、終端及介質

有效

• 申請?zhí)枺?/td>: 202110439635.1
• 申請日: 2021-04-23
• 公開（公告）號: CN113204464B
• 公開（公告）日: 2023-04-25
• 發(fā)明（設計）人: 邵志鵬
• 申請（專利權）人: 商盟商務服務有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30;G06F11/34;G06Q10/0639
• 代理公司: 上海恒慧知識產權代理事務所(特殊普通合伙) 31317
• 代理人: 徐紅銀;劉翠

本發(fā)明提供了一種基于業(yè)務場景的實時業(yè)務監(jiān)控方法及系統(tǒng)，包括業(yè)務應用日志埋點；埋點數(shù)據(jù)實時采集；實時復雜事件處理；輸出超時告警消息。在業(yè)務應用日志埋點進行數(shù)據(jù)監(jiān)控，根據(jù)業(yè)務單發(fā)起初始化狀態(tài)到處理中狀態(tài)再到業(yè)務單完成終態(tài)的狀態(tài)變化過程，配置超時時間，對于總耗時超過超時時間的業(yè)務單進行實時監(jiān)控。其中，采用Redis?Lua腳本對每一項業(yè)務單的狀態(tài)變化日志進行預排序，并通過Flink?CEP模型對每一項預排序后的業(yè)務單進行超時模式匹配，得到業(yè)務異常事件。本發(fā)明既可以很好的貼合業(yè)務場景，對每一筆業(yè)務單進行監(jiān)控并及時發(fā)現(xiàn)超時異常的業(yè)務單，可以擴展到任何具有不同狀態(tài)先后順序變化的業(yè)務場景。

技術領域

本發(fā)明涉及業(yè)務監(jiān)控技術領域，具體地，涉及一種基于業(yè)務場景的實時業(yè)務監(jiān)控方法、系統(tǒng)、終端及介質。

背景技術

在支付業(yè)務中，支付請求并發(fā)量大，越來越高的支付業(yè)務并發(fā)量，復雜的業(yè)務處理邏輯，需要對每一筆支付單做完整鏈路的實時監(jiān)控，并及時發(fā)現(xiàn)超時處理的業(yè)務支付單；應用系統(tǒng)對接的渠道、商戶等各種第三方網(wǎng)絡接口比較多，容易發(fā)生由于網(wǎng)絡、渠道或商戶系統(tǒng)維護、甚至突發(fā)的不可預期的異常，導致業(yè)務處理出現(xiàn)超時的情況，需要及時監(jiān)控到并發(fā)出告警。傳統(tǒng)的解決方法是采用不停地輪詢掃描業(yè)務系統(tǒng)的關系數(shù)據(jù)庫，通過SQL查詢狀態(tài)為“處理中”的業(yè)務支付單，并計算對應的超時時間，將超時時間超過一定閾值的業(yè)務支付單信息發(fā)送給告警平臺。傳統(tǒng)的關系數(shù)據(jù)庫SQL查詢方式，對數(shù)據(jù)庫本身的要求較高，也難以應對分庫分表以及不同業(yè)務分類的處理，應對大規(guī)模的并發(fā)處理性能和效率低下。

因此，傳統(tǒng)方法存在比較大的問題：

1、對大規(guī)模數(shù)據(jù)的聯(lián)機交易數(shù)據(jù)庫表做輪詢SQL查詢，對關系數(shù)據(jù)庫造成了巨大壓力，影響正常聯(lián)機業(yè)務；

2、不同類型業(yè)務閾值不一樣帶來的靈活擴展問題；

3、效率和性能較低，無法應對大規(guī)模的并發(fā)量。

經(jīng)過檢索發(fā)現(xiàn)：

申請?zhí)枮?01610921493.1的中國發(fā)明專利申請《一種業(yè)務監(jiān)控的方法及系統(tǒng)》，包括：從業(yè)務系統(tǒng)中提取業(yè)務日志，并根據(jù)所述業(yè)務日志打印業(yè)務日志，所述打印業(yè)務日志的過程包括：將從業(yè)務系統(tǒng)中提取業(yè)務日志依據(jù)業(yè)務指標進行存儲；采集所打印的業(yè)務日志，并將所述業(yè)務日志推送至分布式發(fā)布訂閱消息系統(tǒng)；根據(jù)所述業(yè)務系統(tǒng)的業(yè)務指標，通過所述分布式發(fā)布訂閱消息系統(tǒng)提取業(yè)務日志，并進行聚合計算；根據(jù)經(jīng)過聚合計算后的業(yè)務日志，掃描得到發(fā)生異常的業(yè)務指標。該專利技術雖然公開了通過獲取“業(yè)務日志”、“分布式發(fā)布訂閱消息系統(tǒng)(Kafka)”等信息進行異常監(jiān)控的相關內容，但是該專利技術中文件是打印日志，分布式發(fā)布訂閱消息系統(tǒng)提取業(yè)務日志，并進行聚合計算掃描得到異常業(yè)務指標；但是將這種方式應用于支付業(yè)務中，仍然存在如下問題：

1、該專利需要對提取的業(yè)務日志進行聚合計算得到業(yè)務指標；

2、該專利是針對業(yè)務指標進行掃描得到發(fā)生異常的業(yè)務指標，監(jiān)控粒度比較粗。

申請?zhí)枮?01410528628.9的中國發(fā)明專利申請《一種對異常數(shù)據(jù)進行處理的方法、裝置及監(jiān)控系統(tǒng)》，涉及了一種對異常數(shù)據(jù)進行處理的方法，該方法通過“超時”來判斷數(shù)據(jù)異常，但是該專利技術中所采用的通過“超時”來判斷數(shù)據(jù)異常的方法，但是將這種方式應用于支付業(yè)務中，仍然存在如下問題：

該專利是通過所發(fā)送的測試數(shù)據(jù)所記錄的第一時間戳與第二時間戳的差值作為超時時間，不涉及數(shù)據(jù)本身的業(yè)務含義，即支付業(yè)務自身的事件狀態(tài)。

申請?zhí)枮?01811373337.1的中國發(fā)明專利申請《一種基于Flink的數(shù)據(jù)流多向處理系統(tǒng)》，記載了利用Kafka的高擴展性和高可靠性，可將多個數(shù)據(jù)源的數(shù)據(jù)準確地收集匯總，與Flink的高效組合。但是將這種方式應用于支付業(yè)務中，仍然存在如下問題：