Es批量删除DeleteByQueryRequestBuilder

ops/2024/9/24 7:23:54/

一、DeleteByQueryRequestBuilder

DeleteByQueryRequestBuilder是Elasticsearch Java客户端中的一个类,用于构建和执行基于查询条件删除文档的请求。实验结果表明:删除速率大概是每秒3万条左右。

DeleteByQueryRequestBuilder类提供了一种方便的方式来构建删除文档的查询请求。它允许您指定一个查询条件,并使用该条件来删除匹配的文档。

使用DeleteByQueryRequestBuilder类,您可以执行各种类型的查询,如基于字段值、范围、词条匹配、布尔逻辑查询等。

以下是DeleteByQueryRequestBuilder类的一些常用方法:

  1. setQuery(QueryBuilder query):设置查询条件。
  2. setIndices(String... indices):设置要在哪些索引中执行删除操作。
  3. setTypes(String... types):设置要在哪些类型中执行删除操作。
  4. setRouting(String routing):设置路由值,以确定要删除的文档所在的特定分片。
  5. setSize(int size):设置每次批量删除的文档数量。
  6. setScroll(TimeValue scroll):设置滚动时间,如果删除的文档数量太多,可以使用滚动来分批删除。

二、Es版本号:6.8.23

           <dependency><groupId>org.elasticsearch.client</groupId><artifactId>transport</artifactId><version>6.8.23</version></dependency>

三、代码:

 /*** 根据查询条件删除Es数据* @param queryBuilder 查询条件*/public long deleteByQueryInSlave(QueryBuilder queryBuilder) {try {// client 是初始化的Es客户端BulkByScrollResponse response = new DeleteByQueryRequestBuilder(client, DeleteByQueryAction.INSTANCE).filter(queryBuilder)// indexName是Es的索引.source(indexName).get();long deleted = response.getDeleted();logger.info("deleteByQueryInSlave, 删除成功,删除文档条数: " + deleted + " ,indexName:" + indexName);} catch (Exception e) {logger.error("deleteByQueryInSlave-根据查询条件删除Es数据-异常, queryBuilder:{}", queryBuilder.toString(), e);}return 0;}

 


http://www.ppmy.cn/ops/13280.html

相关文章

Java语言开发的AI智慧导诊系统源码springboot+redis 3D互联网智导诊系统源码

Java语言开发的AI智慧导诊系统源码springbootredis 3D互联网智导诊系统源码 智慧导诊解决盲目就诊问题&#xff0c;减轻分诊工作压力。降低挂错号比例&#xff0c;优化就诊流程&#xff0c;有效提高线上线下医疗机构接诊效率。可通过人体画像选择症状部位&#xff0c;了解对应…

【C语言】操作符

㊙️小明博客主页&#xff1a;➡️ 敲键盘的小明 ㊙️ ✅关注小明了解更多知识☝️ 文章目录 前言一、什么是操作符 &#xff1f;二、操作符的分类三、操作符详解3.1 算术操作符3.2 移位操作符3.2.1 左移操作符&#xff08;<<&#xff09;3.2.2 右移操作符&#xff08;&g…

Qt | 键盘事件

Qt | 鼠标事件第四节十、键盘事件 1、Qt 使用 QKeyEvent 类来描述与键盘有关的信息,比如按下或释放键的代码,使用枚举类型 QEvent::Type 描述与键盘有关的事件,比如 QEvent::KeyPress 表示键盘按下事件, QEvent::KeyRelease表示键盘释放事件等。 2、是否接收键盘事件,最…

(ChatGPT、Al柯基、Al Web、ChatGPT4.0中文网、VIVI-Al)分享好用的ChatGPT

目录 1、ChatGPT 2、AI柯基 - 智能写作助手 - 沈阳满信电子商务有限公司 3、AI Web

【Ubuntu20.04】使用 systemd 进行服务部署

1、服务文件 ExecStart&#xff0c;改成自己脚本的路径&#xff0c;比如程序启动脚本Restart&#xff0c;异常重启RestartSec&#xff0c;异常后多少秒后重启StartLimitInterval&#xff0c;异常后重试多少次&#xff0c;0 一直重试 [Unit] Descriptionyour_app[Service] Typ…

Oracle SQL - HAVING和分析函数的执行顺序

分析函数是基于最终的结果集进行开窗的&#xff0c;所以HAVING比分析函数先执行 ↓ 没有HAVING时&#xff0c;MAX(col3) over()是A2 SQL> WITH subq_a AS2 (SELECT A col1, A1 col2, 10 col33 FROM dual4 UNION ALL5 SELECT A col1, A1 col2, -5 col36 F…

STM32 MPU配置参数

TXE LEVEL一般只用MPU_TEX_LEVEL0 1 - 1 - 1 -0性能最强&#xff08;TEX - C - B- S&#xff09;. #define MPU_TEX_LEVEL0 ((uint8_t)0x00) #define MPU_TEX_LEVEL1 ((uint8_t)0x01) #define MPU_TEX_LEVEL2 ((uint8_t)0x02) 基于上表进行常用配置 &#xff…

Wireshark数据包分析入门

Wireshark数据包分析 1. 网络协议基础1.1. 应传网数物&#xff08;应表会传网数物&#xff09; 2. 三次握手2.1. 第一次握手2.2. 第二次握手2.3. 第三次握手2.4. 三次握手后流量特征 3. 第一层---物理层&#xff08;以太网&#xff09;4. 第二层---数据链路层&#xff08;PPP L…