[發明專利]一種風險偵測方法、裝置、電子設備和可讀存儲介質

在審

• 申請號: 202110077003.5
• 申請日: 2021-01-20
• 公開（公告）號: CN112766975A
• 公開（公告）日: 2021-05-07
• 發明（設計）人: 洪湃;宋倩;褚中成;曾常安;解安芳
• 申請（專利權）人: 中信銀行股份有限公司
• 主分類號: G06Q20/40
• 分類號: G06Q20/40;G06F9/54
• 代理公司: 北京市蘭臺律師事務所 11354
• 代理人: 張峰

本申請涉及計算機技術領域，尤其涉及一種風險偵測方法、裝置、電子設備和可讀存儲介質，所述方法包括將獲取的目標用戶的目標交易數據存儲于Kafka消息系統；基于Apache Storm的程序讀取Kafka消息系統中的目標交易數據；基于Apache Storm和Esper復雜事件處理組件的程序對所述目標交易數據進行分析處理并輸出分析結果；如果所述分析結果符合預設的風險告警規則，則啟動風險告警。本申請提供的風險偵測方案實現了7*24小時的高可用，支持在線水平擴容，為業務人員提供了高效的規則編輯功能，且支持歷史交易回歸驗證、查詢，支持百億級數據量。

技術領域

本申請涉及計算機數據處理技術領域，尤其涉及一種風險偵測方法、裝置、電子設備和可讀存儲介質。

背景技術

在線支付由于其便捷性和與日常生活的緊密相關性而受到消費者的青睞，并已經成為主流的交易支付方式。然而，在線支付也導致了更多的交易欺詐風險。目前業界主要采用基于規則的方法來應對在線支付的交易欺詐風險，例如基于關系數據庫的傳統交易風險偵測系統，主要采用數據庫表SQL查詢語句即風控規則，需查詢數據庫的SQL數量＝風控規則數量*當前瞬時交易量，日常風險偵測數據量較小所以沒有什么問題，但是當客戶群瞬時交易量激增時(如雙十一零點后巨量客戶集中進行消費交易)，需查詢數據庫的SQL數量被等比例放大(即讀放大)后，導致數據庫性能急劇下降，導致系統處理能力急劇下降，最終導致風險交易報警延遲、相應的風控處置不及時，客戶和金融公司遭受損失。

發明內容

本申請的目的旨在至少能解決上述的技術缺陷之一。本申請所采用的技術方案如下：

第一方面，本申請實施例提供一種風險偵測方法，所述方法包括：

將獲取的目標用戶的目標交易數據存儲于Kafka消息系統；

基于Apache Storm的程序讀取Kafka消息系統中的目標交易數據；

基于Apache Storm和Esper復雜事件處理組件的程序對所述目標交易數據進行分析處理并輸出分析結果；

如果所述分析結果符合預設的風險告警規則，則啟動風險告警。

可選地，所述將獲取的目標用戶的目標交易數據存儲于Kafka消息系統包括：

提取所述目標交易數據至少一個特征信息；其中所述目標交易數據至少包括以下特征信息：目標用戶身份信息、目標交易卡片信息、目標交易類型、目標交易方向、目標交易時間、目標交易地理位置、目標交易金額；

根據所述提取的至少一個特征信息將所述目標交易數據劃分為N個分片；

將所述N個分片存儲于所述Kafka消息系統。

可選地，在基于Apache Storm和Esper復雜事件處理組件的程序對所述目標交易數據進行分析處理之前，所述方法還包括：

將所述N個分片的目標交易數據存儲于Cassandra數據庫。

可選地，所述基于Apache Storm和Esper復雜事件處理組件的程序對所述目標交易數據進行分析處理包括：

解析N個分片的目標交易數據中特征信息并處理為可以被Esper處理的格式數據；

將所述處理的格式目標交易數據存儲于Cassandra數據庫；

根據解析的特征信息和預存規則配置表，生成風險偵測規則；

Esper讀取Cassandra數據庫中的目標交易數據，并按照所述的風險偵測規則對所述的目標交易數據進行分析處理。

可選地，所述啟動風險告警包括：

將所述風險告警信息發送至Kafka消息系統；