[發明專利]一種數據同步方法及其相關設備

在審

• 申請號: 202210631618.2
• 申請日: 2022-06-06
• 公開（公告）號: CN114996355A
• 公開（公告）日: 2022-09-02
• 發明（設計）人: 方勇;王安定;朱志宇;牛通;馬換新;張媛媛;方蓮娣;王玉婷;段曉珊;黃俊祥;李洋;張盼盼
• 申請（專利權）人: 中國銀行股份有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/2455;G06F16/25;G06F16/242
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 楊儻月

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

在獲取到源端發送的當前流數據片段之后，按照所述當前流數據片段的數據類型描述信息，從預先生成的至少一個候選數據同步規則中確定出待使用數據同步規則；

按照所述待使用數據同步規則，對所述當前流數據片段進行數據映射處理，得到待使用數據；

將所述待使用數據存儲至目標端。

2.根據權利要求1所述的方法，其特征在于，所述候選數據同步規則的個數為N；其中，第n個候選數據同步規則用于描述第n種源端數據類型與第n種目標端數據類型之間的數據映射處理；其中，n為正整數，n≤N，N為正整數。

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

響應于用戶在同步規則配置頁面上觸發的操作，生成待使用配置文件；其中，所述待使用配置文件包括所述源端的數據配置信息和所述目標端的數據配置信息；所述源端的數據配置信息包括所述第n種源端數據類型的數據類型描述信息；所述目標端的數據配置信息包括所述第n種目標端數據類型的數據類型描述信息；

解析所述待使用配置文件，得到所述第n個候選數據同步規則。

4.根據權利要求3所述的方法，其特征在于，所述操作包括源端信息配置操作、目標端信息配置操作、映射關系配置操作、和異常容錯配置操作中的至少一個。

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

在確定所述當前流數據片段滿足預設異常條件時，按照所述預設異常條件對應的異常校正規則，對所述當前流數據片段進行校正處理，得到校正后數據；

所述按照所述待使用數據同步規則，對所述當前流數據片段進行數據映射處理，得到待使用數據，包括：

按照所述待使用數據同步規則，對所述校正后數據進行數據映射處理，得到待使用數據。

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

在確定所述當前流數據片段不滿足所述數據類型描述信息對應的數據正常條件時，更新所述數據類型描述信息對應的異常計數值；

在確定所述異常數據計數值超過所述數據類型描述信息對應的異常個數閾值時，生成并發送第一告警信息。

7.一種數據同步裝置，其特征在于，包括：

規則確定單元，用于在獲取到源端發送的當前流數據片段之后，按照所述當前流數據片段的數據類型描述信息，從預先生成的至少一個候選數據同步規則中確定出待使用數據同步規則；

數據映射單元，用于按照所述待使用數據同步規則，對所述當前流數據片段進行數據映射處理，得到待使用數據；

數據同步單元，用于將所述待使用數據存儲至目標端。

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

心跳發送單元，用于在確定所述數據同步裝置處于正常運行狀態時，向注冊中心發送心跳數據，以使在所述注冊中心接收到所述心跳數據之后，確定所述所述數據同步裝置處于正常運行狀態。

9.根據權利要求8所述的方法，其特征在于，所述注冊中心，用于在確定預設時間段內未接收到所述數據同步裝置發送的心跳數據之后，確定所述數據同步裝置處于宕機狀態，生成并發送第二告警信息。

10.一種設備，其特征在于，所述設備包括處理器以及存儲器：

所述存儲器用于存儲計算機程序；

所述處理器用于根據所述計算機程序執行權利要求1-6中任一項所述的方法。

11.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質用于存儲計算機程序，所述計算機程序用于執行權利要求1-6中任一項所述的方法。