关于后端:Python连接es笔记四之创建和删除操作

本文首发于公众号：Hunter 后端
原文链接：Python 连贯 es 笔记四之创立和删除操作

这一篇笔记介绍一下索引和数据的创立和删除。

其实对于索引来说，如果能够接触到 kibana 的话，能够很不便的在界面进行操作，这里简略介绍一下如何应用代码来操作索引的创立和删除。

索引的创立和删除操作

应用的还是 es 的连贯：

from elasticsearch_dsl import connections


connections.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}
)

如果想获取更多后端相干文章，可扫码关注浏览：