ElasticSearch en mémoire pour les tests

Je voudrais écrire quelques intégration avec ElasticSearch. Pour les tests je voudrais exécuter en mémoire ES.

J'ai trouvé quelques informations dans la documentation, mais sans exemple comment écrire ce genre de test. Elasticsearch Référence [1.6] » Test » Java Framework de Test » tests d'intégration
« les tests unitaires

Aussi j'ai trouvé l'article suivant, mais il est hors de données. Facile JUnit test avec Elastic Search

Je cherche exemple de la façon de démarrer et exécuter ES en mémoire et l'accès à celui-ci via l'API REST.

J'avais commencer à regarder Elasticsearch propres classes de test. Par exemple, celui-ci où l'indice le type de magasin peut être ram.

OriginalL'auteur MicTech | 2015-07-14

  1. 6

    Basé sur le second lien que vous avez fourni, j'ai créé ce test abstrait classe:

    @RunWith(SpringJUnit4ClassRunner.class)
public abstract class AbstractElasticsearchTest {
private static final String HTTP_PORT = "9205";
private static final String HTTP_TRANSPORT_PORT = "9305";
private static final String ES_WORKING_DIR = "target/es";
private static Node node;
@BeforeClass
public static void startElasticsearch() throws Exception {    
removeOldDataDir(ES_WORKING_DIR + "/" + clusterName);
Settings settings = Settings.builder()
.put("path.home", ES_WORKING_DIR)
.put("path.conf", ES_WORKING_DIR)
.put("path.data", ES_WORKING_DIR)
.put("path.work", ES_WORKING_DIR)
.put("path.logs", ES_WORKING_DIR)
.put("http.port", HTTP_PORT)
.put("transport.tcp.port", HTTP_TRANSPORT_PORT)
.put("index.number_of_shards", "1")
.put("index.number_of_replicas", "0")
.put("discovery.zen.ping.multicast.enabled", "false")
.build();
node = nodeBuilder().settings(settings).clusterName("monkeys.elasticsearch").client(false).node();
node.start();
}
@AfterClass
public static void stopElasticsearch() {
node.close();
}
private static void removeOldDataDir(String datadir) throws Exception {
File dataDir = new File(datadir);
if (dataDir.exists()) {
FileSystemUtils.deleteRecursively(dataDir);
}
}    
}

    Dans le code de production, j'ai configuré un Elasticsearch client comme suit. Le test d'intégration s'étend au-dessus défini classe abstraite et configure propriété elasticsearch.port comme 9305 et elasticsearch.host comme localhost.

    @Configuration
public class ElasticsearchConfiguration {    
@Bean(destroyMethod = "close")
public Client elasticsearchClient(@Value("${elasticsearch.clusterName}") String clusterName,
@Value("${elasticsearch.host}") String elasticsearchClusterHost,
@Value("${elasticsearch.port}") Integer elasticsearchClusterPort) throws UnknownHostException {
Settings settings = Settings.settingsBuilder().put("cluster.name", clusterName).build();
InetSocketTransportAddress transportAddress = new InetSocketTransportAddress(InetAddress.getByName(elasticsearchClusterHost), elasticsearchClusterPort);
return TransportClient.builder().settings(settings).build().addTransportAddress(transportAddress);
}
}

    Que c'est. Le test d'intégration va exécuter le code de production qui est configuré pour se connecter au nœud a commencé dans le AbstractElasticsearchTest.startElasticsearch().

    Dans le cas où vous souhaitez utiliser le elasticsearch api REST, utiliser le port 9205. E. g. avec Apache HttpComponents:

    HttpClient httpClient = HttpClients.createDefault();
HttpPut httpPut = new HttpPut("http://localhost:9205/_template/" + templateName);
httpPut.setEntity(new FileEntity(new File("template.json")));
httpClient.execute(httpPut);
    Pour ceux qui viennent là, il ressemble dans l'ES 5.x ils ont enlevé le NodeBuilder. Je ne sais pas si il existe un moyen pour exécuter ES directement à partir de vos tests unitaires.

    OriginalL'auteur

  2. 2

    Voici ma mise en œuvre 

    import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.util.UUID;
import org.elasticsearch.client.Client;
import org.elasticsearch.common.settings.ImmutableSettings;
import org.elasticsearch.node.Node;
import org.elasticsearch.node.NodeBuilder;
/**
*
* @author Raghu Nair
*/
public final class ElasticSearchInMemory {
private static Client client = null;
private static File tempDir = null;
private static Node elasticSearchNode = null;
public static Client getClient() {
return client;
}
public static void setUp() throws Exception {
tempDir = File.createTempFile("elasticsearch-temp", Long.toString(System.nanoTime()));
tempDir.delete();
tempDir.mkdir();
System.out.println("writing to: " + tempDir);
String clusterName = UUID.randomUUID().toString();
elasticSearchNode = NodeBuilder
.nodeBuilder()
.local(false)
.clusterName(clusterName)
.settings(
ImmutableSettings.settingsBuilder()
.put("script.disable_dynamic", "false")
.put("gateway.type", "local")
.put("index.number_of_shards", "1")
.put("index.number_of_replicas", "0")
.put("path.data", new File(tempDir, "data").getAbsolutePath())
.put("path.logs", new File(tempDir, "logs").getAbsolutePath())
.put("path.work", new File(tempDir, "work").getAbsolutePath())
).node();
elasticSearchNode.start();
client = elasticSearchNode.client();
}
public static void tearDown() throws Exception {
if (client != null) {
client.close();
}
if (elasticSearchNode != null) {
elasticSearchNode.stop();
elasticSearchNode.close();
}
if (tempDir != null) {
removeDirectory(tempDir);
}
}
public static void removeDirectory(File dir) throws IOException {
if (dir.isDirectory()) {
File[] files = dir.listFiles();
if (files != null && files.length > 0) {
for (File aFile : files) {
removeDirectory(aFile);
}
}
} 
Files.delete(dir.toPath());        
}
}
    Ce n'plusieurs ouvrages sur l'ES 5.X Ils ont enlevé NodeBuilder
    Je suppose que nous pouvons toujours la solution de contournement à l'aide d'un Noeud(paramètres).start();

    OriginalL'auteur

  3. 1

    Vous pouvez démarrer ES en local sur votre machine à l'aide de:

    Settings settings = Settings.settingsBuilder()
.put("path.home", ".")
.build();
NodeBuilder.nodeBuilder().settings(settings).node();

    Quand ES a commencé, remplir gratuit pour accéder à plus de REPOS à l'aide de curl ou d'autres outils:

    curl http://localhost:9200/_cat/health?v

    OriginalL'auteur