首页 > 编程语言 >Python连接es笔记四之创建和删除操作

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

时间:2023-05-31 20:56:14浏览次数:50  
标签:index name 删除 Python 创建 笔记 索引 es conn

本文首发于公众号: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
    }
)

如果想获取更多后端相关文章,可扫码关注阅读:
image

标签:index,name,删除,Python,创建,笔记,索引,es,conn
From: https://www.cnblogs.com/hunterxiong/p/17447302.html

相关文章

  • m基于FPGA的RGB转ycrcb颜色空间转换算法实现,包含testbench,对比三种转换方法
    1.算法仿真效果vivado2019.2仿真结果如下:其中1为直接乘法公式计算;2为移位法计算;3为分布式计算;2.算法涉及理论知识概要人类获得信息的主要方式是视觉,通常情况下颜色有2种描述方式,一种是RGB色度空间表示,一种是YCbCr色度空间表示。然而,普通的RGB颜色空间对视频的显示存在......
  • m基于FPGA的RGB转ycrcb颜色空间转换算法实现,包含testbench,对比三种转换方法
    1.算法仿真效果vivado2019.2仿真结果如下: 其中1为直接乘法公式计算; 2为移位法计算; 3为分布式计算; 2.算法涉及理论知识概要        人类获得信息的主要方式是视觉,通常情况下颜色有2种描述方式,一种是RGB色度空间表示,一种是YCbCr色度空间表示。然而,普通......
  • 理解RESTful 架构
    REST是所有Web应用都应该遵守的架构设计指导原则。 RepresentationalStateTransfer,翻译是”表现层状态转化”。 面向资源是REST最明显的特征,对于同一个资源的一组不同的操作。资源是服务器上一个可命名的抽象概念,资源是以名词为核心来组织的,首先关注的是名词。REST要求,必须通......
  • Autowired注解与Resource注解的区别
    两者的用法其实这两个注解的作用都一样,都是在做bean的注入,在使用过程中,两个注解有时候可以替换使用.两者的共同点@Resource注解和@Autowired注解都可以用作bean的注入.在接口只有一个实现类的时候,两个注解可以互相替换,效果相同不同点:1、@Resource注解是Java自身的注解......
  • AtCoder Beginner Contest 288(D,E,F)
    AtCoderBeginnerContest288(D,E,F)D(思维)D有一个数组,然后有\(q\)次询问,每一次输入一对\(l,r\),我们要判断这一段里面的数是不是好数组好数组,在进行下面任意次操作后可以把这一段数字都变成\(0\),那么这就是个好数组操作是选择一个\(i\)和一个\(c\),但是\(i+k-1\)要小于\(......
  • 系数矩阵为Hessian矩阵时的使用Pearlmutter trick的共轭梯度解法
    共轭梯度法已经在前文中给出介绍:python版本的“共轭梯度法”算法代码  =======================================  使用共轭梯度法时,如果系数矩阵为Hessian矩阵,那么我们可以使用Pearlmuttertrick技术来减少计算过程中的内存消耗,加速计算。 使用Pearlmuttertrick的......
  • Python中的join()函数和split()函数的用法
    题目:CFUltra-FastMathematician 题意:给两个长度相等的0,1字符串,在相同的位置的两个字符不同就输出1,否则输出0.比如:10101000100101就输出:1110001代码:print''.join("10"[i==j]fori,jinzip(raw_input(),raw_input()))join()函数的用法就是把一个list中所有的串按照你定义的分隔......
  • Python基础语法
    Python中查看变量对应的地址用函数id(var)。 注意在Python中与在C语言中有一些不同的地方。比如:a = 10,在Python中是这样的,数值10在内存中开辟一块空间来存放数据10,然后用a去引用这个10,所以这里a相当于一个标签,如果a被重新赋值了,相当于a又指向了另一个地址,比如a = 1000,那么a指......
  • python获取threading多线程的return返回值
    转载:(15条消息)python获取threading多线程的return返回值_pythonthreading返回值_星火燎愿的博客-CSDN博客我们正常使用threading模块创建的线程是无法获取它所执行方法的返回值的;如:w=threading.Thread(target=worker,args=(i,))一、重写线程,获取线程return返回值要想获......
  • 【2023 · CANN训练营第一季】——开发者套件进阶,玩转智能小车课程笔记
    前言:基于新款开发者套件Atlas200IDKA2的智能小车,采用人工智能的方法,对摄像头采集到实时影像进行推理,产生电机等运动机构的控制指令,在特定环境里,实现自动行驶、自动泊车、目标跟踪等功能。昇腾官方开源了“玩”小车的全部软、硬件资料,还准备了模拟环境,让还没有小车的小伙伴体验自......