[發明專利]數據處理方法及計算機可讀介質

有效

• 申請號: 201811216590.6
• 申請日: 2018-10-18
• 公開（公告）號: CN109508244B
• 公開（公告）日: 2021-03-12
• 發明（設計）人: 陳曠;付國為;李杰
• 申請（專利權）人: 北京新唐思創教育科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京合智同創知識產權代理有限公司 11545
• 代理人: 李杰;蘭淑鐸

本發明實施例提供一種數據處理方法及計算機可讀介質。數據處理方法包括：從第一消息隊列中獲取待存儲的數據包，其中，數據包中包括業務數據和對應的時間信息；根據時間信息，將業務數據存儲至與時間信息對應的數據存儲對象中；獲取并更新與數據存儲對象對應的數據存儲清單，其中，數據存儲清單中包含有預設的待存儲至數據存儲對象中的至少一個數據包的信息；判斷數據存儲清單中的待存儲的所有數據包是否已全部存儲至數據存儲對象；若是，則將數據存儲對象中存儲的所有業務數據發布至第二消息隊列；若否，則對數據存儲對象中已存儲的業務數據進行持久化存儲。該數據處理方法可以提高數據利用率。

技術領域

本發明實施例涉及計算機技術領域，尤其涉及一種數據處理方法及計算機可讀介質。

背景技術

目前，企業的發展越來越依賴于通過計算機和網絡系統實現管理。然而，企業的高速發展使得企業內部存在很多遺留系統和遺留數據，特別是對于大公司和運營時間比較長的公司，這樣的系統和數據會非常多。

以包括多條業務線的企業系統為例，可能存在著諸如：1)不同業務線間相同用戶的唯一標識不同；2)不同業務線記錄的用戶信息有差別；3)不同業務線的技術架構有很大差別，導致原始數據的存儲分散，等等問題。由此，導致數據的整合和清理極端困難，無法對已有數據進行有效利用。

發明內容

有鑒于此，本發明實施例所解決的技術問題之一在于提供一種數據處理方法及計算機可讀介質，用以克服現有技術中無法對已有數據進行有效利用的問題。

本發明實施例的第一方面，提供一種數據處理方法，其包括：從第一消息隊列中獲取待存儲的數據包，其中，所述數據包中包括業務數據和對應的時間信息；根據所述時間信息，將所述業務數據存儲至與所述時間信息對應的數據存儲對象中；獲取并更新與所述數據存儲對象對應的數據存儲清單，其中，所述數據存儲清單中包含有預設的待存儲至所述數據存儲對象中的至少一個數據包的信息；判斷所述數據存儲清單中的待存儲的所有數據包是否已全部存儲至所述數據存儲對象；若是，則將所述數據存儲對象中存儲的所有業務數據發布至第二消息隊列；若否，則對所述數據存儲對象中已存儲的業務數據進行持久化存儲。

本發明實施例的第二方面，提供一種計算機可讀介質，其特征在于，所述計算機存儲介質存儲有：用于從第一消息隊列中獲取待存儲的數據包的指令，其中，所述數據包中包括業務數據和對應的時間信息；用于根據所述時間信息，將所述業務數據存儲至與所述時間信息對應的數據存儲對象中的指令；用于獲取并更新與所述數據存儲對象對應的數據存儲清單的指令，其中，所述數據存儲清單中包含有預設的待存儲至所述數據存儲對象中的至少一個數據包的信息；用于判斷所述數據存儲清單中的待存儲的所有數據包是否已全部存儲至所述數據存儲對象的指令；用于在判斷已全部存儲時，將所述數據存儲對象中存儲的所有業務數據發布至第二消息隊列的指令；用于在判斷未全部存儲時，則對所述數據存儲對象中已存儲的業務數據進行持久化存儲的指令。

由以上技術方案可見，本發明實施例的數據處理方案，該方案對從不同業務線讀取的業務數據，根據不同業務線的業務數據的時間信息，對各個業務數據在時間線上進行同步，保證后續利用同步后的業務數據進行分析處理時事件邏輯正確，進而使這些業務數據能夠被充分利用。

附圖說明

為了更清楚地說明本發明實施例或現有技術中的技術方案，下面將對實施例或現有技術描述中所需要使用的附圖作簡單地介紹，顯而易見地，下面描述中的附圖僅僅是本發明實施例中記載的一些實施例，對于本領域普通技術人員來講，還可以根據這些附圖獲得其他的附圖。

圖1示出了本發明的實施例一的數據處理方法的流程圖。

具體實施方式

當然，實施本發明實施例的任一技術方案必不一定需要同時達到以上的所有優點。