[發明專利]多數據流的數據拼接觸發方法、裝置、電子設備和介質

有效

• 申請號: 202010043192.X
• 申請日: 2020-01-15
• 公開（公告）號: CN113127512B
• 公開（公告）日: 2023-09-29
• 發明（設計）人: 程怡;張小虎;石然;譚偉良
• 申請（專利權）人: 百度在線網絡技術（北京）有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種多數據流的數據拼接觸發方法，其特征在于，包括：

接收多個數據流的數據，其中，所述多個數據流包括一個主數據流和至少一個從數據流；所述主數據流為推廣信息的展現日志數據流，所述從數據流為推廣信息的轉化日志數據流；

對于所述主數據流，基于所述主數據流的主數據中攜帶的主事件時間，確定所述主數據流對應的主低水位值；

對于各所述從數據流，基于所述從數據流的從數據中攜帶的從事件時間，確定所述從數據流對應的從低水位值；

根據所述主低水位值和所述從低水位值，觸發執行對當前時間窗口內的主數據和從數據進行拼接的操作；

其中，所述根據所述主低水位值和所述從低水位值，觸發執行對當前時間窗口內的主數據和從數據進行拼接的操作，包括：

判斷所述主低水位值和所述從低水位值是否滿足預設條件集合中的任一預設條件；其中，各所述預設條件包括：所述主低水位值達到第一預設值，所述從低水位值達到第二預設值；各所述預設條件中的第一預設值相同，各所述預設條件中的第二預設值不同；

若是，則觸發執行對當前時間窗口內的主數據和從數據進行拼接的操作。

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

對于所述主數據流，基于所述主數據流的主數據中攜帶的主事件時間，確定所述主數據是否落入當前時間窗口；

對于各所述從數據流，基于所述從數據流的從數據中攜帶的主事件時間，確定所述從數據是否落入當前時間窗口。

3.一種多數據流的數據拼接觸發裝置，其特征在于，包括：

接收模塊，用于接收多個數據流的數據，其中，所述多個數據流包括一個主數據流和至少一個從數據流；所述主數據流為推廣信息的展現日志數據流，所述從數據流為推廣信息的轉化日志數據流；

第一確定模塊，用于對于所述主數據流，基于所述主數據流的主數據中攜帶的主事件時間，確定所述主數據流對應的主低水位值；

第二確定模塊，用于對于各所述從數據流，基于所述從數據流的從數據中攜帶的從事件時間，確定所述從數據流對應的從低水位值；

觸發模塊，用于根據所述主低水位值和所述從低水位值，觸發執行對當前時間窗口內的主數據和從數據進行拼接的操作；

其中，所述觸發模塊包括：

判斷單元，用于判斷所述主低水位值和所述從低水位值是否滿足預設條件集合中的任一預設條件；其中，各所述預設條件包括：所述主低水位值達到第一預設值，所述從低水位值達到第二預設值；各所述預設條件中的第一預設值相同，各所述預設條件中的第二預設值不同；

觸發單元，用于若判斷單元的判斷結果為是，則觸發執行對當前時間窗口內的主數據和從數據進行拼接的操作。

4.根據權利要求3所述的裝置，其特征在于，所述裝置還包括：

第三確定模塊，用于對于所述主數據流，基于所述主數據流的主數據中攜帶的主事件時間，確定所述主數據是否落入當前時間窗口；

第四確定模塊，用于對于各所述從數據流，基于所述從數據流的從數據中攜帶的主事件時間，確定所述從數據是否落入當前時間窗口。

5.一種電子設備，其特征在于，包括：

至少一個處理器；以及

與所述至少一個處理器通信連接的存儲器；其中，

所述存儲器存儲有可被所述至少一個處理器執行的指令，所述指令被所述至少一個處理器執行，以使所述至少一個處理器能夠執行權利要求1-2中任一項所述的多數據流的數據拼接觸發方法。

6.一種存儲有計算機指令的非瞬時計算機可讀存儲介質，其特征在于，所述計算機指令用于使所述計算機執行權利要求1-2中任一項所述的多數據流的數據拼接觸發方法。