所以我在 ElasticSearch 和 Spring Data 方面都是新手,并且我有一个任务来存储所有外发电子邮件的 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);
}
命名如下(忽略“初始化程序”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 的引用文档对这种情况没有帮助,所以我非常感谢对此有更多了解的人提供的任何意见。提前致谢。
最佳答案
您可以在 @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-*"))
关于java - Spring Data ElasticSearch 4.0.0 - 使用通配符在同一类的多个索引中搜索,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/62386833/