[發明專利]索引變更方法及裝置

有效

• 申請號: 202011257710.4
• 申請日: 2020-11-11
• 公開（公告）號: CN112507187B
• 公開（公告）日: 2022-09-27
• 發明（設計）人: 周琦棟;劉偉;孫要飛
• 申請（專利權）人: 貝殼技術有限公司
• 主分類號: G06F16/951
• 分類號: G06F16/951
• 代理公司: 北京路浩知識產權代理有限公司 11002
• 代理人: 苗曉靜

1.一種索引變更方法，其特征在于，包括：

根據索引變更需求，創建與原有第一索引對應的第二索引；其中，所述第一索引具有第一別名；

為所述第一索引創建第一消費者組，所述第一消費者組與預設topic預先建立第一訂閱關系，所述第一消費者組用于消費所述預設topic中的數據；

為所述第二索引創建第二消費者組，所述第二消費者組與所述預設topic預先建立第二訂閱關系，所述第二消費者組用于提交從所述第一消費者組中獲取的消費偏移量，并根據所述消費偏移量消費所述預設topic中的數據；

采用Reindex將所述第一索引的數據復制至所述第二索引；

切換所述第一別名至所述第二索引，建立所述第二索引與所述第一別名的對應關系，以使所述第二索引替代所述第一索引，通過所述第二消費者組提供數據索引服務；

在切換所述第一別名至所述第二索引之前，所述方法還包括：

定時輪詢所述Reindex的任務ID，并調用ES中的任務API，獲取所述Reindex的任務狀態；

根據所述Reindex的任務狀態，切換所述第一別名至所述第二索引；

所述根據所述Reindex的任務狀態，切換所述第一別名至所述第二索引，包括：

若所述Reindex的任務狀態為已完成，則切換所述第一別名至所述第二索引；

若所述Reindex的任務狀態為正在進行中，則持續輪詢所述Reindex的任務ID；

若所述Reindex的任務狀態為提示出錯，則進行告警提示。

2.根據權利要求1所述的索引變更方法，其特征在于，在切換所述第一別名至所述第二索引之后，還包括：

判斷所述第二索引是否替代所述第一索引提供所述數據索引服務，若是，則回收所述第一索引；若否，則切換所述第一別名至所述第一索引，建立所述第一索引與所述第一別名的對應關系，以使所述第一索引替代所述第二索引，通過所述第一消費者組提供所述數據索引服務。

3.根據權利要求1所述的索引變更方法，其特征在于，所述第二消費者組通過調用partitionsFor函數獲取所述第一消費者組的消費偏移量，并通過committed方式提交所述消費偏移量。

4.一種索引變更裝置，其特征在于，包括：

第一創建單元，用于根據索引變更需求，創建與原有第一索引對應的第二索引；其中，所述第一索引具有第一別名；

第二創建單元，用于為所述第一索引創建第一消費者組，所述第一消費者組與預設topic預先建立第一訂閱關系，所述第一消費者組用于消費所述預設topic中的數據；

第三創建單元，用于為所述第二索引創建第二消費者組，其中，所述第二消費者組與所述預設topic預先建立第二訂閱關系，所述第二消費者組用于提交從所述第一消費者組中獲取的消費偏移量，并根據所述消費偏移量消費所述預設topic中的數據；

數據遷移單元，用于采用Reindex將所述第一索引的數據復制至所述第二索引；

索引變更單元，用于切換所述第一別名至所述第二索引，建立所述第二索引與所述第一別名的對應關系，以使所述第二索引替代所述第一索引，通過所述第二消費者組提供數據索引服務；

所述索引變更單元在切換所述第一別名至所述第二索引之前，還用于：

定時輪詢所述Reindex的任務ID，并調用ES中的任務API，獲取所述Reindex的任務狀態；

根據所述Reindex的任務狀態，切換所述第一別名至所述第二索引；

所述索引變更單元，用于根據所述Reindex的任務狀態，切換所述第一別名至所述第二索引，包括：

若所述Reindex的任務狀態為已完成，則切換所述第一別名至所述第二索引；

若所述Reindex的任務狀態為正在進行中，則持續輪詢所述Reindex的任務ID；

若所述Reindex的任務狀態為提示出錯，則進行告警提示。