您的位置:首页 > 编程语言 > Python开发

python 调用elasticsearch的几种不同方式

2018-03-09 17:29 411 查看
from elasticsearch import Elasticsearch
from elasticsearch_dsl import Search,Q,scan
es = Elasticsearch()

1、仿照kibana中的写法
q = {"query": {"match": {"name": "easy"}}}
res = es.Search(body=q)
#这中方式返回的结果和kibana查询结果一致,为json

2、通过elasticsearch_dsl的Search方法
s = Search().using(es).query('match',name='easy')
res = s.execute()
# MultiMatch(query='python django', fields=['title', 'body'])
# Match(title={"query": "web framework", "type": "phrase"})

3、通过Q方式写查询语句(避免了字典的多重嵌套)
q = Q("match",name='easy')
s = Search().using(es).query(q)
res = s.execute(ignore_cache=True)
#ignore_cache=True 清除缓存数据,不然即使改变了查询语句执行出的为之前的结果
可通过s.to_dict()验证语句
可通过s.query = Q("match",name='haha') 重建查询语句
#通过dsl的查询得到的结果有自己的调用方法 res.hits[0].id

4、通过scan的方式
q = {"query": {"match": {"name": "easy"}}}
res = scan(es,size=100,preserve_order=True,query=q)
#本机上实验size参数无作用,总是返回所有结果,preserve_order=True设置为flase或不设置会报错,希望解答
doc = [i for i in res] #即可得到所有返回结果
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: