JesEs

June 26, 2026 · View on GitHub


类在继承体系中的位置:

[BaseDB](../base_db.md)
├── [BaseES](../db_es/base_es.md)
│   ├── [JesES](../db_es/jes_es.md)
│   ├── [LocalES](../db_es/local_es.md)
│   └── [MemoryEs](../db_es/memory_es.md)
├── [BaseRedis](../db_redis/base_redis.md)
│   ├── [LocalRedis](../db_redis/local_redis.md)
│   └── [JimdbApRedis](../db_redis/jimdb_ap_redis.md)
└── [BaseVectorDB](../db_vector/base_vector_db.md)
    └── [VearchDB](../db_vector/vearch_db.md)

简介

JesEs 是 BaseEs 抽象类的具体实现,用于 Elasticsearch 数据库操作。它使用支持身份认证的 AsyncElasticsearch 客户端提供完整的 Elasticsearch 功能。该类实现了 BaseEs 中所有必需的抽象方法,并包含用于索引管理和文档操作的额外辅助方法。

参数

参数类型 / 允许值默认值描述
hostsstr or list必填要连接的 Elasticsearch 主机地址
userstr必填用于身份认证的用户名
passwordstr必填用于身份认证的密码
maxsizeint200连接池中的最大连接数
timeoutint20请求超时时间(秒)
clientAsyncElasticsearchNone内部 Elasticsearch 客户端实例

方法

方法协程 (async)返回值用途
create_index()dict or None使用指定配置创建新索引
index()dict在 Elasticsearch 中索引文档
update()dict更新已有文档
upsert()dict使用 doc_as_upsert 更新或创建文档
search()dict对索引执行搜索查询
exists()bool检查指定索引中是否存在某文档
close()None关闭 Elasticsearch 客户端连接
_index_exists()bool内部方法,检查索引是否存在
_create_new_index()dict内部方法,创建新索引

继承

请参阅 BaseEs 类以了解继承的抽象方法定义,以及 BaseDB 类以了解重试功能和错误处理。