[發明專利]一種數據變更消息的通知方法及裝置在審
| 申請號: | 202011361220.9 | 申請日: | 2020-11-27 |
| 公開(公告)號: | CN112347202A | 公開(公告)日: | 2021-02-09 |
| 發明(設計)人: | 梁婷;白晶晶;袁桂飛;祁成 | 申請(專利權)人: | 中國工商銀行股份有限公司 |
| 主分類號: | G06F16/28 | 分類號: | G06F16/28;G06F16/33;G06F16/36;G06F16/383 |
| 代理公司: | 北京三友知識產權代理有限公司 11127 | 代理人: | 任默聞;孫乳筍 |
| 地址: | 100140 北*** | 國省代碼: | 北京;11 |
| 權利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關鍵詞: | 一種 數據 變更 消息 通知 方法 裝置 | ||
本發明屬于大數據技術領域,本發明提供了一種數據變更消息的通知方法及裝置,數據變更消息的通知方法包括:根據待通知的數據變更消息所在的數據庫中的元數據,生成數據關系圖譜;根據數據關系圖譜確定所述待通知的數據變更消息的所有目標節點;發送所述待通知的數據變更消息至所述所有目標節點。本發明將任務調用關系和表依賴關系進行融合,構建一個完整的“數據依賴圖譜”。基于該“數據依賴圖譜”利用圖的遍歷算法進行變更通知,做到精準通知不遺漏任何一個責任人、控制通知層級一次性通知到位的效果。
技術領域
本發明涉及計算機軟件技術領域,特別涉及一種數據變更消息的通知方法及裝置。
背景技術
眾所周知,數據倉庫的數據加工使用了交易系統的生產數據。當生產數據發生變更、業務發展導致數據下線、數據倉庫的加工邏輯發生變化等情況發生時,需要及時通知下游數據使用方,以使下游使用方做出相應的處理。現有技術中,變通通知方案為:變更者發起變更通知申請,描述變更內容,按照數據加工任務的調用依賴關系發送給直接下游使用方。
上述方案適用于一般交易系統變更的通知,對數據倉庫領域變更存在以下兩個問題:
(1)通知范圍不全面。數據倉庫中為了提高數據產出時效性,或使用的數據源長期不更新等原因,會存在加工任務沒有上下游調用關系、但實際使用了加工任務所產出的表的數據情況;按照數據加工任務調用關系通知,即會發生漏通知的情況
(2)通知的層級控制不到位。數據倉庫加工深入往往有幾十層的調度依賴,針對數據下線情況,將會影響下游所有的數據使用方,一層層通知耗費人力資源。
綜上,如何提供一種新的方案,能夠對數據倉庫的數據變更通知做到全面精準、控制層級,是本領域亟待解決的難題。
發明內容
本發明屬于大數據技術領域,根據本發明所提供的數據變更消息的通知方法及裝置,能夠全面精準、控制層級的進行數據變更信息通知,具體地,本發明將任務調用關系和表依賴關系進行融合,構建一個完整的“數據依賴圖譜”。基于該“數據依賴圖譜”利用圖的遍歷算法進行變更通知,做到精準通知不遺漏任何一個責任人、控制通知層級一次性通知到位的效果。
為了實現上述目的,提供了一種數據變更消息的通知方法,包括:
根據待通知的數據變更消息所在的數據庫中的元數據,生成數據關系圖譜;
根據數據關系圖譜確定所述待通知的數據變更消息的所有目標節點;
發送所述待通知的數據變更消息至所述所有目標節點。
優選地,所述根據待通知的數據變更消息所在的數據庫中的元數據,生成數據關系圖譜,包括:
根據待通知的數據變更消息所在的關系型數據庫中的表依賴元數據及/或任務調用元數據,生成數據關系圖譜。
優選地,所述根據待通知的數據變更消息所在的關系型數據庫中的表依賴元數據及/或任務調用元數據,生成數據關系圖譜,包括:
根據所述表依賴元數據及/或任務調用元數據生成所述數據關系圖譜的點;
根據所述關系型數據庫中各節點之間的關系生成所述數據關系圖譜的邊;
根據所述表依賴元數據及/或任務調用元數據的對象生成所述點的屬性。
優選地,所述根據待通知的數據變更消息所在的關系型數據庫中的表依賴元數據及/或任務調用元數據,生成數據關系圖譜,還包括
根據所述關系型數據庫的表名生成加工任務名;
根據所述表名以及所述加工任務名生成所述數據關系圖譜;所述數據關系圖譜類型為有向無環圖。
該專利技術資料僅供研究查看技術是否侵權等信息,商用須獲得專利權人授權。該專利全部權利屬于中國工商銀行股份有限公司,未經中國工商銀行股份有限公司許可,擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作,請聯系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/202011361220.9/2.html,轉載請聲明來源鉆瓜專利網。
- 上一篇:一種火炬傳遞無人機
- 下一篇:一種節能建筑防水保溫外墻結構
- 數據顯示系統、數據中繼設備、數據中繼方法、數據系統、接收設備和數據讀取方法
- 數據記錄方法、數據記錄裝置、數據記錄媒體、數據重播方法和數據重播裝置
- 數據發送方法、數據發送系統、數據發送裝置以及數據結構
- 數據顯示系統、數據中繼設備、數據中繼方法及數據系統
- 數據嵌入裝置、數據嵌入方法、數據提取裝置及數據提取方法
- 數據管理裝置、數據編輯裝置、數據閱覽裝置、數據管理方法、數據編輯方法以及數據閱覽方法
- 數據發送和數據接收設備、數據發送和數據接收方法
- 數據發送裝置、數據接收裝置、數據收發系統、數據發送方法、數據接收方法和數據收發方法
- 數據發送方法、數據再現方法、數據發送裝置及數據再現裝置
- 數據發送方法、數據再現方法、數據發送裝置及數據再現裝置





