[發明專利]DMP受眾數據實時處理方法及裝置、計算機可讀存儲介質

在審

• 申請號: 201910219126.0
• 申請日: 2019-03-21
• 公開（公告）號: CN111724187A
• 公開（公告）日: 2020-09-29
• 發明（設計）人: 唐英榮
• 申請（專利權）人: 上海晶贊融宣科技有限公司
• 主分類號: G06Q30/02
• 分類號: G06Q30/02;G06N5/02
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 李笑笑;吳敏

一種DMP受眾數據實時處理方法及裝置、計算機可讀存儲介質，所述DMP受眾數據實時處理方法，包括：將實時獲取到的受眾數據輸入至kafka容器；按照預設的配置條件對輸入至所述kafka容器的受眾數據進行識別，得到用戶數據片段；其中，所述用戶數據片段包括：用戶標識、用戶屬性信息以及預設時間段內的用戶行為信息；根據預設的知識庫，對所述用戶數據片段進行翻譯，得到具有預設標簽維度的用戶數據片段；將所述具有預設標簽維度的用戶數據片段進行合并，得到處理后的實時用戶數據片段。采用上述方案，能夠提高DMP受眾數據處理的實時性。

技術領域

本發明實施例涉及數據處理技術領域，尤其涉及一種DMP受眾數據實時處理方法及裝置、計算機可讀存儲介質。

背景技術

傳統的數據管理平臺(Date Management Platform，DMP)是把分散的第一、第三方數據進行整合納入統一的技術平臺，并對這些數據進行標準化和細分，讓用戶可以把這些細分結果推向現有的互動營銷環境里。

然而，目前，DPM受眾數據的處理通常是進行離線數據處理，數據處理的實時性較差。

發明內容

本發明實施例解決的技術問題是如何提高DMP受眾數據處理的實時性。

為解決上述技術問題，本發明實施例提供一種DMP受眾數據實時處理方法，包括：將實時獲取到的受眾數據輸入至kafka容器；按照預設的配置條件對輸入至所述kafka容器的受眾數據進行識別，得到用戶數據片段；其中，所述用戶數據片段包括：用戶標識、用戶屬性信息以及預設時間段內的用戶行為信息；根據預設的知識庫，對所述用戶數據片段進行翻譯，得到具有預設標簽維度的用戶數據片段；將所述具有預設標簽維度的用戶數據片段進行合并，得到處理后的實時用戶數據片段。

可選的，在將實時獲取到的受眾數據輸入至kafka容器之前，還包括：將所述受眾數據的格式轉換成kafka容器可以識別的數據格式。

可選的，所述將所述受眾數據轉換成預設數據格式，包括：將所述受眾數據轉換成schema格式。

可選的，在得到用戶數據片段之后，還包括：將所述用戶數據片段寫入kafka容器的識別主體區域。

可選的，所述根據預設的知識庫，對的所述用戶數據片段進行翻譯，包括：按照預設的拆分條件，將所述用戶數據片段拆分為若干個子片段；從所述知識庫中獲取至少一個子片段對應的附屬信息，所述附屬信息與所述預設標簽維度相對應；將所述若干個子片段以及所述至少一個子片段對應的附屬信息進行合并，得到具有預設標簽維度的用戶數據片段。

可選的，在對所述用戶數據片段進行翻譯后，還包括：將所述用戶行為信息轉換成所述用戶屬性信息。

可選的，在得到處理后的實時用戶數據片段之后，還包括：將所述實時用戶數據片段存儲于集群中。

可選的，在得到處理后的實時用戶數據片段并存儲于集群之后，還包括：當接收到用戶的請求指令后，獲取所述用戶的實時畫像；根據所述用戶的實時畫像，從所述集群中查詢所述用戶對應的實時用戶數據片段。

本發明實施例還提供一種DMP受眾數據實時處理裝置，包括：獲取單元，適于實時獲取受眾數據；輸入單元，適于將實時獲取到的受眾數據輸入至kafka容器；識別單元，適于按照預設的配置條件對輸入至所述kafka容器的受眾數據進行識別，得到用戶數據片段；其中，所述用戶數據片段包括：用戶標識、用戶屬性信息以及預設時間段內的用戶行為信息；翻譯單元，適于根據預設的知識庫，對所述用戶數據片段進行翻譯，得到具有預設標簽維度的用戶數據片段；合并單元，適于將所述具有預設標簽維度的用戶數據片段進行合并，得到處理后的實時用戶數據片段。

可選的，所述DMP受眾數據實時處理裝置還包括：第一轉換單元，適于在將實時獲取到的受眾數據輸入至kafka容器之前，將所述受眾數據的格式轉換成kafka容器可以識別的數據格式。