[發明專利]數據處理方法、裝置、設備及存儲介質

有效

• 申請號: 202010494023.8
• 申請日: 2020-06-03
• 公開（公告）號: CN111639138B
• 公開（公告）日: 2023-04-25
• 發明（設計）人: 屈克;陳娜;郭寶林;寧偉鋒
• 申請（專利權）人: 中國聯合網絡通信集團有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/25;G06F16/2455;G06F16/242;G06F16/18
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 朱穎;劉芳

1.一種數據處理方法，其特征在于，包括：

獲取多條目標消息，所述多條目標消息是通過目標Kafka對多個數據源的消息數據進行格式統一處理得到的，所述目標Kafka為服務器中任一Kafka，所述多個數據源包括數據庫日志、接觸式文件、其他Kafka；

對各條所述目標消息進行處理，得到各條所述目標消息對應的單個業務因子；

對所述單個業務因子根據預設業務規則進行組合，得到業務組合因子，所述業務組合因子包括由業務類型、產品類型、入網時間組合的組合因子；

判斷所述業務組合因子是否與預設業務場景匹配，若所述業務組合因子與預設業務場景匹配，則確定所述單個業務因子對應的所述目標消息是實時有效數據，用以對相應的用戶進行行為分析；

若所述目標消息是所述實時有效數據，則將所述單個業務因子對應的業務信息發送至目標系統，以使所述目標系統根據所述業務信息為相應的用戶提供業務服務。

2.根據權利要求1所述的方法，其特征在于，所述獲取多條目標消息，包括：

通過所述目標Kafka分別獲取數據庫日志的消息數據、接觸式文件的消息數據、其他Kafka中的消息數據并存儲至所述目標Kafka中的不同的主題文件；

通過所述目標Kafka對所述目標Kafka中不同的主題文件中的消息數據進行消息過濾，得到多條第一消息；

從所述目標Kafka中獲取通過所述目標Kafka對所述多條第一消息按照預設格式進行格式轉換得到的多條目標消息。

3.根據權利要求1所述的方法，其特征在于，所述對各條所述目標消息進行處理，得到各條所述目標消息對應的單個業務因子，包括：

對各條所述目標消息進行解析，得到各條所述目標消息中包含的所有字段；

針對每條所述目標消息，提取相應的所有字段對應的單個業務因子；

其中，所述單個業務因子包括業務類型、產品、資費、時間、剩余量、位置變化、機型變化。

4.根據權利要求1所述的方法，其特征在于，所述方法還包括：

若所述業務組合因子與預設業務場景不匹配，則刪除所述單個業務因子對應的所述目標消息。

5.根據權利要求1-4任一項所述的方法，其特征在于，所述若所述目標消息是所述實時有效數據，則將所述單個業務因子對應的業務信息發送至目標系統，包括：

若所述目標消息是所述實時有效數據，則根據所述單個業務因子，觸發與預設業務場景匹配的目標業務場景，所述目標業務場景包括套餐升檔推薦、流量資費推薦、增值業務推薦、流量贈送、語音贈送、話費贈送；

根據所述目標業務場景，生成對應的業務信息；

通過接口能力平臺將所述業務信息發送至目標系統，以使所述目標系統將所述業務信息推送至對應的用戶端。

6.根據權利要求5所述的方法，其特征在于，在所述將所述單個業務因子對應的業務信息發送至目標系統之前，所述方法還包括：

根據業務的優先級，對預設業務場景劃分為重點維保場景和普通維保場景；

為所述重點維保場景配置有一條讀取Kafka消息的通道，為所述普通維保場景配置有針對同一業務分區的所有場景共用一個讀取Kafka消息的通道。