[發明專利]一種同步數據的方法、裝置和計算機可讀存儲介質

有效

• 申請號: 202011241082.0
• 申請日: 2020-11-09
• 公開（公告）號: CN112434243B
• 公開（公告）日: 2023-04-07
• 發明（設計）人: 常文
• 申請（專利權）人: 杭州小電科技股份有限公司
• 主分類號: G06F16/958
• 分類號: G06F16/958;G06F9/54
• 代理公司: 杭州華進聯浙知識產權代理有限公司 33250
• 代理人: 賀才杰

1.一種同步數據的方法，其特征在于，包括：

利用第一中間件向上游數據庫發送獲取日志的交互協議請求，對所述上游數據庫中的操作行為進行讀??；啟動所述第一中間件，將所述上游數據庫中的操作行為推送至第二中間件；從所述第二中間件中獲取目標線程的用戶訂閱狀態；

在所述目標線程處于用戶訂閱的狀態時，提取所述目標線程中用戶訂閱的數據主題中的分區數據；

對所述分區數據通過循環讀取的方式進行解析，得到解析數據；

根據路由配置關系，將所述解析數據寫入對應的下游數據庫。

2.根據權利要求1所述的方法，其特征在于，所述對所述分區數據通過循環讀取的方式進行解析，得到解析數據，包括：

循環讀取所述分區數據進行解析，得到所述解析數據；其中，所述解析數據為可執行的sql格式數據；

基于所述sql格式數據中的主鍵進行哈希運算，得到數字編號，根據所述數字編號將所述sql格式數據插入相應的隊列之間。

3.根據權利要求2所述的方法，其特征在于，所述根據路由配置關系，將所述解析數據寫入對應的下游數據庫，包括：根據所述路由配置關系，從所述隊列中取出所述sql格式數據，寫入對應的所述下游數據庫。

4.根據權利要求1所述的方法，其特征在于，所述方法還包括：

在對所述目標線程中用戶訂閱的數據主題中的分區數據提取失敗、或提取所述分區數據存在延遲的情況下，進行報警。

5.根據權利要求1所述的方法，其特征在于，所述提取所述目標線程中用戶訂閱的數據主題中的分區數據，包括：

從所述第二中間件直接獲取所述目標線程中用戶訂閱的數據主題中的分區數據。

6.根據權利要求1所述的方法，其特征在于，所述提取所述目標線程中用戶訂閱的數據主題中的分區數據，包括：

預設所述第二中間件與所述下游數據庫的所述路由配置關系，然后從所述第二中間件同步獲取所述目標線程中用戶訂閱的數據主題中的分區數據。

7.根據權利要求1所述的方法，其特征在于，所述方法還包括：

在所述目標線程從處于用戶訂閱的狀態變為非訂閱的狀態后，停止提取所述目標線程中用戶訂閱的數據主題中的分區數據。

8.一種同步數據的裝置，其特征在于，包括：獲取模塊、數據模塊、解析以及同步模塊；

所述獲取模塊，用于利用第一中間件向上游數據庫發送獲取日志的交互協議請求，對所述上游數據庫中的操作行為進行讀??；啟動所述第一中間件，將所述上游數據庫中的操作行為推送至第二中間件；從所述第二中間件中獲取目標線程的用戶訂閱狀態；

所述數據模塊，用于在所述目標線程處于用戶訂閱的狀態時，提取所述目標線程中用戶訂閱的數據主題中的分區數據；

所述解析模塊，用于對所述分區數據通過循環讀取的方式進行解析，得到解析數據；

所述同步模塊，用于根據路由配置關系，將所述解析數據寫入對應的下游數據庫。

9.一種計算機設備，包括存儲器、處理器以及存儲在所述存儲器上并可在所述處理器上運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現如權利要求1至7中任一項所述的一種同步數據的方法。

10.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，該程序被處理器執行時實現如權利要求1至7中任一項所述的一種同步數據的方法。