济南网站建设联系小七,常见问题 网站建设,网页模板免费html,小游戏网站模板这一篇笔记介绍一下索引和数据的创建和删除。
其实对于索引来说#xff0c;如果可以接触到 kibana 的话#xff0c;可以很方便的在界面进行操作#xff0c;这里简单介绍一下如何使用代码来操作索引的创建和删除。
索引的创建和删除操作
使用的还是 es 的连接#xff1a;…这一篇笔记介绍一下索引和数据的创建和删除。
其实对于索引来说如果可以接触到 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_createconn.index(indexindex_name,id1,body{name: 李白}
)这样就往里面写入了一条 id1 的数据如果不指定 id 参数系统会为我们自动分配一个 id
conn.index(indexindex_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, actionsaction_list)在这里因为是创建数据所以 _op_type 的值为 index剩下的使用方法和之前更新的操作一致。
删除操作
删除操作在第一篇笔记介绍查询数据的时候带过一笔就是通过 Search() 方法加入条件后不执行 execute()而是执行 delete() 函数进行删除
s Search(usingdefault).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(indexexam,body{query: q1}
)原文链接Python连接es笔记四之创建和删除操作
