[發明專利]數據同步方法和相關設備

在審

• 申請號: 202211178596.5
• 申請日: 2022-09-26
• 公開（公告）號: CN115587145A
• 公開（公告）日: 2023-01-10
• 發明（設計）人: 陳華海;林國養
• 申請（專利權）人: 中國建設銀行股份有限公司;建信金融科技有限責任公司
• 主分類號: G06F16/27
• 分類號: G06F16/27
• 代理公司: 北京同立鈞成知識產權代理有限公司 11205
• 代理人: 丁鑫;臧建明

本發明提供一種數據同步方法和相關設備，屬于數據同步技術領域，該方法包括：在流水表中讀取任務對象，任務對象包括第一同步對象，第一同步對象包括多個數據對象以及對應的操作方式，各個數據對象是事務的不同節點所產生的數據，操作方式用于指示數據源對數據對象進行操作方式對應的數據同步操作；根據任務對象確定的目標適配器，并控制目標適配器對任務對象中的第一同步對象進行寫入操作，以將第一同步對象寫入至目標適配器對應的數據源。本發明中，任務對象中的同步對象包括事務的各個節點所產生的數據以及操作方式，也即是將事務的各個節點產生的數據一次性的同步至數據庫中，提高了事務數據的同步效率。

技術領域

本發明涉及數據同步技術領域，尤其涉及一種數據同步方法和相關設備。

背景技術

在微服務架構下的每個服務具有自己的數據存儲方式，為保證整個架構的可靠性，一些基礎數據(基礎數據例如為用戶信息、機構信息等)會在每個服務對應的數據庫中保留副本，也即會在數據庫進行數據的同步備份。

事務有多個節點，每個節點對應微服務架構下的一個服務。事務為轉賬，則轉賬包括轉賬人的賬號輸入、轉賬金額、金額轉入等多個節點。

示例性技術中，數據庫中觸發數據同步的方式是觸發器觸發，也即檢測到事務的某個節點，則將該節點所產生的數據同步至數據庫。但由于事務有多個節點，需要依次將多個節點設備同步至數據庫，導致事務數據的同步效率較低。

發明內容

本發明提供一種數據同步方法和相關設備，用以解決事務數據的同步效率較低的問題。

一方面，本發明提供一種數據同步方法，包括：

在流水表中讀取任務對象，所述任務對象包括第一同步對象，所述第一同步對象包括多個數據對象以及對應的操作方式，各個所述數據對象是事務的不同節點所產生的數據，所述操作方式用于指示數據源對所述數據對象進行所述操作方式對應的數據同步操作；

根據所述任務對象確定的目標適配器，并控制所述目標適配器對所述任務對象中的第一同步對象進行寫入操作，以將所述第一同步對象寫入至所述目標適配器對應的數據源。

在一實施例中，所述根據所述任務對象確定的目標適配器，包括：

獲取所述任務對象中的描述信息，并根據所述描述信息確定所述第一同步對象待寫入的目標數據源；

將所述目標數據源對應的適配器確定為所述任務對象對應的目標適配器。

在一實施例中，所述獲取所述任務對象中的描述信息之后，還包括：

在根據所述描述信息無法確定所述第一同步對象待寫入的數據源時，輸出提示信息，并間隔目標時長再次獲取所述任務對象中的描述信息，所述提示信息用于提示所述第一同步對象未指定數據源。

在一實施例中，所述輸出提示信息，包括：

在根據所述描述信息無法確定所述第一同步對象待寫入的數據源時，更新所述第一同步對象的重復執行寫入操作的次數；

在所述次數未達到預設次數，輸出所述提示信息。

在一實施例中，所述更新所述第一同步對象的重復執行寫入操作的次數之后，還包括：

在所述次數達到預設次數，丟棄所述任務對象。

在一實施例中，所述在流水表中讀取任務對象之前，還包括：

在檢測到所述事務發生時，獲取所述事務的各個節點產生的數據對象；

根據所述節點確定所述數據對象的操作方式；

根據各個所述數據對象以及對應的操作方式生成第一同步對象，并根據所述第一同步對象創建任務對象；