使用 Spring-Data Elasticsearch 在 Elasticsearch 中动态创建索引名称 [英] Creating Indices name Dynamically in Elasticsearch using Spring-Data Elasticsearch

问题描述

我有一个用例，需要在 Elasticsearch 中每月创建索引.这个想法是在每月的基础上创建索引，以便它们易于维护并且可以在过期时删除.为此，我使用了 spring-batch 并有一个每月的工作，它将为 Elasticsearch 创建每月的索引-Java 集成我使用了 Spring-Data Elasticsearch 实现.我现在面临的问题是，我无法弄清楚如何使用 Entity 对象为索引和映射提供动态名称.我当前的实现是在记住单一索引的情况下完成的.请找到我用来创建索引的以下代码

I have a use case where in need to create the indices per month in Elasticsearch. The idea is to create indices on the monthly bases so that they are easy to maintain and can be deleted when expired.For this to achieve i have used the spring-batch and have a monthly job which will create the indices on monthly bases For Elasticsearch-Java integration I have used the Spring-Data Elasticsearch implementation. The problem which i am facing now is, I am not able to figure out how to provide the dynamic-name to the index and mapping using the Entity object. My Current implementation is done keeping the Single Index in mind. Please find the below code which i am using to create indices

elasticsearchTemplate.createIndex(SingleChat.class);
elasticsearchTemplate.putMapping(SingleChat.class);
elasticsearchTemplate.refresh(SingleChat.class, true);

SingleChat 是我的实体类

And SingleChat is my Entity Class

@Document(indexName="singlemsgtemp_#{jobParameters['MONTH']}",type="singlechat")
public class SingleChat {
    @org.springframework.data.annotation.Id
    String Id;
    @Field(type = FieldType.String)
    String conservationId;
    @Field(type = FieldType.String)
    String from;
    @Field(type = FieldType.String)
    String to;
    @Field(type = FieldType.String)
    String msgContent; 
    @Field(type = FieldType.String)
    String sessionId;
    @Field(type = FieldType.Date, index = FieldIndex.not_analyzed, store = true, format = DateFormat.date_hour_minute_second_millis)
    Date postedDate;
    @Field(type = FieldType.Date, index = FieldIndex.not_analyzed, store = true, format = DateFormat.date_hour_minute_second_millis)
    Date expireDate;
}   

但这并没有按预期工作.我也在尝试其他一些东西.但我愿意接受建议.也可以随意评论我目前的方法，它是否有效.如果需要更多详细信息，请告诉我.

But this is not working as expected. I am trying out some other things also. But i am open for suggestion. Also feel free to comment on my current approach, will it work or not. Please let me know if any more details are required.

推荐答案

我在我的应用程序上所做的是我使用 ElasticSearchTemplate 创建我的动态索引名称，然后我将别名指向我创建的新索引，然后放下旧的.

What I am doing on my application is that I use ElasticSearchTemplate to create my dynamic index name and then I point an alias to the new index I have created and then drop the old one.

esTemplate.createIndex(newIndexName, loadfromFromFile(settingsFileName));
esTemplate.putMapping(newIndexName, "MYTYPE", loadfromFromFile(mappingFileName));

我没有使用我班级的映射和设置，因为我需要它是动态的.

I'm not using the mapping and settings from my class since I need it to be dynamic.

    protected String loadFromFile(String fileName) throws IllegalStateException {
       StringBuilder buffer = new StringBuilder(2048);
       try {
           InputStream is = getClass().getResourceAsStream(fileName);
           LineNumberReader reader = new LineNumberReader(new InputStreamReader(is));
           while (reader.ready()) {
               buffer.append(reader.readLine());
               buffer.append(' ');
           }
       } catch (Exception e) {
           throw new IllegalStateException("couldn't load file " + fileName, e);
       }
       return buffer.toString();
   }

这篇关于使用 Spring-Data Elasticsearch 在 Elasticsearch 中动态创建索引名称的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！