【Elasticsearch】Elasticsearch索引创建与管理详解

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 add_document(index_name, timestamp, message):
    document = {
        "timestamp": timestamp,
        "message": message
    }
    response = es.index(index=index_name, body=document)
    print(f"文档添加结果: {response}")
 
# 查询文档
def search_documents(index_name):
    query = {
        "query": {
            "match_all": {}
        }
    }
    response = es.search(index=index_name, body=query)
    print(f"查询结果: {response}")
 
# 使用示例
index_name = "sample_index"
create_index(index_name)
add_document(index_name, datetime.now().strftime("%Y-%m-%d %H:%M:%S"), "这是一个测试文档。")
search_documents(index_name)
delete_index(index_name)

这段代码展示了如何使用Python Elasticsearch客户端库来创建一个索引、添加文档、执行搜索和删除索引。它提供了创建索引的映射定义、文档添加、搜索和索引删除的基本操作。