[發明專利]基于Azakban的數據同步方法、裝置和計算機設備

有效

• 申請號: 202010224089.5
• 申請日: 2020-03-26
• 公開（公告）號: CN111427698B
• 公開（公告）日: 2022-11-15
• 發明（設計）人: 王永亮
• 申請（專利權）人: 深圳平安醫療健康科技服務有限公司
• 主分類號: G06F9/52
• 分類號: G06F9/52
• 代理公司: 深圳市明日今典知識產權代理事務所(普通合伙) 44343
• 代理人: 王杰輝

本申請揭示了基于Azakban的數據同步方法，包括：將指定實例拆分成多個數據同步任務并行執行，一個數據同步任務通過多個關聯節點共同完成，每個節點對應一個數據模板，以提高數據同步的效率。為匹配上述框架結構，對封裝Azakban基礎的多線程API，重寫了執行方法和調度方法，實現并行調用Azakban，執行完畢后根據相同的驗證編碼把各節點的數據匯集為指定數據同步任務的數據，并進一步匯集成指定實例的數據。

技術領域

本申請涉及到計算機領域，特別是涉及到基于Azakban的數據同步方法、裝置和計算機設備。

背景技術

現有業內或產品大多是基于簡單的調度如依賴Linux的crontab去進行自定義調度，或者是依賴于J2EE的springquatz或Timer等，工具的話會選擇kettle進行任務定義后借助于windows的IIS去進行調度，重量級的調度平臺也是一個選擇，但是在hadoop領域，要滿足多樣性的描述性語言，能夠進行進度跟蹤、自定義的運行模式和事件通知，且能支持重試及運行任意命令，還沒有一套完整的系統或方案，尤其是現有數據同步不能滿足業務調用需求。

發明內容

本申請的主要目的為提供基于Azakban的數據同步方法，旨在解決現有數據同步不能滿足業務調用需求的技術問題。

本申請提出一種基于Azakban的數據同步方法，包括：

判斷指定時刻是否為指定終端在執行指定實例時的首次調用Azakban的時刻；

若是，則生成所述指定時刻對應的時間戳；

將所述指定終端對應的身份信息與所述指定時刻對應的時間戳組合為所述指定實例的驗證編碼；

根據所述驗證編碼為所述指定實例匹配交換機以及Azakban根節點，以建立所述指定終端與所述Azakban的數據連接；

啟動所述Azakban完成所述指定實例的數據同步。

優選地，所述指定實例包括多個數據同步任務，一個數據同步任務映射為Azakban的多個節點，所述啟動所述Azakban完成所述指定實例的數據同步的步驟，包括：

獲取預配置的、與所述Azakban的指定節點對應的指定數據模板，其中，所述指定節點包含于指定數據同步任務對應的Azakban的所有節點中的任意一個，所述指定數據同步任務屬于所述指定實例中的多個數據同步任務中的任意一個；

根據調度指令獲取所述指定節點依據所述指定數據模板返回的數據；根據所述指定節點的數據獲取過程，獲取所述指定數據同步任務中所有節點分別對應的數據，并匯集為所述指定數據同步任務的數據；

根據所述指定數據同步任務的數據匯集過程，匯集所有數據同步任務的數據，形成指定實例的同步數據。

優選地，所述調度指令包括調度狀態位，所述調度狀態位包括暫停、執行或中斷，所述根據調度指令獲取所述指定節點依據指定數據模板返回的數據的步驟，包括：

判斷所述調度狀態位是否為暫停或中斷；

若是，則刪除執行所述調度狀態位之前的數據傳輸痕跡；

判斷所述調度狀態位是否恢復為執行；

若是，則重新獲取所述指定節點依據所述指定數據模板返回的數據。

優選地，所述Azakban包括微服務springc loud封裝的多線程API以及消息中間件，所述獲取預配置的、與Azakban的指定節點對應的指定數據模板的步驟之前，包括：

獲取所述指定實例包括的各數據同步任務；

按照預設規則將各所述數據同步任務在所述消息中間件中形成消息隊列；