如何通过ElasticsearchRestTemplate将搜索请求发送到elastic，参数后带有terminate\u？

Question

我确实请求使用Elasticsearch chRestTemboard为Document实体进行弹性集群。我的DAO类：

import lombok.RequiredArgsConstructor;
import org.jetbrains.annotations.NotNull;
import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;
import org.springframework.data.elasticsearch.core.aggregation.AggregatedPage;
import org.springframework.data.elasticsearch.core.query.SearchQuery;
import org.springframework.stereotype.Component;
import APP_PACKAGE.dto.request.DocElasticFilterDto;
import APP_PACKAGE.dto.request.DocElasticPaginationDto;
import APP_PACKAGE.model.entity.Document;

@Component
@RequiredArgsConstructor
public class DocumentDao {
    private final ElasticsearchRestTemplate esTemplate;

    @NotNull
    public AggregatedPage search(@NotNull DocElasticFilterDto filter, @NotNull DocElasticPaginationDto pagination) {
        SearchQuery query = DocumentQueryBuilderKt.buildSearchQuery(filter, pagination);
        return esTemplate.queryForPage(query, Document.class);
    }
}

ElasticsearchRestTemplate发送到此http请求：

curl -iX POST 'http://HOST:9200/INDEX/_doc/_search?rest_total_hits_as_int=true&typed_keys=true&ignore_unavailable=false&expand_wildcards=open&allow_no_indices=true&ignore_throttled=true&search_type=dfs_query_then_fetch&batched_reduce_size=512' -d '{"from":0,"size":1,"query":{"bool":{"filter":[{"terms":{"pgs":[2],"boost":1.0}},{"terms":{"t":[2],"boost":1.0}}],"adjust_pure_negative":true,"boost":1.0}},"version":true,"sort":[{"t":{"order":"desc"}}]}'

我希望发送带有terminate_after的请求（为每个搜索计算，如从大小（从分页DTO中的参数））参数，如下所示：

curl -iX POST 'http://HOST:9200/INDEX/_doc/_search?rest_total_hits_as_int=true&typed_keys=true&ignore_unavailable=false&expand_wildcards=open&allow_no_indices=true&ignore_throttled=true&search_type=dfs_query_then_fetch&batched_reduce_size=512&terminate_after=1' -d '{"from":0,"size":1,"query":{"bool":{"filter":[{"terms":{"pgs":[2],"boost":1.0}},{"terms":{"t":[2],"boost":1.0}}],"adjust_pure_negative":true,"boost":1.0}},"version":true,"sort":[{"t":{"order":"desc"}}]}'

如何使用spring data elasticsearch实现这一点？

我找到了可能的解决方案-使用没有Spring数据库的RestHighLevelClient

    fun search(filter: DocElasticFilterDto, pagination: DocElasticPaginationDto): DocElasticSearchResult<DocElasticDto> {
        val query = buildSearchQuery(filter)
        log.debug("#search: query: $query")
        val searchSourceBuilder = buildSourceBuilder(query)
        searchSourceBuilder.size(pagination.limit)
        val from = pagination.page * pagination.limit
        searchSourceBuilder.from(from)
        searchSourceBuilder.terminateAfter(from + pagination.limit)

        val response = esClient.search(buildRequest(searchSourceBuilder), RequestOptions.DEFAULT)

        return DocElasticSearchResult(getResults(response), response.hits.totalHits!!.value)
    }

    private fun buildRequest(searchSourceBuilder: SearchSourceBuilder) :SearchRequest {
        val searchRequest = SearchRequest(indexName)
        searchRequest.source(searchSourceBuilder)
        return searchRequest
    }

    private fun buildSourceBuilder(queryBuilder: QueryBuilder) :SearchSourceBuilder {
        val searchSourceBuilder = SearchSourceBuilder()
        searchSourceBuilder.query(queryBuilder)
        searchSourceBuilder.timeout(TimeValue.parseTimeValue(readTimeout, "timeout"))
        return searchSourceBuilder
    }

Answer 1

Spring Data Elasticsearch中当前不支持terminate_after参数。