Python连接es之查询方式示例汇总
作者:Hunter 发布时间:2023-06-07 11:11:03
上一节除了介绍使用 Python 连接 es,还有最简单的 query() 方法,这一节介绍一下几种其他的查询方式。
1、query() 方法介绍
在上一节中介绍了 query() 的一个简单示例,如下:
s = Search(using="default").index("exam")
s = s.query("match", name="张三丰")
query() 中接受两个参数,第一个是字段查询的方式,比如这里是 match,也可以是 term,这个依照查询的目的来替换。
第二个则是查询的字段与值,比如这里是查询的 name 字段为 "张三丰" 的数据。
如果是有多个条件,比如 name="张三丰",address="中国" 的数据,这里的 = ,并非是完全等于的意思,而是会依照前面的查询方式,比如 match 或 term 进行类似的分词或者模糊搜索。
如果是上面多个条件的查询,可以直接在后面加上类似的 query():
s = s.query("match", name="张三丰").query("match", address="中国")
这两个 query() 通过链式操作连在一起转换成 es 语句就是使用 must 将多条件连接在一起,我们可以使用 to_dict() 方式来查看:
s.to_dict()
# {'query': {'bool': {'must': [{'match': {'name': '张三丰'}}, {'match': {'address': '中国'}}]}}}
2、Q() 查询
如果看过之前我写过的 Django 系列笔记,应该记得在 Django 里也有个 Q() 方法的查询,和这里的一样,也是用于条件的联合,与或非条件都可以实现。
引入方式如下:
from elasticsearch_dsl import Q
但是如果是在 Django 中使用 es 的连接,也是同样使用 Q() 方法,我们可以使用 as 来区分,这里我们对于 es 的 Q() 方法可以使用 ES_Q() 来区分:
from elasticsearch_dsl import Q as ES_Q
单个条件的使用 Q() 如下:
s = s.query(ES_Q("match", name="张三丰"))
如下使用 dict 形式的操作也是等效的:
s = s.query(ES_Q({"match": {"name": "张三丰"}}))
与操作
对于这两个条件,如果想要实现它们的与操作:
q1 = ES_Q("match", name="张三丰")
q2 = ES_Q("match", address="中国")
可以如下实现:
s = s.query(q1 & q2)
或操作
如果是想实现上面的或操作,可以如下:
s = s.query(q1 | q2)
非操作
如果是想取反,直接在条件前加一个 ~
即可:
q1 = ~ES_Q("match", name="张三丰")
s = s.query(q1)
multi_match
如果是搜索多字段,可以如下操作:
q = ES_Q("multi_match", query="中国 张三丰", fields=["name", "address"])
s = s.query(q)
text.keyword 操作
对于 es 中 text 字段,前面我们介绍过 .keyword
的查询方式,是将 text 字段作为一个整体进行查询,在 ES_Q() 中,以下两种操作是等效的:
q = ES_Q({"term": {"address.keyword": "中国湖北省"}})
q = ES_Q("term", address__keyword="中国湖北省")
filter() 操作
在 es 中的 filter 操作,在 Python 中是一个 filter() 函数,可以直接使用:
q = ES_Q("term", name="张三丰")
s = s.filter(q)
range 操作
实现大小于的操作示例如下:
q = ES_Q({"range": {"age": {"gte": 21}}})
s = s.query(q)
exclude() 操作
如果是想取反,除了使用 ~Q(),还可以直接使用 exclude() 函数,这个和 Django 里的操作也是一样的:
q = ES_Q("term", name="张三丰")
s = s.exclude(q)
3、排序
如果是想对返回的结果进行排序操作,直接使用 .sort() 方法。
比如想对 age 字段排序,正序返回数据,可如下操作:
s = s.sort("age")
如果是想倒序返回,可以如下操作:
s = s.sort("-age")
多字段排序直接在后面跟上就行:
s = s.sort("-age", "name")
4、分页
Python 连接 es 进行分页,可以直接使用 Python 里的切片操作,比如:
s = s[5:10]
5、source() 指定返回字段
我们可以通过 source() 方法指定返回的字段:
s = s.source(["name", "address"])
source() 方法还可以接受 includes 和 excludes 参数来指定返回的字段或者不返回的字段,这个和 es 的原生处理方式是一致的:
s = s.source(
includes=["address"],
excludes=["name"]
)
6、extra() 操作
extra() 函数接受一些查询的额外属性,比如 size 参数决定返回条数,比如 from 参数可以决定从第几条数据开始返回,sort 参数决定排序方式,以及 _source 参数决定返回的字段。
比如我们想要返回的数据从第 2 条数据开始,返回两条,按照 name 字段进行排序,只返回 name 和 _id 字段,可以如下操作:
s = Search(using="default").index("exam")
s = s.extra(
sort="name",
_source=["name"],
**{
"from": 1,
"size": 2
}
)
response = s.execute()
7、count() 总数
前面介绍过获取符合条件的总数,可以通过 response.hits.total.value 的方式获得,其实对于 Search(),可以直接使用 count() 函数:
count = s.count()
8、from_dict() 函数
如果我们想直接运行 kibana 里执行的命令,可以使用 from_dict() 函数,比如:
s = s.from_dict(
{
"query": {
"term": {
"name": {
"value": "张三丰"
}
}
}
}
)
来源:https://segmentfault.com/a/1190000043662350
猜你喜欢
- 引言近期在好几个地方都看到meshgrid的使用,虽然之前也注意到meshgrid的用法。但总觉得印象不深刻,不是太了解meshgrid的应
- 我认为多选列表具有完美的功能——只需按下Ctrl键,同时点击鼠标从列表中选择多个项目。以下是一个典型的多选列表框:选出你最喜爱的快餐:&nb
- 本文较为详细的分析了php提示Failed to write session data错误的解决方法。分享给大家供大家参考。具体方法如下:一
- 如下所示:sudo easy_install requests出现如图所示信息done即可愉快的使用 requests了来源:https:/
- python-redis-lock官方文档不错的博文可参考问题背景在使用celery执行我们的异步任务时,为了提高效率,celery可以开启
- 上一篇博客主要介绍了决策树的原理,这篇主要介绍他的实现,代码环境python 3.4,实现的是ID3算法,首先为了后面matplotlib的
- 1.打包多个py文件并且去除cmd黑框格式:pyinstaller.exe -F 路径\文件名.py空格路径\文件名.py空格--nocon
- 星爷的一部“国产007”应该是无人不晓,其中一个片段是将“007”向MM展示他的秘密武器。皮鞋可以吹头发,大哥大可以刮胡子……把真实功能隐蔽
- 编程小白在线学习代码,前几天帮女朋友合并表格cv大佬在线泪目,想想之前合并表格也是一直cv,重复性且效率低下的操作完全可以用代码来实现。就用
- 一、概述公司新购了一批PC,准备把几个性能较优的PC升级为数据库服务器,替换老旧的机器。公司有套POS终端软件,后台数据存储是 MySQL
- 先给大家展示下效果图,大家感觉不错,请参考实现代码:实现原理:点击按钮,往需要动画的div中添加或移除拥有动画效果的class。由于微信小程
- 序言:php错误就是会使脚本运行不正常的情况。php的错误有很多种,包括warning、notice、deprecated、fetal er
- 官网资料:loc :https://pandas.pydata.org/pandas-docs/stable/reference
- reload() 简介作用:用于重新载入之前载入的模块语法格式:reload(module)参数:module为模块对象,必须已经被加载返回
- It's well-known.Microsoft SQL Server 7.0增加了一个语句top,可以限制返回的记录数。但是在使
- 前言说说外星人那些事儿....你以为的外星人......他们都是乘坐UFO来地球的,长的嗯哼可能比较有特色。也许长这样害!其实可能也或许不长
- 前言因为工作中不怎么使用python,所以对python的了解不够,只是在使用的时候才去学,在之前的几个例子中几乎没使用什么python的特
- 在开发中有些敏感接口,例如用户余额提现接口,需要考虑在并 * 况下接口是否会发生问题。如果用户将自己的多条提现请求同时发送到服务器,代码能否扛
- 前言在 Go 单元测试这个系列的第二部分 数据库的Mock测试 中我们介绍了用 go-sqlmock 给数据库的 CRUD 操作做Mock
- python全代码如下import reimport csvimport matplotlib.pyplot as pltx=[]y=[]m