新闻中心
Python Elasticsearch DSL如何使用
答案:Python Elasticsearch DSL 提供了更便捷的面向对象方式操作 Elasticsearch,通过安装 elasticsearch-dsl 库并连接服务后,可定义 Document 模型映射字段与索引设置,调用 init() 创建索引,使用 s*e() 添加文档,Search 类构建 match、term、range 等查询,支持 bool 组合与聚合分析,还可通过 get() 更新或 delete() 删除文档,结合 bulk 实现高效批量写入,适用于复杂检索场景。

Python Elasticsearch DSL 是一个用于与 Elasticsearch 进行交互的高级库,它封装了官方的 elasticsearch-py 客户端,提供了更直观、更 Pythonic 的方式来构建查询和操作数据。下面介绍如何使用它进行常见操作。
安装依赖
首先需要安装 elasticsearch-dsl:
pip install elasticsearch-dsl确保你已经运行了 Elasticsearch 服务(例如本地启动在 http://localhost:9200)。
连接到 Elasticsearch
使用 connections 模块配置连接:
# 连接到本地 ES 实例
connections.create_connection(hosts=['localhost'], port=9200, timeout=20)
也可以传入多个节点或使用 URL:
connections.create_connection(hosts=['http://user:pass@localhost:9200'])定义文档模型(Document)
通过继承 Document 类定义索引结构和字段类型:
class Article(Document):
title = Text(analyzer='ik_max_word', search_analyzer='ik_smart')
content = Text(analyzer='ik_max_word')
author = Keyword()
views = Integer()
created_at = Date()
class Index:
name = 'articles' # 索引名称
settings = {
"number_of_shards": 1,
"number_of_replicas": 0
}
说明:
-
Text:会被分词,适合全文检索 -
Keyword:不分词,用于精确匹配(如作者名) -
Date、Integer等对应基本类型 -
Index.name指定索引名 - 可设置分词器(如中文推荐 ik 分词器)
创建索引(映射):
Article.init() # 创建索引并应用 mapping添加和保存文档
创建并保存一条记录:
article = Article(title="Python 使用 Elasticsearch",
content="本文介绍 elasticsearch-dsl 的用法",
author="张三",
views=100,
created_at="2025-04-05"
)
article.s*e() # 写入 ES
指定 ID 保存:
article.s*e(id=1)查询数据(Search API)
使用 Search 类进行复杂查询:
s = Search().index('articles')
s = s.query("match", title="Python")
response = s.execute()
遍历结果:
PPT.CN,PPTCN,PPT.CN是什么,PPT.CN官网,PPT.CN如何使用
一键操作,智能生成专业级PPT
268
查看详情
for hit in response:print(hit.title, hit.author, hit.meta.score)
常用查询类型:
-
query("match", field="value"):全文匹配 -
query("term", author="张三"):精确匹配(Keyword 字段) -
query("range", views={"gte": 50}):范围查询 -
query(~Q("match", title="Elasticsearch")):使用~表示否定
组合查询(bool 查询):
from elasticsearch_dsl import Qs = Search().index('articles')
s = s.query('bool',
must=[Q('match', title='Python')],
filter=[Q('term', author='张三')])
聚合操作(Aggregations)
执行统计聚合:
s.aggs.bucket('by_author', 'terms', field='author')s.aggs.metric('*g_views', '*g', field='views')
获取聚合结果:
response = s.execute()for bucket in response.aggregations.by_author.buckets:
print(bucket.key, bucket.doc_count)
更新和删除文档
根据 ID 获取并修改:
article = Article.get(id=1)article.views = 150
article.s*e()
部分更新(仅更新某些字段):
article.update(views=200)删除文档:
article.delete()删除整个索引:
Article._index.delete()批量操作(Bulk Operations)
使用 bulk 批量写入提升性能:
from elasticsearch_dsl import Index
def bulk_index(data_list):
actions = []
for data in data_list:
action = {
"_index": "articles",
"_source": data
}
actions.append(action)
bulk(client=connections.get_connection(), actions=actions)
或者使用 DocType 的批量支持(较旧版本)或自定义生成器。
小贴士
- 中文分词建议安装并启用 IK 分词器插件
- 生产环境注意设置合理的超时和重试机制
- 可以结合 Django 或 Flask 使用,有相应集成包
- 使用
.scan()遍历大量数据(替代 from/size 分页) - 调试时可用
print(s.to_dict())查看生成的 DSL 查询语句
基本上就这些。掌握定义模型、增删改查、构造查询和聚合,就能高效使用 elasticsearch-dsl。
以上就是Python Elasticsearch DSL如何使用的详细内容,更多请关注其它相关文章!
# 自动生成
# 湘乡网站建设公司
# 网站推广员招聘兼职
# 山东神马网站优化多少钱
# 网站建设费用摊销年限
# 婚恋网站初期怎么推广
# 如何补充seo优化
# 易县网站推广公司哪家好
# 推广自己的营销模式
# 长宁抖音seo客服
# 网上的推广网站产品
# 考试试卷
# 中带
# word
# 连接到
# 新和
# 遍历
# 面向对象
# 官网
# 如何使用
# 文档
# 2025
# django
# app
# go
# python
相关栏目:
【
科技资讯46185 】
【
网络学院92790 】
相关推荐:
AO3网页版最新入口合集 Archive of Our Own在线访问指南
1688商家版怎样分析买家画像精准供货_1688商家版分析买家画像精准供货【供货策略】
漫蛙官网正版漫画入口 漫蛙2官方网页登录地址
C++ explicit关键字防止隐式转换_C++构造函数安全规范
想当下一个《2077》?《心之眼》Steam评价升至"多半好评"
知音漫客官网漫画下载_知音漫客网页版阅读记录
MAC怎么在地图App里使用“四处看看”_MAC体验部分城市的3D实景街景
C++如何实现单例模式_C++设计模式之线程安全的单例写法
qq游戏手机版下载安装_qq游戏移动端入口
漫蛙2正版漫画站 漫蛙2网页版快速访问入口
2025俄罗斯Yandex最新入口 官方网站地址及浏览器下载指南
在Socket.IO连接中实现Access Token自动更新与动态重连
电脑屏幕颜色不舒服怎么办_Windows夜间模式与色彩校准教程【护眼技巧】
学习通网页版快速入口 学习通官网网页版直接打开
c++ 获取系统当前时间 c++时间戳获取方法
CSS图片焦点样式实现教程:理解与应用tabindex属性
字由网在线版登录地址 字由网网页版安全入口
深入理解J*a合成构造器:何时以及为何阻止其生成
葱吃多了会怎样 葱吃多了会伤胃吗
腾讯视频怎么举报不良内容_腾讯视频内容举报流程与违规信息处理方法
Gmail邮箱申请注册直达_Gmail邮箱免费注册PC版官网入口2025
微博网页版直接访问 微博网页版账号管理快速入口
C++如何打印当前代码行号与文件名_C++预定义宏FILE与LINE的使用
在命令行怎么运行html项目_命令行运行html项目方法【教程】
PyTorch模型训练效果不佳?深入剖析常见错误与调试技巧
Golang如何实现容器化日志收集与分析_Golang容器日志收集分析方法
cad怎么合并重叠的线段_cad清理重复重叠线条的操作方法
包子漫画官方网站在线链接-包子漫画在线阅读平台主页地址
双系统安装时,如何设置默认启动系统? msconfig命令了解一下!
蛙漫2台版漫画地址 Manwa2正版网页版链接
漫蛙漫画官方主页入口 漫蛙MANWA网页直达访问链接
PHP中获取MongoDB服务器运行时间(Uptime)的专业指南
KFC套餐升级怎么获取优惠代码_KFC套餐升级活动与优惠代码获取方法
php源码怎么在电脑上测试_电脑测试php源码方法步骤【教程】
TikTok国际版网页端快速入口 TikTok全球版短视频浏览教程
AO3最新入口2025公告_AO3中文官网合集
抖音网页版平台入口 抖音网页版官网在线访问教程
QQ邮箱登录首页官网地址2026 QQ邮箱官方网页入口
魅族20怎样在浏览器开无图省流_iPhone魅族20浏览器开无图省流【流量节省】
AI泡沫首次被“刺破”:GPU十年都无法存活!
AO3访问入口汇总 AO3网页版同人作品一键直达
Windows10怎么开启夜间模式 Windows10系统设置调整色温与亮度缓解夜间用眼疲劳【教程】
使用Python高效删除Word宏并转换DOCM为DOCX格式
黑鲨3Pro怎样在相册开漫画风滤镜_iPhone黑鲨3Pro相册开漫画风滤镜【趣味滤镜】
PowerPoint如何制作滚动字幕结尾彩蛋_PowerPoint路径动画实现平滑滚动字幕效果
Pandas DataFrame 高效批量赋值:告别循环与笛卡尔积误区
J*aScript中如何高效提取对象指定属性
在哪找SublimeJ远程工具_SFTP插件配置教程
win11 Snap Layouts怎么用 Win11窗口布局与分屏多任务高效指南【必学】
微博网页版官方账号登录 微博网页版内容浏览使用指南


2025-11-15
浏览次数:次
返回列表