[發明專利]基于Saas模式的標簽服務系統、方法、設備及介質

在審

• 申請號: 202111100747.0
• 申請日: 2021-09-18
• 公開（公告）號: CN113868574A
• 公開（公告）日: 2021-12-31
• 發明（設計）人: 張志勇;阮東東;張元弟;楊子龍
• 申請（專利權）人: 北京仁科互動網絡技術有限公司
• 主分類號: G06F16/958
• 分類號: G06F16/958;G06F16/955;G06F8/30
• 代理公司: 北京路浩知識產權代理有限公司 11002
• 代理人: 王治東

本發明涉及一種基于Saas模式的標簽服務系統、方法、電子設備、存儲介質，該系統包括：數據獲取節點，用于獲取第一租戶的用戶行為數據流；標簽管理節點，用于根據所述第一租戶配置的標簽信息生成標簽引擎元數據流；標簽計算節點，用于利用標簽引擎，根據從所述用戶行為數據流中獲取的用戶行為數據生成所述用戶行為數據的標簽數據；其中，所述標簽計算節點有多個子節點，所述標簽引擎是基于敏捷開發語言根據所述標簽引擎元數據流生成或實時更新的。本發明中標簽引擎無需停機維護，可以低成本便捷地實時更新，且整個系統構成分布式流處理框架，能夠高吞吐量實時地進行標簽計算，提升了標簽計算效率。

技術領域

本發明涉及互聯網技術領域，尤其涉及一種基于Saas模式的標簽服務系統、方法、電子設備、存儲介質。

背景技術

用戶標簽是對用戶的某個維度特征的描述，很多數據產品，諸如個性化推薦系統、智能運營平臺、廣告系統、CRM等都需要用到用戶標簽。

在當前的標簽系統中，一部分是通過web程序來構建，由于不同用戶的標簽計算需求不同，隨著時間的推移每個用戶的標簽計算需求也會發生變化，因此需要對標簽算法/標簽引擎頻繁地進行更新?，F有技術web程序架構下，通常需要對服務器進行停機更新，其維護成本較高、標簽計算效率較低。

對于現有技術中標簽系統維護成本較高、標簽計算效率較低，現亟需一種低維護成本、高標簽計算效率的解決方案。

發明內容

本發明提供一種基于Saas模式的標簽服務系統、方法、電子設備、存儲介質，用以解決現有技術中標簽系統維護成本較高、標簽計算效率較低的缺陷，實現低維護成本、高標簽計算效率。

本發明提供一種基于Saas模式的標簽服務系統，包括：

數據獲取節點，用于獲取第一租戶的用戶行為數據流；

標簽管理節點，用于根據所述第一租戶配置的標簽信息生成標簽引擎元數據流；

標簽計算節點，用于利用標簽引擎，根據從所述用戶行為數據流中獲取的用戶行為數據生成所述用戶行為數據的標簽數據；其中，所述標簽計算節點有多個子節點，所述標簽引擎是基于敏捷開發語言根據所述標簽引擎元數據流生成或實時更新的。

根據本發明提供的一種標簽服務系統，還包括：

管理分發節點，用于將所述第一租戶的用戶行為數據流中的用戶行為數據分發至所述標簽計算節點的一個子節點；所述管理分發節點，還用于將所述標簽引擎元數據流廣播至所述標簽計算節點的所有子節點。

根據本發明提供的一種標簽服務系統，所述管理分發節點，包括：

第一發布訂閱節點，用于分類存儲多個租戶的用戶行為數據流；所述第一租戶為所述多個租戶中的一個；

第二發布訂閱節點，用于分類存儲所述多個租戶配置的標簽引擎元數據流；

分發子節點，用于根據分桶規則將所述多個租戶的用戶行為數據流中的用戶行為數據分發至所述標簽計算節點的一個子節點；所述分發子節點，還用于將所述多個租戶配置的標簽引擎元數據流廣播至所述標簽計算節點的每一子節點。

根據本發明提供的一種標簽服務系統，所述標簽引擎為Groovy引擎；所述第一發布訂閱節點和所述第二發布訂閱節點是基于kafka的發布訂閱節點；所述分發子節點是基于flink的分發節點。

根據本發明提供的一種標簽服務系統，還包括:

存儲節點，用于將所述用戶行為數據與所述用戶行為數據的標簽數據關聯存儲。

本發明還提供一種基于Saas模式的標簽計算方法，包括：

獲取第一租戶的用戶行為數據流；