I am using the Elasticsearch’s 8.x Java API client for indexing documents to Elasticsearch. While indexing, I’m specifying an ingest pipeline to be executed during data ingestion.
<code>public Mono<IndexResponse> addContent(RequestDoc requestDoc) {
IndexRequest<ContentTransformedModel> indexRequest = IndexRequest.of(request -> request
.index("test-index")
.document(requestDoc)
.pipeline("test-ingest-pipeline"));
return reactiveElasticsearchClient.index(indexRequest)
.onErrorResume(IOException.class,
e -> Mono.error(new ElasticsearchPublishException(ES_INDEX_INTERNAL_SERVER_ERROR, e)));
}
</code>
<code>public Mono<IndexResponse> addContent(RequestDoc requestDoc) {
IndexRequest<ContentTransformedModel> indexRequest = IndexRequest.of(request -> request
.index("test-index")
.document(requestDoc)
.pipeline("test-ingest-pipeline"));
return reactiveElasticsearchClient.index(indexRequest)
.onErrorResume(IOException.class,
e -> Mono.error(new ElasticsearchPublishException(ES_INDEX_INTERNAL_SERVER_ERROR, e)));
}
</code>
public Mono<IndexResponse> addContent(RequestDoc requestDoc) {
IndexRequest<ContentTransformedModel> indexRequest = IndexRequest.of(request -> request
.index("test-index")
.document(requestDoc)
.pipeline("test-ingest-pipeline"));
return reactiveElasticsearchClient.index(indexRequest)
.onErrorResume(IOException.class,
e -> Mono.error(new ElasticsearchPublishException(ES_INDEX_INTERNAL_SERVER_ERROR, e)));
}
I want to move this implementation to Spring data elasticsearch. Is it possible to configure ingest pipelines for indexing documents in Spring data elasticsearch?