[發(fā)明專利]數(shù)據(jù)同步方法、系統(tǒng)、裝置、電子設(shè)備、存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202011142415.4
• 申請日: 2020-10-22
• 公開（公告）號: CN112214551A
• 公開（公告）日: 2021-01-12
• 發(fā)明（設(shè)計）人: 倪東;何宜杰
• 申請（專利權(quán)）人: 微醫(yī)云（杭州）控股有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F11/34
• 代理公司: 北京超凡宏宇專利代理事務(wù)所(特殊普通合伙) 11463
• 代理人: 鐘揚飛

本申請?zhí)峁┮环N數(shù)據(jù)同步方法、系統(tǒng)、裝置、電子設(shè)備、計算機可讀存儲介質(zhì)，方法包括：獲取數(shù)據(jù)同步任務(wù)的配置信息；其中，配置信息包括待同步數(shù)據(jù)庫的第一連接信息和工作者節(jié)點的第二連接信息；其中，待同步數(shù)據(jù)庫包括主數(shù)據(jù)庫和從數(shù)據(jù)庫，工作者節(jié)點包括主工作者節(jié)點和從工作者節(jié)點；在任務(wù)列表頁面展示數(shù)據(jù)同步任務(wù)；響應(yīng)于針對數(shù)據(jù)同步任務(wù)的啟動指定，基于第二連接信息向主工作者節(jié)點下發(fā)數(shù)據(jù)同步請求，使得主工作者節(jié)點基于第一連接信息執(zhí)行數(shù)據(jù)同步任務(wù)；其中，數(shù)據(jù)同步請求包括第一連接信息。本申請方案，通過為每一數(shù)據(jù)同步任務(wù)分配主數(shù)據(jù)庫和從數(shù)據(jù)庫、主工作者節(jié)點和從工作者節(jié)點，可以降低數(shù)據(jù)同步方法失敗的幾率。

技術(shù)領(lǐng)域

本申請涉及計算機技術(shù)領(lǐng)域，特別涉及一種數(shù)據(jù)同步方法、系統(tǒng)、裝置、電子設(shè)備、計算機可讀存儲介質(zhì)。

背景技術(shù)

企業(yè)內(nèi)部的搜索服務(wù)需要實時地對新增的業(yè)務(wù)數(shù)據(jù)進行查詢與展示。通常而言，業(yè)務(wù)數(shù)據(jù)(比如：訂單數(shù)據(jù))寫入到數(shù)據(jù)庫后，需同步至消息隊列中，以便消費者(consumer)設(shè)備(比如：搜索引擎服務(wù))對新增的業(yè)務(wù)數(shù)據(jù)進行消費。對于業(yè)務(wù)復(fù)雜的企業(yè)而言，對多種業(yè)務(wù)數(shù)據(jù)進行同步以及保證數(shù)據(jù)同步的可靠性是至關(guān)重要的。

發(fā)明內(nèi)容

本申請實施例的目的在于提供一種數(shù)據(jù)同步方法、系統(tǒng)、裝置、電子設(shè)備、計算機可讀存儲介質(zhì)，用于保證數(shù)據(jù)同步的可靠性。

一方面，本申請?zhí)峁┝艘环N數(shù)據(jù)同步方法，應(yīng)用于控制終端，包括：

獲取數(shù)據(jù)同步任務(wù)的配置信息；其中，所述配置信息包括待同步數(shù)據(jù)庫的第一連接信息和工作者節(jié)點的第二連接信息；其中，所述待同步數(shù)據(jù)庫包括主數(shù)據(jù)庫和從數(shù)據(jù)庫，所述工作者節(jié)點包括主工作者節(jié)點和從工作者節(jié)點；

在任務(wù)列表頁面展示所述數(shù)據(jù)同步任務(wù)；

響應(yīng)于針對所述數(shù)據(jù)同步任務(wù)的啟動指定，基于所述第二連接信息向所述主工作者節(jié)點下發(fā)數(shù)據(jù)同步請求，使得所述主工作者節(jié)點基于所述第一連接信息執(zhí)行所述數(shù)據(jù)同步任務(wù)；其中，所述數(shù)據(jù)同步請求包括所述第一連接信息。

在一實施例中，所述方法還包括：

響應(yīng)于針對所述任務(wù)列表頁面中任一數(shù)據(jù)同步任務(wù)的重配置指令，更改所述數(shù)據(jù)同步任務(wù)的配置信息。

在一實施例中，所述方法還包括：

接收所述工作者節(jié)點上報的工作異常信息，并記錄到對應(yīng)于所述數(shù)據(jù)同步任務(wù)的工作日志；

響應(yīng)于針對所述數(shù)據(jù)同步任務(wù)的日志查看指令，展示所述工作日志。

在一實施例中，所述方法還包括：

如果所述工作異常信息指示任務(wù)失敗時，在所述任務(wù)列表頁面輸出報警提示信息。

在一實施例中，所述方法還包括：

如果所述主工作者節(jié)點停止執(zhí)行所述數(shù)據(jù)同步任務(wù)，向所述從工作者節(jié)點下發(fā)所述數(shù)據(jù)同步請求，使得所述從工作者節(jié)點基于所述第一連接信息執(zhí)行所述數(shù)據(jù)同步任務(wù)。

一方面，本申請?zhí)峁┝艘环N數(shù)據(jù)同步系統(tǒng)，包括：

控制終端；

工作者節(jié)點，所述工作者節(jié)點包括主工作者節(jié)點和從工作者節(jié)點；

所述控制終端，用于獲取數(shù)據(jù)同步任務(wù)的配置信息；其中，所述配置信息包括待同步數(shù)據(jù)庫的第一連接信息和工作者節(jié)點的第二連接信息；其中，所述待同步數(shù)據(jù)庫包括主數(shù)據(jù)庫和從數(shù)據(jù)庫；在任務(wù)列表頁面展示所述數(shù)據(jù)同步任務(wù)；響應(yīng)于針對所述數(shù)據(jù)同步任務(wù)的啟動指定，基于所述第二連接信息向所述主工作者節(jié)點下發(fā)數(shù)據(jù)同步請求；

所述主工作者節(jié)點，與所述控制終端連接，用于依據(jù)所述第一連接信息獲取所述待同步數(shù)據(jù)庫的日志文件；將所述日志文件放入消息隊列。