ElasticSearch 实战：es集群健康检查和简单的索引操作

from elasticsearch import Elasticsearch
 
# 连接到Elasticsearch集群
es = Elasticsearch("http://localhost:9200")
 
# 检查集群健康状态
cluster_health = es.cluster.health()
print(cluster_health)
 
# 创建一个简单的索引操作
index_name = 'test_index'
doc_type = 'test_type'
document_id = 1
document_body = {
    'name': 'John Doe',
    'age': 30,
    'about': 'I love to go rock climbing'
}
 
# 创建索引
create_index_response = es.indices.create(index=index_name, ignore=400)
print(create_index_response)
 
# 索引一个文档
index_response = es.index(index=index_name, doc_type=doc_type, id=document_id, body=document_body)
print(index_response)
 
# 获取并打印文档
get_response = es.get(index=index_name, doc_type=doc_type, id=document_id)
print(get_response)

这段代码展示了如何使用Elasticsearch Python API连接到Elasticsearch集群，检查集群健康状态，创建一个新的索引，并在该索引中索引一个文档。然后，代码获取并打印这个文档以确认索引操作成功。这是进行Elasticsearch开发的基本步骤之一。