Python连接es笔记四之创建和删除操作,其实对于索引来说,如
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
}
)
如果想获取更多后端相关文章,可扫码关注阅读:
相关内容
- Python连接es笔记三之es更新操作,对于es的更新的操作
- Python连接es笔记二之查询方式汇总,以下是本篇笔记目
- Python连接es笔记一之连接与查询es,以下是本篇笔记目录
- Django笔记四十之运行Django环境的python脚本,假设说我们
- Django笔记三十九之settings配置介绍,以下是本篇笔记目
- Django笔记三十八之发送邮件,在Python中,提
- Django笔记三十七之多数据库操作(补充版),在第二十二
- Django笔记三十六之单元测试汇总介绍,在我们创建的每
- Django笔记三十五之admin后台界面介绍,Django自带了一
- Django笔记三十三之缓存操作,在Django中可以
评论关闭