elasticsearch文档Delete By Query API(二)
执行结果如下：
此API的优势在于它可以集成 wait_for_completion=false，进而透明地返回任务执行状态。如果任务已完成并且 wait_for_completion=false也已经设置，则它将返回 results或者一个error字段，使用这个功能的会自动创建.tasks/task/${taskId}，当然开发者可以删除该文档。
5.Works with the Cancel Task API
任何的 deletebyquery操作都可以使用Task Cancel API取消，如下：
curl -X POST “localhost:9200/_tasks/r1A2WoRbTwKZ516z6NEs5A:36619/_cancel?pretty”
通过上一小节的请求可以获取到Task ID。
取消应该尽快操作但是依然可能需要花费几秒钟，上面的Task API也会列出Task，直到该Task被唤醒取消自己。
6.Rethrottling
requestpersecond的值可以在 deletebyquery期间使用 _rethrottle API进行修改：
curl -X POST “localhost:9200/_delete_by_query/r1A2WoRbTwKZ516z6NEs5A:36619/_rethrottle?requests_per_second=-1”
通过上一小节的请求可以获取到Task ID。
就像在 _delete_by_query API中设置节流参数一样， request_per_second如果为-1表示禁用限制，或者任何十进制数字，如1.7或12，以节流到该级别，对于加速查询的会立即生效，但是对于减慢查询的，则是在完成当前批处理之后才会生效，这样可以防止滚动超时。
7.Slicing
delete by query 支持 sliced scroll 进而实现并行化删除，这种并行化可以提高效率，并提供一种方便的方法将请求分解为更小的部分。
7.1 Manually slicingedit
首先可以手动的进行并行化处理，如下：
curl -X POST “localhost:9200/twitter/_delete_by_query?pretty” -H ‘Content-Type: application/json’ -d’
{
“slice”: {
“id”: 0,
“max”: 2
},
“query”: {
“range”: {
“likes”: {
“lt”: 10
}
}
}
}
’
curl -X POST “localhost:9200/twitter/_delete_by_query?pretty” -H ‘Content-Type: application/json’ -d’
{
“slice”: {
“id”: 1,
“max”: 2
},
“query”: {
“range”: {
“likes”: {
“lt”: 10
}
}
}
}
’
开发者只需要指定一个slice id和slice数量即max，这里的slice id不能大于max。
接下来通过如下方式可以验证：
curl -X GET “localhost:9200/_refresh?pretty”
curl -X POST “localhost:9200/twitter/_search?size=0&filter_path=hits.total&pretty” -H ‘Content-Type: application/json’ -d’
{
“query”: {
“range”: {
“likes”: {
“lt”: 10
}
}
}
}
’
一个合理的执行结果类似下面这样：
7.2 Automatic slicingedit
开发者还可以通过使用切片的 _uid来让 deletebyquery自动并行执行，此时，只需要指定slices数量即可，如下：
curl -X POST “localhost:9200/bank/_delete_by_query?refresh&slices=5&pretty” -H ‘Content-Type: application/json’ -d’
{
“query”: {
“match_all”: {}
}
}
’
执行结果如下，可以看到每次删除的文档数量：
开发者也可以通过如下请求去验证：
curl -X POST “localhost:9200/bank/_search?size=0&filter_path=hits.total&pretty” -H ‘Content-Type: application/json’ -d’
{
“query”: {
“match_all”: {}
}
}
’
验证结果如下：
设置slices为auto将让Elasticsearch选择要使用的切片数，此设置将使每个分片一个切片，达到限制后，如果有多个源索引，它将根据具有最小分片数量的索引选择切片数。
将slices添加到deleteby_query中可以自动执行上述手动切片过程，创建子请求，这意味着它有如下特点：
-
开发者可以在Tasks API中查看这些请求，这些子请求是具有slices请求任务的“子”任务。
-
获取slices请求的状态仅包含已完成切片的状态。
自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。
深知大多数Java工程师，想要提升技能，往往是自己摸索成长或者是报班学习，但对于培训机构动则几千的学费，着实压力不小。自己不成体系的自学效果低效又漫长，而且极易碰到天花板技术停滞不前！
因此收集整理了一份《2024年Java开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。
既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Java开发知识点，真正体系化！
由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！
如果你觉得这些内容对你有帮助，可以扫码获取！！（备注Java获取）
最后
ActiveMQ消息中间件面试专题
- 什么是ActiveMQ?
- ActiveMQ服务器宕机怎么办？
- 丢消息怎么办？
- 持久化消息非常慢怎么办？
- 消息的不均匀消费怎么办？
- 死信队列怎么办？
- ActiveMQ中的消息重发时间间隔和重发次数吗？
ActiveMQ消息中间件面试专题解析拓展：
redis面试专题及答案
- 支持一致性哈希的客户端有哪些？
- Redis与其他key-value存储有什么不同？
- Redis的内存占用情况怎么样？
- 都有哪些办法可以降低Redis的内存使用情况呢？
- 查看Redis使用情况及状态信息用什么命令？
- Redis的内存用完了会发生什么？
- Redis是单线程的，如何提高多核CPU的利用率？
Spring面试专题及答案
- 谈谈你对 Spring 的理解
- Spring 有哪些优点？
- Spring 中的设计模式
- 怎样开启注解装配以及常用注解
- 简单介绍下 Spring bean 的生命周期
Spring面试答案解析拓展
高并发多线程面试专题
- 现在有线程 T1、T2 和 T3。你如何确保 T2 线程在 T1 之后执行，并且 T3 线程在 T2 之后执行？
- Java 中新的 Lock 接口相对于同步代码块（synchronized block）有什么优势？如果让你实现一个高性能缓存，支持并发读取和单一写入，你如何保证数据完整性。
- Java 中 wait 和 sleep 方法有什么区别？
- 如何在 Java 中实现一个阻塞队列？
- 如何在 Java 中编写代码解决生产者消费者问题？
- 写一段死锁代码。你在 Java 中如何解决死锁？
高并发多线程面试解析与拓展
jvm面试专题与解析
- JVM 由哪些部分组成？
- JVM 内存划分？
- Java 的内存模型?
- 引用的分类？
- GC什么时候开始？
JVM面试专题解析与拓展！
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！
如何解决死锁？
高并发多线程面试解析与拓展
[外链图片转存中…(img-Pu3TkSNr-1713083997197)]
jvm面试专题与解析
- JVM 由哪些部分组成？
- JVM 内存划分？
- Java 的内存模型?
- 引用的分类？
- GC什么时候开始？
JVM面试专题解析与拓展！
[外链图片转存中…(img-cFdrKFaI-1713083997197)]
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取！
北京人形旗下天工造物具身智能开源社区，聚焦具身天工与慧思开物两大平台
更多推荐
17
0- 0
已为社区贡献4条内容
所有评论(0)