[發明專利]一種索引數據遷移方法、裝置及設備在審
| 申請號: | 202011640278.7 | 申請日: | 2020-12-31 |
| 公開(公告)號: | CN112699098A | 公開(公告)日: | 2021-04-23 |
| 發明(設計)人: | 朱潤石;呂浩;杜波;薛永嬌;徐文政 | 申請(專利權)人: | 中國農業銀行股份有限公司 |
| 主分類號: | G06F16/21 | 分類號: | G06F16/21;G06F16/22;G06F16/27 |
| 代理公司: | 北京集佳知識產權代理有限公司 11227 | 代理人: | 郭化雨 |
| 地址: | 100005 北*** | 國省代碼: | 北京;11 |
| 權利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關鍵詞: | 一種 索引 數據 遷移 方法 裝置 設備 | ||
本申請實施例公開了一種索引數據遷移方法、裝置及設備,先獲取待遷移索引數據的目標字段數據段,對目標字段數據段進行切分,得到多個待處理任務數據段;再建立與待處理任務數據段對應的待執行遷移任務,根據待執行遷移任務確定待遷移隊列;從待遷移隊列中獲取目標遷移任務,根據目標遷移任務獲取目標任務數據段;最后,將目標任務數據段分配至目標線程;調用目標線程根據目標任務數據段,從原始索引數據庫中獲取待遷移索引數據;通過目標線程將待遷移索引數據寫入目標索引數據庫。如此,通過多線程和分布式架構,可以提高遷移索引數據的遷移效率。部分線程遷移出現問題時不會影響到其他線程的遷移過程。在保證了容錯性的基礎上,提高遷移效率。
技術領域
本申請涉及數據處理領域,具體涉及一種索引數據遷移方法、裝置及設備。
背景技術
在使用互聯網的過程中會產生大量的數據,通常需要將產生的數據儲存至搜索引擎的索引庫中,以便搜索引擎利用索引庫中的索引數據進行查詢和分析。
隨著搜索引擎的不斷優化和更新,為了滿足對索引數據的處理的需要,需要進行搜索引擎的替換。在進行搜索引擎的替換時,如果在新的搜索引擎中重新建立對應的索引數據,需要建立的索引數據的數據量較大,需要耗費較高的成本。因此,需要將原始搜索引擎中的索引數據轉移至新的搜索引擎中。目前,在搜索引擎之間進行索引數據的遷移的效率較低,難以對大量的需要遷移的索引數據進行及時的遷移處理。
發明內容
有鑒于此,本申請實施例提供一種索引數據遷移方法、裝置及設備,能夠實現高效的索引數據的遷移。
為解決上述問題,本申請實施例提供的技術方案如下:
第一方面,本申請提供一種索引數據遷移方法,所述方法包括:
獲取待遷移索引數據的目標字段數據段,對所述目標字段數據段進行切分,得到多個待處理任務數據段;
建立與所述待處理任務數據段對應的待執行遷移任務,根據所述待執行遷移任務確定待遷移隊列;所述待處理任務數據段與所述待執行遷移任務一一對應;
從所述待遷移隊列中獲取目標遷移任務,根據所述目標遷移任務獲取目標任務數據段;所述目標遷移任務為所述待執行遷移任務中的一個或者多個,所述目標任務數據段為與所述目標遷移任務對應的待執行任務數據段;
將所述目標任務數據段分配至目標線程;
調用所述目標線程根據所述目標任務數據段,從原始索引數據庫中獲取所述待遷移索引數據;
通過所述目標線程將所述待遷移索引數據寫入目標索引數據庫。
在一種可能的實現方式中,所述獲取待遷移索引數據的目標字段數據段,對所述目標字段數據段進行切分,得到多個待處理任務數據段,包括:
獲取目標字段起始值和目標字段結束值,根據所述目標字段起始值和所述目標字段結束值確定目標字段數據段;
獲取切分間隔,利用所述切分間隔對所述目標字段數據段進行劃分,得到多個待處理任務數據段。
在一種可能的實現方式中,所述方法還包括:
獲取所述各個待處理任務數據段所對應的待遷移索引數據的數量;
計算所述各個待處理任務數據段所對應的待遷移索引數據的數量之間的差值,判斷所述差值是否小于目標差值;
若所述差值大于或者等于目標差值,對待遷移索引數據的數量大于目標數量的待處理任務數據段進行劃分,得到重新劃分后的待處理任務數據段。
在一種可能的實現方式中,所述建立與所述待處理任務數據段對應的待執行遷移任務,根據所述待執行遷移任務確定待遷移隊列,包括:
建立與所述待處理任務數據段對應的待執行遷移任務;
該專利技術資料僅供研究查看技術是否侵權等信息,商用須獲得專利權人授權。該專利全部權利屬于中國農業銀行股份有限公司,未經中國農業銀行股份有限公司許可,擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作,請聯系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/202011640278.7/2.html,轉載請聲明來源鉆瓜專利網。
- 數據顯示系統、數據中繼設備、數據中繼方法、數據系統、接收設備和數據讀取方法
- 數據記錄方法、數據記錄裝置、數據記錄媒體、數據重播方法和數據重播裝置
- 數據發送方法、數據發送系統、數據發送裝置以及數據結構
- 數據顯示系統、數據中繼設備、數據中繼方法及數據系統
- 數據嵌入裝置、數據嵌入方法、數據提取裝置及數據提取方法
- 數據管理裝置、數據編輯裝置、數據閱覽裝置、數據管理方法、數據編輯方法以及數據閱覽方法
- 數據發送和數據接收設備、數據發送和數據接收方法
- 數據發送裝置、數據接收裝置、數據收發系統、數據發送方法、數據接收方法和數據收發方法
- 數據發送方法、數據再現方法、數據發送裝置及數據再現裝置
- 數據發送方法、數據再現方法、數據發送裝置及數據再現裝置





