Python Elasticsearch 客户端使用详解

Elasticsearch 是一个广泛使用的分布式搜索和分析引擎，而elasticsearch是其官方提供的 Python 客户端库。通过该库，开发者可以方便地与 Elasticsearch 集群进行交互，完成从集群状态监控到复杂查询的各类操作。本文将系统性地介绍如何使用 Python 操作 Elasticsearch，内容涵盖集群管理、索引控制以及文档的增删改查与高级查询功能。

一、安装与连接

首先，通过 pip 安装官方客户端：

pipinstallelasticsearch==8.14.0

在代码中初始化客户端：

fromelasticsearchimportElasticsearch,NotFoundError es=Elasticsearch('http://localhost:9200',basic_auth=("elastic","123456"),retry_on_timeout=True,max_retries=3)

二、集群操作

获取集群健康状态

集群健康状态反映当前数据分片的分配情况，是运维监控的重要指标：

health=es.cluster.health()print("集群状态:",health['status'])print("节点数量:",health['number_of_nodes'])print("未分配分片数:",health['unassigned_shards'])

集群状态: green 节点数量: 1 未分配分片数: 0

获取集群基本信息

info=es.info()print("Elasticsearch 版本:",info['version']['number'])print("集群名称:",info['cluster_name'])

Elasticsearch 版本: 8.14.0 集群名称: docker-cluster

三、索引操作

索引（Index）是 Elasticsearch 中存储文档的逻辑容器，类似于关系型数据库中的“表”。

判断索引是否存在

exists=es.indices.exists(index='my_index')print("索引存在?",exists)

索引存在? False

创建索引

创建索引时可指定分片数、副本数及字段映射（mapping）：

mapping={"settings":{"number_of_shards":1,"number_of_replicas":0},"mappings":{"properties":{"title":{"type":"text"},"category":{"type":"keyword"},"price":{"type":"float"},"created_at":{"type":"date"}}}}es.indices.create(index='my_index',body=mapping)

删除索引

es.indices.delete(index='my_index')

四、文档操作

文档（Document）是 Elasticsearch 中的基本数据单元，以 JSON 格式存储。

创建文档

doc={"title":"Python 与 Elasticsearch","category":"dev",<