java 删除超过10000的es索引数据

可以使用 Elasticsearch 的 Delete By Query API 来删除超过10000条的索引数据。

首先，我们需要使用 Scroll API 来获取要删除的数据的 ID 列表，然后再使用 Delete By Query API 来进行删除操作。

示例代码：

RestHighLevelClient client = new RestHighLevelClient(
        RestClient.builder(new HttpHost("localhost", 9200, "http")));

// 构建查询请求
SearchRequest searchRequest = new SearchRequest("my_index");
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(QueryBuilders.matchAllQuery());
searchSourceBuilder.size(10000); // 每个批次删除10000条数据
searchRequest.source(searchSourceBuilder);

// 使用 Scroll API 获取数据的 ID 列表
SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
String scrollId = searchResponse.getScrollId();
SearchHit[] searchHits = searchResponse.getHits().getHits();
List<String> idList = new ArrayList<>();
for (SearchHit hit : searchHits) {
    String id = hit.getId();
    idList.add(id);
}

// 使用 Delete By Query API 删除数据
BulkByScrollResponse bulkResponse = DeleteByQueryAction.INSTANCE.newRequestBuilder(client)
        .filter(QueryBuilders.matchQuery("_id", String.join(",", idList)))
        .source("my_index")
        .execute(RequestOptions.DEFAULT);
long deletedCount = bulkResponse.getDeleted();
System.out.println("Deleted " + deletedCount + " documents");

// 清除 Scroll 上下文
ClearScrollRequest clearScrollRequest = new ClearScrollRequest();
clearScrollRequest.addScrollId(scrollId);
client.clearScroll(clearScrollRequest, RequestOptions.DEFAULT);

// 关闭客户端连接
client.close();

上述代码中，我们首先使用 Search API 查询出要删除的数据的 ID 列表，然后使用 Delete By Query API 进行删除。为了避免一次性删除过多的数据导致的性能问题，我们将每次删除的数据条数限制为10000条。如果要删除的数据量较大，可以使用循环批量删除的方式，直到所有数据都被删除为止。

注意，Delete By Query API 的执行效率较低，不适合频繁的使用。在实际使用中，应该尽量避免使用 Delete By Query API 来进行数据删除操作。