[發明專利]業務數據同步方法及裝置、非易失性存儲介質、處理器

在審

• 申請號: 202011282003.0
• 申請日: 2020-11-16
• 公開（公告）號: CN112380229A
• 公開（公告）日: 2021-02-19
• 發明（設計）人: 劉亦軒
• 申請（專利權）人: 中消云（北京）物聯網科技研究院有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F16/27;G06F16/958
• 代理公司: 北京康信知識產權代理有限責任公司 11240
• 代理人: 肖璐

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

在監聽到源數據庫中的業務數據更新時，將獲取到的待推送數據轉存至目標消息隊列；

當同步轉化服務程序監聽所述目標消息隊列中的所述待推送數據時，依據所述推送數據的數據表類型對所述待推送數據進行轉化處理，得到轉化后待推送數據，其中，所述轉化后待推送數據的數據結構與目標第三方平臺的數據結構對應；

采用推送服務程序將所述轉化后待推送數據推送至所述目標第三方平臺。

2.根據權利要求1所述的方法，其特征在于，采用監聽組件監聽所述源數據庫中的源數據日志文件，確定所述業務數據是否發生更新，其中，所述監聽組件包括：數據庫同步監聽Canal組件。

3.根據權利要求1所述的方法，其特征在于，將獲取到的待推送數據轉存至目標消息隊列，包括：

獲取所述源數據庫中的更新后業務數據，以及與所述更新后業務數據對應的更新前業務數據；

將所述更新前業務數據和所述更新后業務數據轉化為所述待推送數據，其中，所述待推送數據的數據結構為目標消息體結構。

4.根據權利要求1所述的方法，其特征在于，依據所述推送數據的數據表類型對所述待推送數據進行轉化處理，包括：

獲取所述待推送數據中攜帶的數據標識信息；

基于所述數據標識信息確定所述數據表類型；

依據所述數據表類型判斷所述待推送數據是否適用本地定制服務，其中，所述本地定制服務基于目標事件監聽機制處理待推送數據，并將待推送數據封裝成目標事件進行廣播；

若判斷結果為是，則確定與所述數據表類型對應的監聽類型，其中，不同的所述監聽類型對應不同的事件監聽器，所述事件監聽器用于在接收到廣播后對所述待推送數據進行轉化處理。

5.根據權利要求4所述的方法，其特征在于，若判斷結果為否則丟棄所述待推送數據。

6.根據權利要求1所述的方法，其特征在于，采用推送服務程序將所述轉化后待推送數據推送至所述目標第三方平臺，包括：

采用所述推送服務程序將所述轉化后待推送數據轉化為目標字符串；

通過超文本傳輸協議Http請求訪問所述目標第三方平臺的數據接收接口，并采用接口請求工具將所述目標字符串推送至所述數據接收接口，其中，所述目標第三方平臺還用于將所述目標字符串存儲至本地數據庫中。

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

監聽模塊，用于在監聽到源數據庫中的業務數據更新時，將獲取到的待推送數據轉存至目標消息隊列；

轉化處理模塊，用于當同步轉化服務程序監聽所述目標消息隊列中的所述待推送數據時，依據所述推送數據的數據表類型對所述待推送數據進行轉化處理，得到轉化后待推送數據，其中，所述轉化后待推送數據的數據結構與目標第三方平臺的數據結構對應；

推送模塊，用于采用推送服務程序將所述轉化后待推送數據推送至所述目標第三方平臺。

8.一種非易失性存儲介質，其特征在于，所述非易失性存儲介質存儲有多條指令，所述指令適于由處理器加載并執行權利要求1至6中任意一項所述的業務數據同步方法。

9.一種處理器，其特征在于，所述處理器用于運行程序，其中，所述程序被設置為運行時執行權利要求1至6中任意一項所述的業務數據同步方法。

10.一種電子裝置，包括存儲器和處理器，其特征在于，所述存儲器中存儲有計算機程序，所述處理器被設置為運行所述計算機程序以執行權利要求1至6中任意一項所述的業務數據同步方法。