數(shù)據(jù)流式同步系統(tǒng)、設(shè)備以及方法

基本信息

申請?zhí)?/td> CN202110211711.3 申請日 -
公開（公告）號 CN112818022A 公開（公告）日 2021-05-18
申請公布號 CN112818022A 申請公布日 2021-05-18
分類號 G06F16/2455;G06F16/2457;G06F16/22;G06F16/23;G06F16/27 分類 計算；推算；計數(shù);
發(fā)明人 張丙松;阮金亮;高學(xué)鵬 申請（專利權(quán)）人 北京新致君陽信息技術(shù)有限公司
代理機(jī)構(gòu) 上海正策律師事務(wù)所 代理人 李麗;張晟
地址 100085 北京市順義區(qū)金航西路4號院2號樓4層419室-K019（天竺綜合保稅區(qū)）
法律狀態(tài) -

摘要

摘要 一種數(shù)據(jù)流式同步系統(tǒng)，包括同步配置單元、消息讀取單元、數(shù)據(jù)加工單元以及數(shù)據(jù)入庫單元，該同步配置單元被配置為：維護(hù)目標(biāo)系統(tǒng)的增量訂閱信息，根據(jù)訂閱配置確定是否啟用相關(guān)表的增量同步，需要同步的字段范圍，目標(biāo)端寫入的同步表信息，目標(biāo)端選擇的審計表信息；該消息讀取單元被配置為：執(zhí)行增量消息的格式檢查及異常處理；該數(shù)據(jù)加工單元被配置為：執(zhí)行消息結(jié)構(gòu)的解析與加工；該數(shù)據(jù)入庫單元被配置為：執(zhí)行增量消息的過濾分組，消息主鍵的匹配與排序，增量數(shù)據(jù)的插入，數(shù)據(jù)庫事務(wù)的提交與回滾，異常捕獲與拋出，其中該數(shù)據(jù)流式同步系統(tǒng)的各單元形成星型拓?fù)浣Y(jié)構(gòu)，基于消息隊列中間件解耦上下游系統(tǒng)間的數(shù)據(jù)同步關(guān)聯(lián)。