Elasticsearch介绍及其索引库的创建删除和重新绑定

from datetime import datetime
from elasticsearch import Elasticsearch
 
# 连接到Elasticsearch
es = Elasticsearch(hosts=['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(response)
 
# 索引库的删除
def delete_index(index_name):
    response = es.indices.delete(index=index_name)
    print(response)
 
# 索引库的重新绑定
def reindex(old_index, new_index):
    body = {
        "source": {
            "index": old_index
        },
        "dest": {
            "index": new_index,
            "version_type": "internal"
        }
    }
    response = es.reindex(body=body)
    print(response)
 
# 示例使用
index_name = 'sample_index'
create_index(index_name)
 
# 添加一些样本数据
data = [
    {
        "timestamp": datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
        "message": "Elasticsearch is fun!"
    }
]
es.index(index=index_name, document_type='_doc', body=data[0])
 
# 重命名索引
new_index_name = 'new_sample_index'
reindex(index_name, new_index_name)
 
# 删除旧的索引
delete_index(index_name)

这段代码展示了如何使用Elasticsearch Python API来创建一个新的索引库，删除一个索引库，以及如何将一个索引库的内容重新索引到一个新的索引库。代码中定义了索引的映射，添加了一条示例数据，并展示了如何使用reindex API来迁移数据。