[發明專利]基于kafka的人群訂閱的方法、系統、終端及存儲介質

在審

• 申請號: 202210979920.7
• 申請日: 2022-08-16
• 公開（公告）號: CN115408458A
• 公開（公告）日: 2022-11-29
• 發明（設計）人: 余輝
• 申請（專利權）人: 深圳市酷開網絡科技股份有限公司
• 主分類號: G06F16/25
• 分類號: G06F16/25;G06F16/28
• 代理公司: 深圳市君勝知識產權代理事務所(普通合伙) 44268
• 代理人: 陳專

本發明公開了一種基于kafka的人群訂閱方法、系統、終端及存儲介質，所述方法包括：獲取不同人群的人群數據，控制人群生產程序將所述人群數據發送至kafka，并接收所述kafka返回的狀態數據，將所述狀態數據存儲至關系型數據庫管理系統中；當接收訂閱頁面發送的請求時，將所述狀態數據在所述訂閱頁面進行展示，并在所述訂閱頁面中訂閱人群；基于所述人群，獲取所述關系型數據庫管理系統中所述人群對應的目標狀態數據，并將所述目標狀態數據發送至所述kafka中進行消費，以完成所述人群的訂閱。本發明通過各個團隊在使用用戶畫像系統時，采取訂閱的方式，就能夠獲取所需要的人群進行數據抽取，并且訂閱可以在人群執行之前或人群執行完成之后。

技術領域

本發明涉及計算機技術領域，尤其涉及一種基于kafka的人群訂閱方法、系統、終端及存儲介質。

背景技術

用戶畫像是真實用戶的虛擬代表，是建立在一系列真實數據(Marketing data，Usability data)之上的目標用戶模型，通過用戶調研去了解用戶，根據他們的目標、行為和觀點的差異，將他們區分為不同的類型，然后每種類型中抽取出典型特征，賦予名字、照片、一些人口統計學要素和場景等描述，就形成了一個人物原型(personas)。

現有的技術中用戶畫像系統目前極其普遍，其中各個團隊都在使用公司用戶畫像系統，同時每個團隊只需要本團隊中的人群信息；其次不能將所有人群的數據全部發送給所有團隊，大部分公司會通過一個存儲系統進行存儲人群信息，各個團隊可以去進行查詢再抽取，這樣導致時效性不高，并且人群只能在執行完成之后，才能進行數據抽取。

因此，現有技術還有待于改進和發展。

發明內容

本發明的主要目的在于提供一種基于kafka的人群訂閱方法、系統、終端及存儲介質，旨在解決現有技術中只能在執行完成后對數據進行抽取及抽取的時效性不高的問題。

為實現上述目的，本發明提供一種基于kafka的人群訂閱方法，所述基于kafka的人群訂閱方法包括如下步驟：

獲取不同人群的人群數據，控制人群生產程序將所述人群數據發送至kafka，并接收所述kafka返回的狀態數據，將所述狀態數據存儲至關系型數據庫管理系統中；

當接收訂閱頁面發送的請求時，將所述狀態數據在所述訂閱頁面進行展示，并在所述訂閱頁面中訂閱人群；

基于所述人群，獲取所述關系型數據庫管理系統中所述人群對應的目標狀態數據，并將所述目標狀態數據發送至所述kafka中進行消費，以完成所述人群的訂閱。

可選地，所述的基于kafka的人群訂閱方法，其中，所述獲取不同人群的人群數據，控制人群生產程序將所述人群數據發送至kafka，并接收所述kafka返回的狀態數據，將所述狀態數據存儲至關系型數據庫管理系統中，具體包括：

獲取不同人群的人群數據，控制人群生產程序將所述人群數據按照生產的規范和數據的規范發送至kafka中；

當所述kafka將接收的所述人群數據進行存儲時，接收所述kafka返回不同人群的狀態數據，并將所述狀態數據標記后存儲至關系型數據庫管理系統中。

可選地，所述的基于kafka的人群訂閱方法，其中，所述狀態數據包括Topic、partition、開始偏移量和結束偏移量。

可選地，所述的基于kafka的人群訂閱方法，其中，所述當接收訂閱頁面發送的請求時，將所述狀態數據在所述訂閱頁面進行展示，并在所述訂閱頁面中訂閱人群，具體包括：

當訂閱頁面在預設時間內發送查看狀態數據的請求時，控制所述關系型數據庫管理系統將所有人群的狀態數據在所述訂閱頁面進行展示；

基于所述狀態數據，在所述訂閱頁面選擇人群進行訂閱。