安装
pip install elasticsearch pip install elasticsearch[async] #支持异步
插入
from elasticsearch import Elasticsearch
from elasticsearch import AsyncElasticsearch
esClient = Elasticsearch(hosts="127.0.0.1",port=9200)
esClient.index(index="test",doc_type="_doc",document={
'name':'merry charistma',
'age':18
})
查询
from elasticsearch import Elasticsearch
from elasticsearch import AsyncElasticsearch
esClient = Elasticsearch(hosts="127.0.0.1",port=9200)
#查询
body={
'bool':{
'must':[
{
'term':{
'age':{
'value':18
}
}
}
]
}
}
res = esClient.search(index="test",query=body)
print(res)
cnt = esClient.count(index="test",body={
"query":body
})
print(cnt)
修改
from elasticsearch import Elasticsearch
from elasticsearch import AsyncElasticsearch
esClient = Elasticsearch(hosts="127.0.0.1",port=9200)
esClient.update(index="test",doc_type="_doc",id=1,body={
"doc":{
"name":"长得丑"
}
}
)
删除
from elasticsearch import Elasticsearch from elasticsearch import AsyncElasticsearch esClient = Elasticsearch(hosts="127.0.0.1",port=9200) esClient.delete(index="test",doc_type="_doc",id=1)
