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

Posted hunterxiong

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了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下的Elasticsearch操作

导入包

from elasticsearch import Elasticsearch

本地连接

es = Elasticsearch([127.0.0.1:9200])

创建索引

es.indices.create(index="python_es01",ignore=400)

ingore=400 ingore是忽略的意思,400是未找到

删除索引

es.indices.delete(index="python_es01")

检查索引是否存在

es.indices.exists(index="python_es01")

插入数据

es.index(index="python_es01",doc_type="doc",id=1,body={"name":"kitty","age":50})

同时也可以不加id,即

es.index(index="python_es01",doc_type="doc",body={"name":"kitty","age":10})

查询操作

按id查询

result = es.get(index="python_es01",doc_type="doc",id=1)

会有一个返回值

全查

body= {
        "query":{
            "match_all":{}
        }
    }
result = es.search(index="python_es01",body=body)

使用id的用GET,其他search

删除操作

result = es.delete(index="goods",doc_type="type1",id=2)

按查询结果删除

result = es.delete_by_query(index="goods",body=body)

建立mapping

body = {
    "mappings": {
        "properties": {
            "name": {
                "type": "text"
            },
            "price": {
                "type": "long"
            }
        }
    }
}
result = es.indices.create(index="shang",body=body)

 

以上是关于Python连接es笔记四之创建和删除操作的主要内容,如果未能解决你的问题,请参考以下文章

python下的Elasticsearch操作

Android学习笔记四之Activity

ELK学习笔记:3- python api&pyspark读取es中filebeat收集的日志数据-2023-2-11

Java操作ElasticSearch-索引-文档

Python学习笔记

重修课程day40(mysql四之表与表关联和表操作)