单一操作
插入
create:必须指定待查询的idnex、type、id和查询体body;缺一不可,否则报错
index:相比于create,index的用法就相对灵活很多;id并非是一个必选项,如果指定,则该文档的id就是指定值,若不指定,则系统会自动生成一个全局唯一的id赋给该文档。
eg:
body = {"name": 'lucy', 'sex': 'female', 'age': 10}
es = Elasticsearch(['localhost:9200'])
es.index(index='indexName', doc_type='typeName', body, id=None)
1
2
3
删除
delete:删除指定index、type、id的文档
es.delete(index='indexName', doc_type='typeName', id='idValue')
1
查找
get:获取指定index、type、id所对应的文档
es.get(index='indexName', doc_type='typeName', id='idValue')
1
更新
update:跟新指定index、type、id所对应的文档
es.update(index='indexName', doc_type='typeName', id='idValue', body={待更新字段})
1
批量操作
条件查询
search:查询满足条件的所有文档,没有id属性,且index,type和body均可为None。
body的语法格式必须符合DSL(Domain Specific Language )格式
query = {'query': {'match_all': {}}}# 查找所有文档
query = {'query': {'term': {'name': 'jack'}}}# 查找名字叫做jack的所有文档
query = {'query': {'range': {'age': {'gt': 11}}}}# 查找年龄大于11的所有文档
allDoc = es.search(index='indexName', doc_type='typeName', body=query)
print allDoc['hits']['hits'][0]# 返回第一个文档的内容
1
2
3
4
5
6
7
8
9
条件删除
delete_by_query:删除满足条件的所有数据,查询条件必须符合DLS格式
query = {'query': {'match': {'sex': 'famale'}}}# 删除性别为女性的所有文档
query = {'query': {'range': {'age': {'lt': 11}}}}# 删除年龄小于11的所有文档
es.delete_by_query(index='indexName', body=query, doc_type='typeName')