使用Java高级Rest客户端弹性搜索自定义创建索引

Question

createIndexWithCustomMappings(String indexName, String fieldsMapping){CreateIndexResponse createIndexResponse = client.admin().indices()
                .prepareCreate(index).setSettings(fieldsMapping).execute().get();}

我有一个在spring boot应用程序中创建弹性搜索索引的代码。目前使用的客户端是transport客户端，它现在根据弹性搜索文档进行折旧，现在被高级Rest客户端取代。

用于使用高级Rest客户端创建索引。我见过这个代码。

    CreateIndexRequest request = new CreateIndexRequest(indexName);
    CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);

这里的fieldsMapping是一个json文件，它包含有关analyzer、tokenizer和filter的详细信息，并作为字符串传递给这个方法。我无法在java rest高级客户端中找到方法来合并setSettings（fieldsMapping）。执行（）。get（）如上所述，使用transport client。

任何关于这个设置（字段映射）如何工作的想法java高级Rest客户端

Answer 1

您可以使用Elasticsearch chRestTemboard本身的实现。

使用Elasticsearch 6。x:

以下是使用设置创建索引的方式：

@Override
    public boolean createIndex(String indexName, Object settings) {
        CreateIndexRequest request = new CreateIndexRequest(indexName);
        if (settings instanceof String) {
            request.settings(String.valueOf(settings), Requests.INDEX_CONTENT_TYPE);
        } else if (settings instanceof Map) {
            request.settings((Map) settings);
        } else if (settings instanceof XContentBuilder) {
            request.settings((XContentBuilder) settings);
        }
        try {
            return client.indices().create(request, RequestOptions.DEFAULT).isAcknowledged();
        } catch (IOException e) {
            throw new ElasticsearchException("Error for creating index: " + request.toString(), e);
        }
    }

以下是更新索引映射的方式：

@Override
    public boolean putMapping(String indexName, String type, Object mapping) {
        Assert.notNull(indexName, "No index defined for putMapping()");
        Assert.notNull(type, "No type defined for putMapping()");
        PutMappingRequest request = new PutMappingRequest(indexName).type(type);
        if (mapping instanceof String) {
            request.source(String.valueOf(mapping), XContentType.JSON);
        } else if (mapping instanceof Map) {
            request.source((Map) mapping);
        } else if (mapping instanceof XContentBuilder) {
            request.source((XContentBuilder) mapping);
        }
        try {
            return client.indices().putMapping(request, RequestOptions.DEFAULT).isAcknowledged();
        } catch (IOException e) {
            throw new ElasticsearchException("Failed to put mapping for " + indexName, e);
        }
    }

使用Elasticsearch 7。x:

1. 你需要创建一个变量IndexCoordinates.of（"indexName"）
2. 从ElasticSearchTem板获取该索引的索引操作
3. 通过像这样的index操作变量创建索引：

IndexOperations indexOperations = elasticsearchTemplate.indexOps(indexCoordinates);
        String indexSettings = "" //Pass json string here
        String mappingJson = "" //Pass json string here
        Document mapping = Document.parse(mappingJson);
        Map<String, Object> settings = JacksonUtil.fromString(indexSettings, new TypeReference<>() {});

        indexOperations.create(settings, mapping);
        indexOperations.refresh(); //(Optional) refreshes the doc count

这实际上取决于您使用的是哪个spring data elasticsearch。也可以随意查看文档：https://docs.spring.io/spring-data/elasticsearch/docs/current/reference/html/#new-特征

希望这对你的elasticsearch之旅有所帮助！请随意询问有关java实现的更多问题：）