天天看點

ES批量删除指定id資料

ES批量删除指定id資料

//查詢指定分頁的待删除的資料
List<KnowledgeBase> knowledgeDeletes = knowledgeBaseMapper.selectKnowledgeBasesDelete(date,pageNum,pageSize);
if (CollectionUtils.isNotEmpty(knowledgeDeletes)) {
    XxlJobLogger.log("執行es清理資料操作start");
    BulkRequest request = new BulkRequest();
    for (KnowledgeBase kb : knowledgeDeletes) {
        DeleteRequest deleteRequest = new DeleteRequest(esIndexProperties.getKnowledgeBaseIndex(),esIndexProperties.getKnowledgeBase(),kb.getId().toString());
        request.add(deleteRequest);
    }
    client.bulk(request);
    XxlJobLogger.log("執行es清理資料操作end");
}      

繼續閱讀