ElasticSearch重建/创建/删除索引操作 - 第501篇

from datetime import datetime
from elasticsearch import Elasticsearch
 
# 连接到Elasticsearch
es = Elasticsearch("http://localhost:9200")
 
# 创建索引
def create_index(index_name):
    body = {
        "mappings": {
            "properties": {
                "timestamp": {
                    "type": "date",
                    "format": "yyyy-MM-dd HH:mm:ss"
                },
                "message": {
                    "type": "text"
                }
            }
        }
    }
    response = es.indices.create(index=index_name, body=body)
    print(f"索引创建结果: {response}")
 
# 删除索引
def delete_index(index_name):
    response = es.indices.delete(index=index_name)
    print(f"索引删除结果: {response}")
 
# 重建索引
def reindex(source_index, target_index):
    # 假设source_index存在，target_index不存在
    body = {
        "source": {
            "index": source_index
        },
        "dest": {
            "index": target_index
        }
    }
    response = es.reindex(body)
    print(f"索引重建结果: {response}")
 
# 示例使用
create_index("example_index")  # 创建索引
delete_index("example_index")  # 删除索引
reindex("source_index", "target_index")  # 重建索引

这段代码提供了创建、删除和重建Elasticsearch索引的函数。使用者可以根据需要调用这些函数来管理索引。注意，在实际使用中，需要根据Elasticsearch的版本和配置来调整连接方式和相关操作的细节。