[發明專利]基于開源列式數據庫的畫像應用方法、裝置及存儲介質

在審

• 申請號: 202010571636.7
• 申請日: 2020-06-19
• 公開（公告）號: CN111741360A
• 公開（公告）日: 2020-10-02
• 發明（設計）人: 馬全輝
• 申請（專利權）人: 深圳市酷開網絡科技有限公司
• 主分類號: H04N21/442
• 分類號: H04N21/442;H04N21/466;H04N21/858;G06F16/18;G06F16/22;G06F16/24;G06F16/25
• 代理公司: 深圳市世紀恒程知識產權代理事務所 44287
• 代理人: 肖文靜

1.一種基于開源列式數據庫的畫像應用方法，其特征在于，所述基于開源列式數據庫的畫像應用方法包括以下步驟：

采集當前電視終端的日志數據，并將采集到的所述日志數據寫入預設的開源列式數據庫存儲；

接收前端頁面發送的數據庫語句并執行；

根據當前執行的數據庫語句自所述預設的開源列式數據庫查詢對應的日志數據顯示。

2.如權利要求1所述的基于開源列式數據庫的畫像應用方法，其特征在于，所述采集當前電視終端的日志數據，并將采集到的所述日志數據寫入預設的開源列式數據庫存儲的步驟，包括：

將采集到的所述日志數據寫入kafka消息隊列，并以flink消費所述kafka消息隊列篩選日志數據；

將篩選后的日志數據存儲至預設的開源列式數據庫存儲。

3.如權利要求2所述的基于開源列式數據庫的畫像應用方法，其特征在于，所述將采集到的所述日志數據寫入kafka消息隊列，并以flink消費所述kafka消息隊列以篩選日志數據的步驟，包括：

獲取所述flink消費業務邏輯；

通過所述flink調用獲取到的消費業務邏輯消費所述kafka消息隊列以篩選日志數據。

4.如權利要求2所述的基于開源列式數據庫的畫像應用方法，其特征在于，所述將采集到的所述日志數據寫入kafka消息隊列，并以flink消費所述kafka消息隊列以篩選日志數據的步驟，包括：

確認消費所述kafka消息隊列的訪問量；

若所述訪問量超出預設訪問量閾值時，以預設流量限制消費的訪問量。

5.如權利要求2所述的基于開源列式數據庫的畫像應用方法，其特征在于，所述將篩選后的日志數據存儲至預設的開源列式數據庫存儲的步驟，包括：

整合篩選后的日志數據；

將整合后的日志數據存儲至預設的開源列式數據庫存儲。

6.如權利要求1所述的基于開源列式數據庫的畫像應用方法，其特征在于，所述根據當前執行的數據庫語句自所述預設的開源列式數據庫查詢對應的日志數據顯示的步驟，包括：

確認所述數據庫語句的業務模型；

根據所述業務模型顯示查詢到的所述日志數據。

7.如權利要求1所述的基于開源列式數據庫的畫像應用方法，其特征在于，所述采集當前電視終端的日志數據，并將采集到的所述日志數據寫入預設的開源列式數據庫存儲的步驟之前，還包括：

獲取當前電視終端的數據采集需求；

根據所述數據采集需求埋點日志格式以采集所述電視終端的日志數據。

8.如權利要求1至7任一項所述的基于開源列式數據庫的畫像應用方法，其特征在于，所述基于開源列式數據庫的畫像應用方法，還包括：

新建kafka消息隊列，并根據已新建的所述kafka消息隊列連接flink；

通過所述kafka消息隊列以及連接的flink創建基于開源列式數據庫的日志數據應用框架。

9.一種基于開源列式數據庫的畫像應用裝置，其特征在于，所述裝置包括：存儲器、處理器以及存儲在所述存儲器上并可以在所述處理器上運行的基于開源列式數據庫的畫像應用程序，所述基于開源列式數據庫的畫像應用程序被處理器執行時實現如權利要求1至8任一項所述的基于開源列式數據庫的畫像應用方法的步驟。

10.一種存儲介質，其特征在于，所述存儲介質存儲有基于開源列式數據庫的畫像應用程序，所述基于開源列式數據庫的畫像應用程序被處理器執行時實現如權利要求1至8任一項所述的基于開源列式數據庫的畫像應用方法的步驟。