Динамический индекс с SpringData ElasticSearch

Question

Как я могу параметризовать индекс SpringData ElasticSearch во время выполнения?

Например, модель данных:

@Document(indexName = "myIndex") 
public class Asset { 

    @Id 
    public String id; 

    // ... 
} 

и репозиторий:

public interface AssetRepository extends ElasticsearchCrudRepository<Asset, String> { 

    Asset getAssetById(String assetId); 
} 

Я знаю, что могу заменить myIndex с параметром, но этот параметр будет решен во время создания экземпляра/загрузки. У нас есть та же структура активов для нескольких клиентов/арендаторов, у которых есть свой собственный индекс. Что мне нужно что-то вроде этого:

public interface AssetRepository extends ElasticsearchCrudRepository<Asset, String> { 

    Asset getAssetByIdFromIndex(String assetId, String index); 
} 

или это

repoInstance.forIndex("myOtherIndex").getAssetById("123"); 

Я знаю, что это не работает из коробки, но есть ли способ программно «взломать» его?

Answer 1

org.springframework.data.elasticsearch.repository.ElasticSearchRepository имеет метод

FacetedPage<T> search(SearchQuery searchQuery); 

где SearchQuery может занять несколько индексов, которые будут использоваться для поиска.

Я надеюсь, что он отвечает

Answer 2

Даже при том, что боб инициализации во время загрузки, вы можете достичь его родниковой языка выражений:

@Bean 
Name name() { 
    return new Name(); 
} 

@Document(indexName="#{name.name()}") 
public class Asset{} 

Вы можете изменить свойство бина, чтобы изменить индекс вы хотите сохранить/поиск:

assetRepo.save(new Asset(...)); 
    name.setName("newName"); 
    assetRepo.save(new Asset(...)); 

Что следует отметить, не поделиться этой боб в нескольких потоке, который может испортить ваш индекс.

Адрес a working example.