2017-12-25 11 views
1

私のアプリケーションは、esサーバを起動する必要があります。つまり、ローカルノードを意味します。クライアントはHttpClientでなければなりません。ElasticSearch test httpクライアント

val clusterName: String = "getting-started-with-elastic4s" 
val homePath: Path = Files.createTempDirectory(clusterName) 
val localNode = LocalNode(clusterName,homePath.toAbsolutePath.toString) 
localNode.start() 
val client = HttpClient(ElasticsearchClientUri("localhost",9200)) 
client.execute{ 
    createIndex("trial") 
}.await 

タイムアウトになります。なにが問題ですか?

答えて

0

ポートが9200になるという保証はありません。通常はが、おそらく他のポートを使用しています。ローカル・ノード自体からhttpクライアントを生成する必要があります。

val clusterName = "getting-started-with-elastic4s" 
    val homePath = Files.createTempDirectory(clusterName) 
    val localNode = LocalNode(clusterName, homePath.toAbsolutePath.toString) 
    localNode.start() 

    val client = localNode.http(true) 
    val resp = client.execute { 
    createIndex("trial") 
    }.await 
    println(resp) 
+0

私は5.5を使用しています。このhttpコールは6.0であると思います。 –

+0

も5.5でなければなりません。 – monkjack

関連する問題