Python连接es笔记四之创建和删除操作

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

这一篇笔记介绍一下索引和数据的创建和删除。
其实对于索引来说，如果可以接触到 kibana 的话，可以很方便的在界面进行操作，这里简单介绍一下如何使用代码来操作索引的创建和删除。
索引的创建和删除操作

使用的还是 es 的连接：

1. from elasticsearch_dsl import connections
4. connections.configure(
5.     default={"hosts": "localhost:9200"},
6. )
8. conn = connections.connections.get_connection("default")

复制代码

创建索引

1. index_name = "test_create"
2. conn.indices.create(index_name)

复制代码

检测索引是否存在

1. print(conn.indices.exists(index_name))

复制代码

返回的是一个布尔型数据。
删除索引

1. conn.indices.delete(index_name)

复制代码

数据的创建和删除

创建单条数据
还是默认使用刚刚创建的索引 test_create，我们需要往里面加入一条数据，示例如下：

1. index_name = "test_create"
3. conn.index(
4.     index=index_name,
5.     id=1,
6.     body={
7.         "name": "李白"
8.     }
9. )

复制代码

这样就往里面写入了一条 id=1 的数据，如果不指定 id 参数，系统会为我们自动分配一个 id：

1. conn.index(
2.     index=index_name,
3.     body={
4.         "name": "李白"
5.     }
6. )

复制代码

这种创建方式也是允许的。
批量创建数据
这里用到在批量更新时候的使用过的 elasticsearch.helpers 函数。
示例如下：

1. action_1 = {
2.     "_op_type": "index",
3.     "_index": "test_create",
4.     "doc": {"age": 20, "name": "杨过", "address": "终南山"},
5. }
7. action_2 = {
8.     "_op_type": "index",
9.     "_index": "test_create",
10.     "doc": {"age": 21, "name": "郭靖", "address": "桃花岛"},
11. }
13. action_list = [action_1, action_2]
14. helpers.bulk(conn, actions=action_list)

复制代码

在这里，因为是创建数据，所以 _op_type 的值为 index，剩下的使用方法和之前更新的操作一致。
删除操作
删除操作在第一篇笔记介绍查询数据的时候带过一笔，就是通过 Search() 方法加入条件后，不执行 execute()，而是执行 delete() 函数进行删除：

1. s = Search(using="default").index("exam").query("match", name="张三丰")
2. s.delete()

复制代码

还有一种 es 连接直接操作的 delete_by_query() 函数，示例如下：

1. conn = connections.connections.get_connection("default")
3. q1 = ES_Q("term", name="杨过")
5. conn.delete_by_query(
6.     index="exam",
7.     body={
8.         "query": q1
9.     }
10. )

复制代码

如果想获取更多后端相关文章，可扫码关注阅读：


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

继续阅读请点击广告