[發明專利]一種行為數據會話ID分配的方法、系統及設備

有效

• 申請號: 202110620365.4
• 申請日: 2021-06-03
• 公開（公告）號: CN113364863B
• 公開（公告）日: 2022-12-30
• 發明（設計）人: 梁瑞騰
• 申請（專利權）人: 上海微盟企業發展有限公司
• 主分類號: H04L67/14
• 分類號: H04L67/14;H04L61/3015
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 王曉坤

本申請公開了一種行為數據會話ID分配的方法，包括：獲取當前接收的行為數據的時間戳，并獲取第一指針的值；若所述第一會話ID不為空，則計算所述行為數據的時間戳與所述第一會話末尾時刻的第一差值；若所述第一差值小于零，則計算所述第一會話開始時刻與所述行為數據的時間戳的第二差值；若所述第二差值小于第一閾值，則將所述第一會話開始時刻更新為所述行為數據的時間戳，并將所述第一會話ID分配給所述行為數據。本申請在實時計算過程中完成了對亂序數據的會話ID分配，避免了亂序數據處理延遲。本申請同時還提供了一種行為數據會話ID分配的系統、設備及可讀存儲介質，具有上述有益效果。

技術領域

本申請涉及行為數據會話ID分配領域，特別涉及一種行為數據會話ID分配的方法、系統、設備及可讀存儲介質。

背景技術

隨著Web技術的不斷發展，電子商務活動日漸頻繁。客戶對企業網站的每一次點擊都會被企業網絡服務器記錄在日志中，由此產生了點擊流數據。點擊流數據一方面數據量巨大，另一方面很難保證數據是完整按照時間順序排序的，然而有些業務邏輯的實現依賴數據的時間順序，與點擊流數據亂序的現實相悖，以至于這部分邏輯不能實時處理。

例如在對行為數據進行解析時，一個用戶如果在預設時間內(例如十分鐘)不做任何操作(反映到數據上，就是連續十分鐘后臺都收不到該用戶的行為數據)，那么他本次的會話自動結束。如果十分鐘之后他產生了新的行為數據了，此時就會分配一個新的會話ID給這些行為數據。在實時的場景中，由于數據傳輸阻塞，可能會出現系統在10點10分的時候接收到一個用戶在10點整產生的行為數據的情況，而此時系統又必須在很短的時間內為該行為數據分配一個會話ID給這條記錄，否則就會造成數據處理延遲。

因此，如何在實時計算過程中實現對亂序數據的會話ID分配是本領域技術人員目前需要解決的技術問題。

發明內容

本申請的目的是提供一種行為數據會話ID分配的方法、系統、設備及可讀存儲介質，用于在實時計算過程中實現對亂序數據的會話ID分配。

為解決上述技術問題，本申請提供一種行為數據會話ID分配的方法，該方法包括：

獲取當前接收的行為數據的時間戳，并獲取第一指針的值；所述第一指針為順序到達數據的指針，所述第一指針包括第一會話ID、第一會話初始時刻、第一會話末尾時刻；

若所述第一會話ID不為空，則計算所述行為數據的時間戳與所述第一會話末尾時刻的第一差值；

若所述第一差值小于零，則計算所述第一會話開始時刻與所述行為數據的時間戳的第二差值；

若所述第二差值小于第一閾值，則將所述第一會話開始時刻更新為所述行為數據的時間戳，并將所述第一會話ID分配給所述行為數據。

可選的，還包括：

若所述第一差值大于所述第一閾值，則生成新第一會話ID分配給所述行為數據，并將所述第一會話初始時刻和所述第一會話末尾時刻更新為所述行為數據的時間戳；

若所述第一差值大于零且小于或等于所述第一閾值，則將所述第一會話末尾時刻更新為所述行為數據的時間戳與所述第一會話開始時刻的最小值，并將所述第一會話ID分配給所述行為數據。

可選的，還包括：

若所述第一會話ID為空，則生成新第一會話ID分配給所述行為數據，并將所述第一會話初始時刻和所述第一會話末尾時刻更新為所述行為數據的時間戳。

可選的，還包括：

若所述第二差值大于或等于所述第一閾值，則獲取第二指針的值；所述第二指針為逆序到達數據的指針，所述第二指針包括第二會話ID、第二會話初始時刻、第二會話末尾時刻；

若所述第二會話ID不為空，則計算所述行為數據的時間戳與所述第二會話末尾時刻的第三差值；