Удаление нескольких документов из индекса в ElasticSearch со значением одного из элементов - версия 7.8 - PullRequest
Новая
       79

Удаление нескольких документов из индекса в ElasticSearch со значением одного из элементов - версия 7.8

1 голос
/ 14 июля 2020

мой do c в elsticsearch выглядит так, как показано ниже 

    "hits" : [
      {
        "_index" : "MyIndex",
        "_type" : "_doc",
        "_id" : "Lxh7THMBycWRIeJFdwbZ",
        "_score" : 1.0,
        "_source" : {
          "@timestamp" : "2020-07-14T13:10:26.087+0430",
          "message" : "elk: customer inserted: id=5",
          "traceId" : "ABC",
          "severity" : "INFO",
          "thread" : "http-nio-8095-exec-2"
        }
      }
]

Я хочу удалить все документы в одном индексе, который "traceId": "AB C" с кодом java. Я использую Elasticsearch 7.8, а мой клиент - RestHighLevelClient. пожалуйста, направь меня.

1 Ответ

0 голосов
/ 14 июля 2020

Приведенный ниже пример кода должен помочь. Вы можете обратиться к приведенным ниже ссылкам на go через API и понять, что нужно сделать поэтапно.

Практически каждый запрос, отправленный через Java, будет состоять из двух частей.

Что касается вашего примера, обратите внимание, что я предполагаю, что traceId.keyword - это поле типа keyword, и, следовательно, я использую TermBuilder т.е. Term Query . Если это тип text, я упомянул Match Query в комментарии, вам придется использовать его.

Пример кода 

import java.io.IOException;

import org.apache.http.HttpHost;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.index.query.TermQueryBuilder;
import org.elasticsearch.index.reindex.BulkByScrollResponse;
import org.elasticsearch.index.reindex.DeleteByQueryRequest;

public class DeleteBasedOnQuery {

    public static void main(String[] args) throws IOException {

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

        deleteQueryUsingMatch(client);

        client.close();

    }
    
    private static void deleteQueryUsingMatch(RestHighLevelClient client) throws IOException {
        
        //Mention index name
        DeleteByQueryRequest request = new DeleteByQueryRequest("my_delete_index");
        request.setConflicts("proceed"); 
        request.setBatchSize(100);
        request.setRefresh(true); 
        
        //Term Query to Delete the document. Note the field name and value in below code
        request.setQuery(new TermQueryBuilder("traceId.keyword", "ABC"));
        
        //Match Query to Delete the Document
        //request.setQuery(QueryBuilders.matchQuery("traceID", "abc"));
        
        //Execute the request to delete based on above details
        BulkByScrollResponse bulkResponse = client.deleteByQuery(request, RequestOptions.DEFAULT);
        
        //By this time your delete query got executed and you have the response with you. 
        long totalDocs = bulkResponse.getTotal(); 
        long deletedDocs = bulkResponse.getDeleted(); 
        
        //Print the response details
        System.out.println("Total Docs Processed :: " +  totalDocs);
        System.out.println("Total Docs Deleted :: " +  deletedDocs);        
        
    }

}
...