在 ElasticSearch 集群中重命名索引

1. 概述

在 ElasticSearch 中，索引（Index）是一组具有逻辑关联的数据分片的集合。

本教程中，我们将介绍如何在不中断服务的前提下，安全地重命名一个 ElasticSearch 索引。我们会讲解如何使用索引别名（Alias）、创建新索引、重新导入数据（Reindex）、原子性地更新别名，并最终清理旧索引。

2. 索引别名（Index Aliases）

在 ElasticSearch 中，别名本质上是索引的另一个名称。这个机制允许我们通过一个不同的名字来引用一个索引。

举个例子，我们可以通过以下命令为索引添加一个别名：

$ curl -X POST "localhost:9200/_aliases" -H 'Content-Type: application/json' -d'
{
  "actions": [
    { "add": { "index": "customers", "alias": "current_customers" }}
  ]                                                                       
}'

✅ 该命令将索引 customers 添加了一个别名 current_customers。
此后，我们可以在大多数 ElasticSearch 操作中使用 current_customers 替代 customers，这在重命名索引时非常有用 —— 因为我们可以通过别名无缝切换。

3. 重命名流程详解

接下来，我们将整个重命名过程拆分为几个步骤，逐一讲解。

3.1. 创建新索引

第一步是创建一个具有新名称的索引。为了保证结构一致，我们需要从旧索引中复制设置（Settings）和映射（Mappings）。

示例代码如下：

import elasticsearch

es = elasticsearch.Elasticsearch("http://localhost:9200")

# 定义新旧索引名称
old_index = "customers"
new_index = "customers_v2"

# 获取旧索引的配置信息
index_info = es.indices.get(index=old_index)
settings = index_info[old_index]["settings"]["index"]
mappings = index_info[old_index]["mappings"]

# 过滤掉自动管理的配置项
auto_managed_settings = [
    "creation_date", "uuid", "version", "provided_name"
]
filtered_settings = {k: v for k, v in settings.items() if k not in auto_managed_settings}

# 创建新索引
es.indices.create(index=new_index, body={
    "settings": filtered_settings,
    "mappings": mappings
})

⚠️ 注意：自动管理的字段不能直接设置，必须在创建新索引前过滤掉。

3.2. 数据迁移（Reindex）

有了结构一致的新索引后，接下来就是将旧索引中的数据迁移到新索引中。我们使用的是 ElasticSearch 提供的 Reindex API：

reindex_body = {
    "source": {
        "index": old_index
    },
    "dest": {
        "index": new_index
    }
}

reindex_response = es.reindex(body=reindex_body, wait_for_completion=False)
task_id = reindex_response['task']

# 监控进度
while True:
    task_status = es.tasks.get(task_id=task_id)
    if task_status['completed']:
        print("Reindexing completed!")
        break
    else:
        progress = task_status['task']['status']['created'] / task_status['task']['status']['total']
        print(f"Reindexing progress: {progress:.2%}")
    time.sleep(5)

✅ 使用 wait_for_completion=False 可以避免大索引阻塞当前线程，适合异步处理。
✅ 循环检查任务状态，可以实时监控迁移进度。

3.3. 更新别名（原子操作）

迁移完成后，下一步是将别名从旧索引切换到新索引上。这一步必须以原子方式执行，以确保服务不中断：

update_aliases_body = {
    "actions": [
        {"remove": {"index": old_index, "alias": "current_customers"}},
        {"add": {"index": new_index, "alias": "current_customers"}}
    ]
}

es.indices.update_aliases(body=update_aliases_body)

# 验证更新
alias_info = es.indices.get_alias(name="current_customers")
if new_index in alias_info:
    print("Alias updated successfully!")
else:
    print("Alias update failed.")

✅ 使用 update_aliases 接口可以一次性完成别名的移除和添加，保证切换过程无中断。
✅ 更新完成后建议做一次验证，确保别名已正确指向新索引。

4. 特殊场景处理

上述流程适用于大多数情况，但在某些特定场景下，还需要做额外处理。

4.1. 时间序列索引（Time-Based Indices）

如果你使用的是时间序列索引（如 logs-2023-01, logs-2023-02 等），你可能需要批量重命名多个索引。

以下是一个示例代码，使用通配符匹配索引并逐个处理：

old_indices = es.indices.get(index="logs-2023-*")

for old_index in old_indices:
    date_part = old_index.split('-', 2)[-1]
    new_index = f"new-logs-2023-{date_part}"

    reindex_body = {
        "source": {"index": old_index},
        "dest": {"index": new_index}
    }

    es.reindex(body=reindex_body, wait_for_completion=True)

✅ 使用通配符 * 可以灵活匹配多个索引。
✅ 分割索引名并保留时间部分，有助于新索引命名的可读性和一致性。

4.2. Kibana 中的索引模式（Index Pattern）

如果你在 Kibana 中使用了基于旧索引名的索引模式（Index Pattern），还需要更新 Kibana 的配置。

可以通过 Kibana UI 修改，也可以使用 API 实现：

import requests

kibana_url = "http://localhost:5601"
headers = {"kbn-xsrf": "true", "Content-Type": "application/json"}

pattern_body = {
    "attributes": {
        "title": "customers_v2*"
    }
}

response = requests.put(f"{kibana_url}/api/saved_objects/index-pattern/pattern-id", 
                        headers=headers, json=pattern_body)

if response.status_code == 200:
    print("Kibana index pattern updated successfully!")
else:
    print("Failed to update Kibana index pattern.")

⚠️ 注意替换 pattern-id 为实际的索引模式 ID。
✅ 更新后确保 Kibana 中的可视化和仪表盘仍能正常工作。

5. 总结

本文完整介绍了在 ElasticSearch 中安全重命名索引的流程，主要包括：

使用索引别名作为过渡
创建新索引并复制旧索引结构
使用 Reindex API 迁移数据
原子性更新别名，确保服务不中断
处理时间序列索引和 Kibana 配置等特殊情况

✅ 索引别名是实现无缝切换的关键工具。
✅ 整个流程设计合理，适合生产环境操作。

如果你正在考虑重构索引结构或进行版本升级，这套方案非常值得参考。

Persistence

REST

Security