[發明專利]基于流計算的視頻設備在線時長的統計方法、裝置及終端

有效

• 申請號: 202010116598.6
• 申請日: 2020-02-25
• 公開（公告）號: CN111263120B
• 公開（公告）日: 2021-05-25
• 發明（設計）人: 欒潤峰;楊爽
• 申請（專利權）人: 北京金和網絡股份有限公司
• 主分類號: H04N7/18
• 分類號: H04N7/18;H04N17/00
• 代理公司: 北京細軟智谷知識產權代理有限責任公司 11471
• 代理人: 秦瓊

1.基于流計算的視頻設備在線時長的統計方法，其特征在于，所述方法包括：

根據預設時間周期定時獲取根據所有視頻設備各自累計在線狀態數據流得到的激活狀態數據流，以及獲取根據所有視頻設備各自上下線狀態反饋消息得到的上下線狀態數據流；

基于所述激活狀態數據流和所述上下線狀態數據流得到所有視頻設備各自的累計在線時長；

所述方法還包括：

根據所有視頻設備各自的最新實時累計統計狀態數據數據流得到所有視頻設備在下一預設時間周期的所述激活狀態數據流；

其中，所述基于所述激活狀態數據流和所述上下線狀態數據流得到所有視頻設備各自的累計在線時長，包括：

將所述激活狀態數據流與所述上下線狀態數據流進行流聯合處理，合并成為一個全部設備狀態數據流；

基于所述全部設備狀態數據流，判斷在當前時間周期內所有視頻設備各自是否有上下線狀態反饋消息，根據判斷結果確定是利用上下線狀態反饋消息還是利用激活狀態消息得到當前時間周期內所有視頻設備各自的上下線統計數據流；

將得到的當前時間周期內所有視頻設備各自的上下線統計數據流與各自之前累計狀態數據流進行合并，得到所有視頻設備各自的最新實時累計統計狀態數據數據流；

根據所有視頻設備各自的最新實時累計統計狀態數據數據流對所有視頻設備各自進行在線時長統計。

2.根據權利要求1所述的方法，其特征在于，所述判斷在當前時間周期內所有視頻設備各自是否有上下線狀態反饋消息，根據判斷結果確定是利用上下線狀態反饋消息還是利用激活狀態消息得到當前時間周期內所有視頻設備各自的上下線統計數據流，包括：

在當前時間周期內，如果某個視頻設備有上下線狀態反饋消息，則舍棄當前時間周期內含有的該視頻設備的激活狀態消息，根據該視頻設備的上下線狀態反饋消息計算該視頻設備在當前時間周期內上下線時長統計結果，以此形成該視頻設備當前時間周期內的上下線統計數據流。

3.根據權利要求1所述的方法，其特征在于，所述判斷在當前時間周期內所有視頻設備各自是否有上下線狀態反饋消息，根據判斷結果確定是利用上下線狀態反饋消息還是利用激活狀態消息得到當前時間周期內所有視頻設備各自的上下線統計數據流，包括：

在當前時間周期內，如果某個視頻設備沒有上下線狀態反饋消息，而僅含有激活狀態消息，則將激活狀態消息作為結果返回，以此形成該視頻設備當前時間周期內的上下線統計數據流。

4.根據權利要求1所述的方法，其特征在于，所述全部設備狀態數據流中，所有消息按照消息產生時間戳升序進行排序。

5.基于流計算的視頻設備在線時長的統計裝置，其特征在于，包括：

獲取模塊，用于根據預設時間周期定時獲取根據所有視頻設備各自累計在線狀態數據流得到的激活狀態數據流，以及獲取根據所有視頻設備各自上下線狀態反饋消息得到的上下線狀態數據流；

第一得到模塊，用于基于所述激活狀態數據流和所述上下線狀態數據流得到所有視頻設備各自的累計在線時長；

其中，所述基于所述激活狀態數據流和所述上下線狀態數據流得到所有視頻設備各自的累計在線時長，包括：

將所述激活狀態數據流與所述上下線狀態數據流進行流聯合處理，合并成為一個全部設備狀態數據流；

基于所述全部設備狀態數據流，判斷在當前時間周期內所有視頻設備各自是否有上下線狀態反饋消息，根據判斷結果確定是利用上下線狀態反饋消息還是利用激活狀態消息得到當前時間周期內所有視頻設備各自的上下線統計數據流；

將得到的當前時間周期內所有視頻設備各自的上下線統計數據流與各自之前累計狀態數據流進行合并，得到所有視頻設備各自的最新實時累計統計狀態數據數據流；

根據所有視頻設備各自的最新實時累計統計狀態數據數據流對所有視頻設備各自進行在線時長統計；

所述統計裝置，還包括：

第二得到模塊，用于根據所有視頻設備各自的最新實時累計統計狀態數據數據流得到所有視頻設備在下一預設時間周期的所述激活狀態數據流。

6.一種可讀存儲介質，其上存儲有程序，其特征在于，該程序被處理器執行時實現權利要求1-4任一項所述方法的步驟。

7.一種視頻監控終端，其特征在于，包括：

存儲器，其上存儲有可執行程序；

處理器，用于執行所述存儲器中的所述可執行程序，以實現權利要求1-4中任一項所述方法的步驟。