写点什么

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

作者:Hunter熊
  • 2023-11-22
    北京
  • 本文字数:997 字

    阅读完需:约 3 分钟

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 })
复制代码


发布于: 刚刚阅读数: 5
用户头像

Hunter熊

关注

公众号:Hunter后端 2018-09-17 加入

Python后端工程师,欢迎互相沟通交流

评论

发布
暂无评论
Python连接es笔记四之创建和删除操作_Python_Hunter熊_InfoQ写作社区