[發明專利]一種線索數據分類的方法、裝置、介質及電子設備

在審

• 申請號: 202310163291.5
• 申請日: 2023-02-15
• 公開（公告）號: CN116089544A
• 公開（公告）日: 2023-05-09
• 發明（設計）人: 李由;梁鵬斌;曾文佳
• 申請（專利權）人: 零犀（北京）科技有限公司
• 主分類號: G06F16/28
• 分類號: G06F16/28;G06F16/2455;G06F11/30;G06F9/54
• 代理公司: 北京超凡宏宇專利代理事務所(特殊普通合伙) 11463
• 代理人: 呂愛霞

本申請實施例提供一種線索數據分類的方法、裝置、介質及電子設備，所述方法包括：獲取目標標簽配置規則表，其中，所述目標標簽配置規則表用于定義劃分待處理話單數據的規則；向至少一個流處理線程廣播所述目標標簽配置規則；通過所述目標標簽配置規則所述至少一個流處理線程中的各流處理線程為待處理的話單數據分配標簽。通過本申請的一些實施例保證了流處理的并行能力和數據一致性，提高了數據處理的時效性和吞吐量。

技術領域

本申請涉及數據處理領域，具體而言本申請實施例涉及一種線索數據分類的方法、裝置、介質及電子設備。

背景技術

實時的流處理需要改變流向，由于規則的改變被化為高意向的用戶還是低意向的用戶，實時調整策略的實時生效，做了一個配置表即規則表，這個表與流處理框架結合實現動態的流向的改變。

例如，現有技術每間隔五秒或者三秒查一下庫中的規則確定規則是否變化，變化了再去調整數據流，因此實時性處理較差。

發明內容

本申請實施例的目的在于提供一種線索數據分類的方法、裝置、介質及電子設備，通過本申請的一些實施例保證了流處理的并行能力和數據一致性，提高了數據處理的時效性和吞吐量。

第一方面，本申請實施例提供一種線索數據分類的方法，所述方法包括：獲取目標標簽配置規則表，其中，所述目標標簽配置規則表用于定義劃分待處理話單數據的規則；向至少一個流處理線程廣播所述目標標簽配置規則；通過所述目標標簽配置規則所述至少一個流處理線程中的各流處理線程為待處理的話單數據分配標簽。

本申請的一些實施例通過主動識別目標標簽配置規則表并向用于分類各話單數據的線程廣播該目標標簽配置規則表，進而可以實現根據最新的分類規則完成對話單數據的分類，提升分類結果的準確性。

在一些實施例中，所述獲取目標標簽配置規則表，包括：對數據庫中的標簽配置規則表進行實時監控，當確認所述標簽配置規則表的內容發生變動則將變動后的所述標簽配置規則表作為所述目標標簽配置規則表。

本申請的一些實施例通過識別存儲在數據庫上標簽配置規則表的變化情況來得到改變后的標簽配置規則表(即目標標簽配置規則表)，可以實時獲取最新的對話單分類的標簽配置規則表并最終提升對話單數據分類的準確性。

在一些實施例中，通過flinkCDC監控所述數據庫中的所述標簽配置規則表。

本申請的一些實施例采用flinkCDC技術監控數據庫上存儲的標簽配置規則表的內容是否發生變化，FlinkCDC這是一個可以直接從MySQL、PostgreSQL等數據庫直接讀取全量數據和增量變更數據的組件。。

在一些實施例中，所述數據庫為mysql數據庫。

本申請的一些實施例采用關系型數據庫存儲標簽配置規則表。

在一些實施例中，所述向至少一個流處理線程廣播所述目標標簽配置規則，包括：利用廣播流技術，將所述目標標簽配置規則表發送到所述至少一個流處理線程中。

本申請的一些實施例通過廣播流技術向各個流處理線程廣播最新的標簽配置規則表(即目標標簽配置規則表)。

在一些實施例中，所述廣播流技術為Flink廣播流技術。

第二方面，本申請的一些實施例提供一種線索數據分類的裝置，所述裝置包括：目標標簽配置規則表獲取模塊，被配置為獲取目標標簽配置規則表，其中，所述目標標簽配置規則表用于定義劃分待處理話單數據的規則；廣播模塊，被配置為向至少一個流處理線程廣播所述目標標簽配置規則；標簽分配模塊，被配置為通過所述目標標簽配置規則所述至少一個流處理線程中的各流處理線程為待處理的話單數據分配標簽。

第三方面，本申請的一些實施例提供一種計算機可讀存儲介質，其上存儲有計算機程序，所述程序被處理器執行時可實現如第一方面任意實施例所述的方法。