[發明專利]基于數據流的報表指標的顯示方法、裝置及終端

有效

• 申請號: 201811280786.1
• 申請日: 2018-10-30
• 公開（公告）號: CN109614417B
• 公開（公告）日: 2020-09-22
• 發明（設計）人: 唐錦陽;羅華林;余文喆
• 申請（專利權）人: 北京奇藝世紀科技有限公司
• 主分類號: G06F16/2458
• 分類號: G06F16/2458;G06F16/248
• 代理公司: 北京潤澤恒知識產權代理有限公司 11319
• 代理人: 莎日娜

1.一種基于數據流的報表指標的顯示方法，其特征在于，包括：

將接收到的流式數據按照數據類型拆分成多個數據流，所述多個數據流包括：第一日志流和第二日志流，且第一日志流和第二日志流存在先后關系；

將所述第一日志流按照關鍵字key緩存到數據庫中；

提取所述第二日志流的關鍵字key；

從所述數據庫中查詢所述第二日志流的關鍵字key；

如果查詢到所述關鍵字key，則讀取與所述關鍵字key對應的第一日志流的數值value；

將與所述關鍵字key對應的數值value添加到所述第二日志流中，以將所述第二日志流與對應的第一日志流進行實時關聯；

統計關聯后的第二日志流，得到對應的報表指標；

實時顯示所述報表指標。

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

所述關鍵字key包括：用戶ID和視頻ID，所述數值value包括：需要提供給第二日志流的內容的時間戳和維度信息。

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

將拆分得到的所述第一日志流按照設定的時間通過對應的布隆過濾器進行過濾；

對通過每個時間的布隆過濾器的所述第一日志流的關鍵字key進行標記，得到對應的標志位；

將所述標志位對應的關鍵字key及第一日志流同時存儲到內存分布式數據庫中和普通分布式數據庫中。

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

提取所述第二日志流的關鍵字key；

按照所述關鍵字key查詢標志位；

如果查詢到對應的標志位，則根據所述標志位確定對應布隆過濾器的時間；

判斷所述時間與當前時間的差值是否大于等于設定緩存閾值；

如果所述差值大于等于設定的緩存閾值，則從所述普通分布式數據庫讀取與所述標志位對應的第一日志流的數值value；

如果所述差值不大于等于設定的緩存閾值，則從所述內存分布式數據庫中讀取與所述標志位對應的第一日志流的數值value；

其中，所述將所述第二日志流與對應的第一日志流進行實時關聯，包括：

將與所述標志位對應的第一日志流的數值value添加到所述第二日志流中。

5.一種基于數據流的報表指標的顯示裝置，其特征在于，包括：

拆分模塊，用于將接收到的流式數據按照數據類型拆分成多個數據流，所述多個數據流包括：第一日志流和第二日志流，且第一日志流和第二日志流存在先后關系；

緩存模塊，用于將所述第一日志流按照關鍵字key緩存到數據庫中；

第一確定模塊，用于從所述數據庫中為所述第二日志流確定對應的第一日志流；

關聯模塊，用于將與所述關鍵字key對應的數值value添加到所述第二日志流中，以將所述第二日志流與對應的第一日志流進行實時關聯；

統計模塊，用于統計關聯后的第二日志流，得到對應的報表指標；

顯示模塊，用于實時顯示所述報表指標；

所述第一確定模塊包括：

第一提取模塊，用于提取所述第二日志流的關鍵字key；

第一查詢模塊，用于從所述數據庫中查詢所述第二日志流的關鍵字key；

第一讀取模塊，用于在所述查詢模塊查詢到所述關鍵字key時，讀取與所述關鍵字key對應的第一日志流的數值value。

6.根據權利要求5所述的裝置，其特征在于，

所述第一提取模塊提取的所述關鍵字key包括：用戶ID和視頻ID；

所述第一讀取模塊讀取的所述數值value包括：需要提供給第二日志流的內容的時間戳和維度信息。

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

過濾模塊，用于將所述拆分模塊拆分得到的所述第一日志流按照設定的時間通過對應的布隆過濾器進行過濾；

標記模塊，用于對通過每個時間的布隆過濾器的所述第一日志流的關鍵字key分別進行標記，得到對應的標志位；

存儲模塊，用于將所述標志位對應的關鍵字key及第一日志流同時存儲到內存分布式數據庫中和普通分布式數據庫中。