java - Spring Data ElasticSearch 4.0.0 - 使用通配符在同一类的多个索引中搜索
问题描述
所以我是 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 的参考文档对这种情况没有帮助,所以我会感谢对此有更多了解的人的任何意见。提前致谢。
解决方案
您可以在注释中使用 SpEL 表达式@Document
,对于您的情况,例如:
@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-*"))
推荐阅读
- sql - 存在函数
- ios - 在同一个应用程序中拥有导航控制器和标签栏控制器
- kotlin - Kotlin - 在 init 块中使用编译的正则表达式会引发空指针异常
- javascript - 文本输入的反应状态真的很慢
- javascript - 我无法使用 reactjs fetch 和 nodejs 作为 REST apis 项目读取服务器端的授权标头
- github - 文件夹上的 GitHub 箭头无法打开
- graphql - NestJS Fastify graphql e2e 测试失败
- css - Css 关键帧和动画无法在 Google Chrome 或 Firefox 上运行
- python - 将不和谐的机器人(python)上传到 Heroku:App 与 buildpack 错误不兼容(我知道它被问了很多)
- python-3.x - Python获取具有相同CSS类的html标签列表