[發明專利]一種數據處理方法及服務器、計算機存儲介質

有效

• 申請號: 201710326633.5
• 申請日: 2017-05-10
• 公開（公告）號: CN108874812B
• 公開（公告）日: 2021-12-10
• 發明（設計）人: 鐘沛珉
• 申請（專利權）人: 騰訊科技（北京）有限公司
• 主分類號: G06F16/9535
• 分類號: G06F16/9535
• 代理公司: 北京派特恩知識產權代理有限公司 11270
• 代理人: 蔣雅潔;張穎玲

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

收集實時的數據流，所述實時的數據流包含表征用戶行為的第一類數據和表征用戶關注數據自身的第二類數據；

根據所述第一類數據和所述第二類數據建立用戶狀態隊列；

根據觸發所述第一類數據的時間信息，標識位于所述用戶狀態隊列中的每一個用戶狀態信息，得到所述用戶狀態隊列中以動態時間窗口表示的每一個用戶狀態；

根據所述用戶狀態隊列得到用戶狀態特征；

獲取待處理的候選數據和運算模型；

將所述用戶狀態特征和所述待處理的候選數據作為所述運算模型的輸入參數，經所述運算模型的運算后得到輸出參數；

根據所述輸出參數得到數據處理結果，發送所述數據處理結果。

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

收集所述實時的數據流時得到新增的第二類數據；

提取當前用戶狀態隊列；

將新增的第二類數據直接添加入所述當前用戶狀態隊列的隊尾部，對所述當前用戶狀態隊列進行更新。

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

收集所述實時的數據流時得到新增的第一類數據；

提取當前用戶狀態隊列；

在所述當前用戶狀態隊列中，查詢到與新增的第一類數據對應的第二類數據；

從所述當前用戶狀態隊列中，刪除所述第二類數據所在的用戶狀態信息；

將位于被刪除用戶狀態信息后的所有用戶狀態信息進行位置依次前移，對所述當前用戶狀態隊列進行更新；

將新增的第一類數據添加入更新后的用戶狀態隊列的隊尾部。

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

所述第一類數據和/或第二類數據實時更新時，觸發對當前用戶狀態隊列的更新；

所述當前用戶狀態隊列的隊列長度達到第一閾值時，將處于所述當前用戶狀態隊列中位置靠前的用戶狀態信息依次從所述當前用戶狀態隊列中刪除，將處于所述當前用戶狀態隊列中位置靠后的用戶狀態信息依次前移，將實時更新的數據插入所述當前用戶狀態隊列的隊尾部。

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

所述第一類數據和/或第二類數據實時更新時，觸發對當前用戶狀態隊列的更新；

獲取處于所述當前用戶狀態隊列中隊尾部的用戶狀態信息所對應的第一時間信息；

根據所述第一時間信息與當前時間信息的差值來判斷所述當前用戶狀態隊列中隊列內容的有效性，若所述差值大于第二閾值，則對所述當前用戶狀態隊列中的所有用戶狀態信息進行清空。

6.一種服務器，其特征在于，所述服務器包括：

收集單元，用于收集實時的數據流，所述實時的數據流包含表征用戶行為的第一類數據和表征用戶關注數據自身的第二類數據；

隊列建立單元，用于根據所述第一類數據和所述第二類數據建立用戶狀態隊列；

用戶狀態描述單元，用于根據觸發所述第一類數據的時間信息，標識位于所述用戶狀態隊列中的每一個用戶狀態信息，得到所述用戶狀態隊列中以動態時間窗口表示的每一個用戶狀態；

特征確定單元，用于根據所述用戶狀態隊列得到用戶狀態特征；

獲取單元，用于獲取待處理的候選數據和運算模型；

運算單元，用于將所述用戶狀態特征和所述待處理的候選數據作為所述運算模型的輸入參數，經所述運算模型的運算后得到輸出參數；

發送單元，用于根據所述輸出參數得到數據處理結果，發送所述數據處理結果。

7.根據權利要求6所述的服務器，其特征在于，所述收集單元，進一步用于：

收集所述實時的數據流時得到新增的第二類數據；

所述服務器還包括：

提取單元，用于提取當前用戶狀態隊列；

更新單元，用于將新增的第二類數據直接添加入所述當前用戶狀態隊列的隊尾部，對所述當前用戶狀態隊列進行更新。