本文首发于公众号:Hunter后端
原文链接:Python连贯es笔记四之创立和删除操作
这一篇笔记介绍一下索引和数据的创立和删除。
其实对于索引来说,如果能够接触到 kibana 的话,能够很不便的在界面进行操作,这里简略介绍一下如何应用代码来操作索引的创立和删除。
索引的创立和删除操作
应用的还是 es 的连贯:
from elasticsearch_dsl import connectionsconnections.configure( default={"hosts": "localhost:9200"},)conn = connections.connections.get_connection("default")
创立索引
index_name = "test_create"conn.indices.create(index_name)
检测索引是否存在
print(conn.indices.exists(index_name))
返回的是一个布尔型数据。
删除索引
conn.indices.delete(index_name)
数据的创立和删除
创立单条数据
还是默认应用刚刚创立的索引 test_create
,咱们须要往里面退出一条数据,示例如下:
index_name = "test_create"conn.index( index=index_name, id=1, body={ "name": "李白" })
这样就往里面写入了一条 id=1 的数据,如果不指定 id 参数,零碎会为咱们主动调配一个 id:
conn.index( index=index_name, body={ "name": "李白" })
这种创立形式也是容许的。
批量创立数据
这里用到在批量更新时候的应用过的 elasticsearch.helpers 函数。
示例如下:
action_1 = { "_op_type": "index", "_index": "test_create", "doc": {"age": 20, "name": "杨过", "address": "终南山"},}action_2 = { "_op_type": "index", "_index": "test_create", "doc": {"age": 21, "name": "郭靖", "address": "桃花岛"},}action_list = [action_1, action_2]helpers.bulk(conn, actions=action_list)
在这里,因为是创立数据,所以 _op_type 的值为 index,剩下的应用办法和之前更新的操作统一。
删除操作
删除操作在第一篇笔记介绍查问数据的时候带过一笔,就是通过 Search() 办法退出条件后,不执行 execute(),而是执行 delete() 函数进行删除:
s = Search(using="default").index("exam").query("match", name="张三丰")s.delete()
还有一种 es 连贯间接操作的 delete_by_query() 函数,示例如下:
conn = connections.connections.get_connection("default")q1 = ES_Q("term", name="杨过")conn.delete_by_query( index="exam", body={ "query": q1 })
如果想获取更多后端相干文章,可扫码关注浏览: