[發明專利]一種信息推送方法、計算機可讀的存儲介質及電子裝置

在審

• 申請號: 202211335711.5
• 申請日: 2022-10-28
• 公開（公告）號: CN115630070A
• 公開（公告）日: 2023-01-20
• 發明（設計）人: 張玉福
• 申請（專利權）人: 海爾優家智能科技（北京）有限公司;青島海爾科技有限公司;海爾智家股份有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/21
• 代理公司: 北京瀚仁知識產權代理事務所(普通合伙) 11482
• 代理人: 陳敏

本申請公開了一種信息推送方法、計算機可讀的存儲介質及電子裝置，涉及計算機技術領域，該信息推送方法包括：將源數據庫的歷史全量數據存儲至數據庫寬表；獲取源數據庫的變化數據，并將變化數據寫入數據庫寬表，得到更新后的數據庫寬表；從更新后的數據庫寬表中確定出與變化數據相關聯的維度數據，并對變化數據和維度數據進行分類，得到多個維度數據集；根據多個維度數據集和自定義篩選條件進行信息推送。該方法通過將歷史全量數據以及變化數據寫入數據庫寬表，將信息推送業務中的數據訪問由原來的MySQL數據庫轉移到數據庫寬表，降低了對MySQL數據庫的過度訪問，有效避免服務器的崩潰，實現了高速查詢，有利于提高響應速度，提升用戶的體驗感。

技術領域

本申請涉及計算機技術領域，具體而言，涉及一種信息推送方法、計算機可讀的存儲介質及電子裝置。

背景技術

隨著在線購物的盛行，電子商務的用戶數量日漸增多，在不同業務場景下也隨之產生了大量的、快速且實時變化的流式數據。基于用戶在不同業務場景下產生的大量數據并對數據進行分析，可為用戶提供合理的購物引導，例如，針對各類產品，可以結合用戶所在位置向用戶推薦其所在位置合理范圍內的有效店鋪。

為了提高推薦的實時性，相關技術中引入了Flink框架進行流式處理，但數據存儲媒介延續著對傳統關系型數據庫如MySQL的依賴使用，隨著數據量的增加在進行業務查詢搜索時，直接從MySQL數據庫進行數據讀取存在以下問題：一方面，需要對各種數據進行關聯查詢過濾，查詢響應時間較長；另一方面，對數據庫的訪問頻率增加，容易出現IO交互鏈路堵塞，進而造成數據庫崩潰以及業務處理異常退出的問題，因而也影響信息推送效果。

發明內容

本發明旨在解決上述技術問題，即，解決現有進行信息推送時響應時間長，且容易出現數據庫崩潰以及業務處理異常退出的問題。

在第一方面，本申請提供了一種信息推送方法，其包括：

將源數據庫的歷史全量數據存儲至數據庫寬表；

獲取所述源數據庫的變化數據，并將所述變化數據寫入所述數據庫寬表，得到更新后的數據庫寬表；

從所述更新后的數據庫寬表中確定出與所述變化數據相關聯的維度數據，并對所述變化數據和所述維度數據進行分類，得到多個維度數據集；

根據所述多個維度數據集和自定義篩選條件進行信息推送。

在一些實施例中，所述獲取所述源數據庫的變化數據包括：通過讀取所述源數據庫的數據變更日志獲取所述源數據庫的變化數據。

在一些實施例中，所述將所述變化數據寫入所述數據庫寬表，得到更新后的數據庫寬表包括：

將所述變化數據引入流式數據源，得到變化數據流；

根據所述變化數據流的操作模式，對所述變化數據流進行用戶自定義函數處理，以及，確定與所述變化數據流關聯的維度屬性；

將處理后的所述變化數據流寫入所述數據庫寬表，并將所述變化數據流以及與所述變化數據流關聯的維度屬性的數據聚合存儲，得到更新后的數據庫寬表。

在一些實施例中，所述確定與所述變化數據流關聯的維度屬性包括：根據所述變化數據流的源表確定所述變化數據流的維度屬性，根據所述變化數據流的維度屬性確定與所述變化數據流關聯的維度屬性。

在一些實施例中，所述將所述變化數據引入所述流式數據源，得到變化數據流之后，所述方法還包括：采用Flink框架讀取所述流式數據源中的所述變化數據流。

在一些實施例中，所述對所述變化數據和所述維度數據進行分類，包括：

根據所述變化數據的源表確定所述變化數據的維度屬性；

基于所述維度屬性對所述變化數據和所述維度數據進行分類。