所以我是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);
}
而且命名是这样的(忽略“ 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的参考文档在这种情况下没有帮助,所以我非常感谢对此有更多了解的人的任何投入。提前致谢。
您可以在@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-*"))