Spring Data ElasticSearch 4.0.0 - 使用通配符在相同的多个索引中搜索 class

Question

所以我在 ElasticSearch 和 Spring 数据方面都是新手，我有一项任务是存储所有外发电子邮件的 html 内容。

@Document(indexName = "email")
@Mapping(mappingPath = "elastic/mappings/email.json")
public class EsOutboundEmail extends PartitionedDocument {

有人告诉我按月索引它，我认为这是为了以后冻结旧数据，所以我想出了这样的办法。

public String indexByMonth(AbstractDocument source) {
    final IndexCoordinates cos = elasticSearchMappingInitializer.getOrCreateDatedIndex(source.getClass());

    IndexQueryBuilder queryBuilder = new IndexQueryBuilder()
            .withId(source.getId())
            .withObject(source);

    return elasticsearchOperations.index(queryBuilder.build(), cos);
}

命名如下（忽略 "initializer" bean 名称，它会改变）：

   public IndexCoordinates getOrCreateDatedIndex(Class<? extends AbstractDocument> clazz) {
       String indexName = getIndexName(clazz);
       indexName = String.format("%s-%s", indexName, now().format(DateTimeFormatter.ofPattern("yyyy-MM")));
       final IndexOperations indexOperations = elasticsearchOperations.indexOps(IndexCoordinates.of(indexName));
       if (!indexOperations.exists()) {
           indexOperations.create();
           indexOperations.createMapping(clazz);
       }
       return IndexCoordinates.of(indexName);
   }

   public String getIndexName(Class<? extends AbstractDocument> clazz) {
       if (!clazz.isAnnotationPresent(Document.class)) {
           throw new IllegalStateException("Elasticsearch domain must have @Document annotation!");
       }

       Document annotation = clazz.getDeclaredAnnotation(Document.class);
       return annotation.indexName();
   }

所以结果将是 email-2020-06。

现在，在这里搜索感觉有点不对：

    public <T extends AbstractDocument> T searchOneDated(Query query, Class<T> clazz) {
        String indexName = elasticSearchMappingInitializer.getIndexName(clazz);
        indexName = format("%s-*", indexName);

        return ofNullable(elasticsearchOperations.searchOne(query, clazz, IndexCoordinates.of(indexName)))
                .map(SearchHit::getContent)
                .orElse(null);
    }

我无法摆脱这样一种感觉，即有一种方法可以更简单地做到这一点，但正如我所说，我是新手，4.0.0 的参考文档对这种情况没有帮助，所以我很感激任何对此有更多了解的人的意见。提前致谢。

Answer 1

您可以在 @Document 注释中使用 SpEL 表达式，对于您的情况，例如：

@Document(indexName="email-#{T(java.time.LocalDate).now().format(T(java.time.format.DateTimeFormatter).ofPattern(\"yyyy-MM\"))}")
public class EsOutboundEmail extends PartitionedDocument {
  // ...
}

保存实体：

ESOutboundEmail email = ...;
elasticsearchOperations.save(email);

和搜索：

elasticsearchOperations.searchOne(query, clazz)

如果索引不存在，您仍然需要确保创建索引（请注意，我添加了对 putMapping(Document) 的调用，您错过了）：

   final IndexOperations indexOperations = elasticsearchOperations.indexOps(EsOutboundEmail.class);
   if (!indexOperations.exists()) {
       indexOperations.create();
       Document mapping = indexOperations.createMapping(clazz);
       indexOperations.putMapping(mapping);
   }

编辑 2020-06-16：

我在搜索中漏掉了通配符：

elasticsearchOperations.searchOne(query, clazz, IndexCoordinates.of("email-*"))

Spring Data ElasticSearch 4.0.0 - 使用通配符在相同的多个索引中搜索 class

Spring Data ElasticSearch 4.0.0 - Using wildcards to search in multiple indexes of the same class

java

elasticsearch

spring-data-elasticsearch