[發(fā)明專利]一種數(shù)據(jù)流的關(guān)聯(lián)方法及裝置

有效

• 申請?zhí)枺?/td>: 201811644550.1
• 申請日: 2018-12-30
• 公開（公告）號: CN109726223B
• 公開（公告）日: 2021-12-03
• 發(fā)明（設(shè)計）人: 韓紅根
• 申請（專利權(quán)）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2458
• 代理公司: 北京集佳知識產(chǎn)權(quán)代理有限公司 11227
• 代理人: 王寶筠

本申請公開了一種數(shù)據(jù)流的關(guān)聯(lián)方法及裝置，其中，方法包括：存儲第一數(shù)據(jù)流中的數(shù)據(jù)；在接收到第二數(shù)據(jù)流中的關(guān)聯(lián)數(shù)據(jù)的情況下，判斷已存儲的數(shù)據(jù)中是否存在目標數(shù)據(jù)；所述目標數(shù)據(jù)為預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與所述關(guān)聯(lián)數(shù)據(jù)中預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容相同的數(shù)據(jù)；如果存在，將所述目標數(shù)據(jù)與所述關(guān)聯(lián)數(shù)據(jù)中各項的內(nèi)容作為一組數(shù)據(jù)進行保存。本申請可以避免具有關(guān)聯(lián)的數(shù)據(jù)的丟失。

技術(shù)領(lǐng)域

本申請涉及數(shù)據(jù)處理領(lǐng)域，尤其涉及一種數(shù)據(jù)流的關(guān)聯(lián)方法及裝置。

背景技術(shù)

目前，為了從大量數(shù)據(jù)中挖掘出具有價值的數(shù)據(jù)，需要對多種數(shù)據(jù)進行關(guān)聯(lián)分析，即從多種數(shù)據(jù)中確定出具有關(guān)聯(lián)的數(shù)據(jù)，并對所確定出的具有關(guān)聯(lián)的數(shù)據(jù)進行分析。

目前，對數(shù)據(jù)流進行關(guān)聯(lián)分析的過程中，會出現(xiàn)具有關(guān)聯(lián)的數(shù)據(jù)丟失，進而使得數(shù)據(jù)分析時數(shù)據(jù)的不完整。

發(fā)明內(nèi)容

本申請?zhí)峁┝艘环N數(shù)據(jù)流的關(guān)聯(lián)方法及裝置，目的在于解決關(guān)聯(lián)數(shù)據(jù)丟失的問題。

為了實現(xiàn)上述目的，本申請?zhí)峁┝艘韵录夹g(shù)方案：

本申請公開了一種數(shù)據(jù)流的關(guān)聯(lián)方法，包括：

存儲第一數(shù)據(jù)流中的數(shù)據(jù)；

在接收到第二數(shù)據(jù)流中的關(guān)聯(lián)數(shù)據(jù)的情況下，判斷已存儲的數(shù)據(jù)中是否存在目標數(shù)據(jù)；所述第一數(shù)據(jù)流與所述第二數(shù)據(jù)流為待進行關(guān)聯(lián)操作的數(shù)據(jù)流，且所述第二數(shù)據(jù)流為觸發(fā)關(guān)聯(lián)操作的數(shù)據(jù)流；所述關(guān)聯(lián)數(shù)據(jù)為所述第二數(shù)據(jù)流中的任意一條數(shù)據(jù)；所述目標數(shù)據(jù)為預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與所述關(guān)聯(lián)數(shù)據(jù)中預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容相同的數(shù)據(jù)；

如果存在，將所述目標數(shù)據(jù)與所述關(guān)聯(lián)數(shù)據(jù)中各數(shù)據(jù)項的內(nèi)容作為一組數(shù)據(jù)進行保存。

其中，所述關(guān)聯(lián)數(shù)據(jù)對應(yīng)的數(shù)據(jù)項中包括預(yù)設(shè)的標識項；所述標識項的內(nèi)容唯一標識所述關(guān)聯(lián)數(shù)據(jù)；

在所述判斷已存儲的數(shù)據(jù)中是否存在目標數(shù)據(jù)之后，還包括：

如果存在所述目標數(shù)據(jù)，將所述關(guān)聯(lián)數(shù)據(jù)中的預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與所述標識項的內(nèi)容作為一組數(shù)據(jù)進行保存。

其中，還包括：

在所述判斷已存儲的數(shù)據(jù)中是否存在目標數(shù)據(jù)之前，判斷已保存的預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與標識項的內(nèi)容中，是否存在所述關(guān)聯(lián)數(shù)據(jù)中的預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與標識項的內(nèi)容；

所述判斷已存儲的數(shù)據(jù)中是否存在目標數(shù)據(jù)，包括：

如果不存在所述關(guān)聯(lián)數(shù)據(jù)中的預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與標識項的內(nèi)容時，判斷已存儲的數(shù)據(jù)中是否存在目標數(shù)據(jù)。

其中，在所述判斷已保存的預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與標識項的內(nèi)容中，是否存在所述關(guān)聯(lián)數(shù)據(jù)中的預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與標識項的內(nèi)容之后，還包括：

如果存在所述關(guān)聯(lián)數(shù)據(jù)中的預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與標識項的內(nèi)容時，則接收所述第二數(shù)據(jù)流中的關(guān)聯(lián)數(shù)據(jù)，并返回執(zhí)行判斷已保存的預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與標識項的內(nèi)容中，是否存在所接收到的關(guān)聯(lián)數(shù)據(jù)中預(yù)設(shè)關(guān)聯(lián)項的內(nèi)容與標識項的內(nèi)容的步驟；所述關(guān)聯(lián)數(shù)據(jù)為所述第二數(shù)據(jù)流中的任意一條數(shù)據(jù)。

其中，在所述判斷已存儲的數(shù)據(jù)中是否存在目標數(shù)據(jù)之后，還包括：

如果不存在所述目標數(shù)據(jù)，保存所述關(guān)聯(lián)數(shù)據(jù)；

在預(yù)設(shè)總時長內(nèi)，每隔預(yù)設(shè)時長對所述關(guān)聯(lián)數(shù)據(jù)執(zhí)行所述判斷已存儲的數(shù)據(jù)中是否存在目標數(shù)據(jù)；若存在，則將所述目標數(shù)據(jù)與所述關(guān)聯(lián)數(shù)據(jù)中的各數(shù)據(jù)項的內(nèi)容作為一組數(shù)據(jù)進行保存；

如果在所述預(yù)設(shè)總時長內(nèi)，已存儲的數(shù)據(jù)中不存在目標數(shù)據(jù)，則刪除所述關(guān)聯(lián)數(shù)據(jù)。

本申請還提供了一種數(shù)據(jù)流的關(guān)聯(lián)裝置，包括：

存儲單元，用于存儲第一數(shù)據(jù)流中的數(shù)據(jù)；