新闻中心

Python Elasticsearch DSL如何使用

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

python elasticsearch dsl如何使用

Python Elasticsearch DSL 是一个用于与 Elasticsearch 进行交互的高级库,它封装了官方的 elasticsearch-py 客户端,提供了更直观、更 Pythonic 的方式来构建查询和操作数据。下面介绍如何使用它进行常见操作。

安装依赖

首先需要安装 elasticsearch-dsl:

pip install elasticsearch-dsl

确保你已经运行了 Elasticsearch 服务(例如本地启动在 http://localhost:9200)。

连接到 Elasticsearch

使用 connections 模块配置连接:

from elasticsearch_dsl import connections

# 连接到本地 ES 实例
connections.create_connection(hosts=['localhost'], port=9200, timeout=20)

也可以传入多个节点或使用 URL:

connections.create_connection(hosts=['http://user:pass@localhost:9200'])

定义文档模型(Document)

通过继承 Document 类定义索引结构和字段类型:

from elasticsearch_dsl import Document, Text, Keyword, Integer, Date

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:不分词,用于精确匹配(如作者名)
  • DateInteger 等对应基本类型
  • 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 类进行复杂查询:

from elasticsearch_dsl import Search

s = Search().index('articles')
s = s.query("match", title="Python")
response = s.execute()

遍历结果:

PPT.CN,PPTCN,PPT.CN是什么,PPT.CN官网,PPT.CN如何使用 PPT.CN,PPTCN,PPT.CN是什么,PPT.CN官网,PPT.CN如何使用

一键操作,智能生成专业级PPT

PPT.CN,PPTCN,PPT.CN是什么,PPT.CN官网,PPT.CN如何使用 268 查看详情 PPT.CN,PPTCN,PPT.CN是什么,PPT.CN官网,PPT.CN如何使用 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 Q

s = 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.helpers import 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窗口布局与分屏多任务高效指南【必学】  微博网页版官方账号登录 微博网页版内容浏览使用指南 

搜索