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");
}