[發(fā)明專利]一種基于流式計(jì)算的實(shí)時(shí)反欺詐數(shù)據(jù)處理方法及系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202110333981.1
• 申請日: 2021-03-29
• 公開（公告）號: CN112862009A
• 公開（公告）日: 2021-05-28
• 發(fā)明（設(shè)計(jì)）人: 胡奎政
• 申請（專利權(quán)）人: 中信銀行股份有限公司
• 主分類號: G06K9/62
• 分類號: G06K9/62;G06Q10/06;G06Q40/04
• 代理公司: 北京市蘭臺律師事務(wù)所 11354
• 代理人: 于越;張峰

1.一種基于流式計(jì)算的實(shí)時(shí)反欺詐數(shù)據(jù)處理方法，其特征在于，包括：

獲取實(shí)時(shí)交易數(shù)據(jù)；

解析實(shí)時(shí)交易數(shù)據(jù)合法性和有效性；

根據(jù)實(shí)時(shí)交易數(shù)據(jù)查詢關(guān)聯(lián)的離線特征數(shù)據(jù)；

根據(jù)離線特征數(shù)據(jù)將實(shí)時(shí)交易數(shù)據(jù)轉(zhuǎn)換為對應(yīng)不同特征以及特征下不同維度的多條輸入數(shù)據(jù)；

匯總輸入數(shù)據(jù)形成實(shí)時(shí)預(yù)測特征輸入集；

將實(shí)時(shí)預(yù)測特征輸入集輸入預(yù)先訓(xùn)練完成的反欺詐預(yù)測模型得到反欺詐評分。

2.如權(quán)利要求1所述的方法，其特征在于，所述獲取實(shí)時(shí)交易數(shù)據(jù)包括以預(yù)設(shè)窗口時(shí)間將實(shí)時(shí)交易數(shù)據(jù)切分，生成格式化實(shí)時(shí)交易數(shù)據(jù)。

3.如權(quán)利要求2所述的方法，其特征在于，所述解析實(shí)時(shí)交易數(shù)據(jù)合法性和有效性包括設(shè)置過濾器對格式化實(shí)時(shí)交易數(shù)據(jù)進(jìn)行合法性檢查和時(shí)效性檢查；所述合法性檢查包括檢查交易是否滿足預(yù)設(shè)的交易規(guī)則；所述時(shí)效性檢查包括檢查實(shí)時(shí)交易數(shù)據(jù)是否存在延遲和是否有效。

4.如權(quán)利要求1所述的方法，其特征在于，所述根據(jù)實(shí)時(shí)交易數(shù)據(jù)查詢關(guān)聯(lián)的離線特征數(shù)據(jù)包括從實(shí)時(shí)交易數(shù)據(jù)提取交易特征主鍵信息，并依據(jù)交易特征主鍵信息查詢存儲的離線特征數(shù)據(jù)。

5.如權(quán)利要求1所述的方法，其特征在于，所述根據(jù)離線特征數(shù)據(jù)將實(shí)時(shí)交易數(shù)據(jù)轉(zhuǎn)換為對應(yīng)不同特征以及特征下不同維度的多條輸入數(shù)據(jù)包括將實(shí)時(shí)交易數(shù)據(jù)依據(jù)不同特征以及特征下不同維度轉(zhuǎn)換為多條輸入數(shù)據(jù)，針對不同特征以及特征下不同維度的多條輸入數(shù)據(jù)執(zhí)行聚合或累加操作得到并存儲中間匯總結(jié)果。

6.如權(quán)利要求5所述的方法，其特征在于，所述匯總輸入數(shù)據(jù)形成實(shí)時(shí)預(yù)測特征輸入集包括整合不同特征、維度的中間匯總結(jié)果與對應(yīng)的離線特征數(shù)據(jù)形成實(shí)時(shí)預(yù)測特征輸入集。

7.一種基于流式計(jì)算的實(shí)時(shí)反欺詐數(shù)據(jù)處理系統(tǒng)，其特征在于，包括：

實(shí)時(shí)特征加工引擎，用于獲取實(shí)時(shí)交易數(shù)據(jù)；

數(shù)據(jù)驗(yàn)證模塊，用于解析實(shí)時(shí)交易數(shù)據(jù)合法性和有效性；

輸入集生成模塊，用于生成實(shí)時(shí)預(yù)測特征輸入集；

緩存服務(wù)器，用于存儲離線特征數(shù)據(jù)；

反欺詐評價(jià)模塊，用于調(diào)用預(yù)先訓(xùn)練完成的反欺詐預(yù)測模型對實(shí)時(shí)交易數(shù)據(jù)進(jìn)行反欺詐評分。

8.如權(quán)利要求7所述的系統(tǒng)，其特征在于，所述輸入集生成模塊包括離線特征數(shù)據(jù)查詢子模塊、輸入數(shù)據(jù)生成子模塊和輸入數(shù)據(jù)匯總子模塊；

所述離線特征數(shù)據(jù)查詢子模塊根據(jù)實(shí)時(shí)交易數(shù)據(jù)查詢關(guān)聯(lián)的離線特征數(shù)據(jù)；

所述輸入數(shù)據(jù)生成子模塊將實(shí)時(shí)交易數(shù)據(jù)依據(jù)不同特征以及特征下不同維度轉(zhuǎn)換為多條輸入數(shù)據(jù)，針對不同特征以及特征下不同維度的多條輸入數(shù)據(jù)執(zhí)行聚合或累加操作得到并存儲中間匯總結(jié)果；

所述輸入數(shù)據(jù)匯總子模塊整合不同特征、維度的中間匯總結(jié)果與對應(yīng)的離線特征數(shù)據(jù)形成實(shí)時(shí)預(yù)測特征輸入集。

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

10.一種電子設(shè)備，其特征在于，包括處理器和存儲器；

所述存儲器，用于存儲實(shí)時(shí)交易數(shù)據(jù)；

所述處理器，用于通過調(diào)用實(shí)時(shí)交易數(shù)據(jù)，執(zhí)行權(quán)利要求1至7中任一項(xiàng)所述的方法。