Spring Boot如何使用RestHighLevelClient按条件删除Elasticsearch索引数据

核心思路 #

你需要的操作不是删除整个ES文档，而是更新文档局部内容：通过ES内置的Painless脚本过滤数组，移除符合条件的元素，再通过RestHighLevelClient的更新API提交请求即可。

前置准备 #

首先确保项目已正确引入对应ES版本的RestHighLevelClient依赖，并完成客户端初始化，示例依赖（以ES 7.17版本为例）：

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>elasticsearch-rest-high-level-client</artifactId>
    <version>7.17.0</version>
</dependency>

客户端配置示例：

@Configuration
public class EsConfig {
    @Bean
    public RestHighLevelClient restHighLevelClient() {
        return new RestHighLevelClient(
                RestClient.builder(new HttpHost("你的ES地址", 9200, "http"))
        );
    }
}

具体实现代码 #

场景1：已知文档ID（如你示例中_id为3的文档） #

@Autowired
private RestHighLevelClient restHighLevelClient;

public void deleteNestedArrayElement() throws IOException {
    // 1. 构造更新请求，指定索引、文档ID
    UpdateRequest request = new UpdateRequest("es_52_companydetails_index", "3");
    
    // 2. 编写Painless脚本：过滤数组移除符合条件的元素，加非空判断避免空指针
    String scriptContent = "if (ctx._source.companyaddress != null) { " +
            "ctx._source.companyaddress.removeIf(addr -> addr.main_phone1 == params.targetPhone); " +
            "}";
    Script script = new Script(ScriptType.INLINE, "painless", scriptContent, 
            Collections.singletonMap("targetPhone", "1"));
    request.script(script);
    
    // 3. 执行请求
    restHighLevelClient.update(request, RequestOptions.DEFAULT);
}

场景2：批量删除所有文档中符合条件的嵌套元素 #

如果不知道文档ID，需要批量处理所有满足条件的文档，使用UpdateByQueryRequest实现：

public void batchDeleteNestedArrayElement() throws IOException {
    UpdateByQueryRequest request = new UpdateByQueryRequest("es_52_companydetails_index");
    
    // 可选：设置查询条件，只处理匹配的文档，示例只处理companyaddress数组中存在main_phone1=1的文档，减少不必要的更新
    request.setQuery(new NestedQueryBuilder("companyaddress", 
            new TermQueryBuilder("companyaddress.main_phone1", "1"), 
            ScoreMode.None));
    
    // 同上面的更新脚本
    String scriptContent = "if (ctx._source.companyaddress != null) { " +
            "ctx._source.companyaddress.removeIf(addr -> addr.main_phone1 == params.targetPhone); " +
            "}";
    Script script = new Script(ScriptType.INLINE, "painless", scriptContent,
            Collections.singletonMap("targetPhone", "1"));
    request.setScript(script);
    
    // 可选配置：设置批量大小、超时时间
    request.setBatchSize(1000);
    request.setTimeout(TimeValue.timeValueMinutes(5));
    
    // 执行请求
    restHighLevelClient.updateByQuery(request, RequestOptions.DEFAULT);
}

注意事项 #

• 需保证RestHighLevelClient的版本和你的ES服务端版本完全一致，避免出现兼容性问题
• 操作前建议先执行查询验证匹配的文档范围，避免误修改数据
• 如果你的companyaddress字段设置为nested类型，批量查询时需要用NestedQueryBuilder匹配，脚本操作不受映射类型影响

内容的提问来源于stack exchange，提问作者Dorayya