Elasticsearch Scala Config

This is a simple elasticsearch scala config.

SBT Config

Add the following dependency:

"com.sksamuel.elastic4s" %% "elastic4s-http" % "6.5.1"

Code Config

Create the ES client:

import com.sksamuel.elastic4s.http.{ElasticClient, ElasticProperties}
import com.sksamuel.elastic4s.http.ElasticDsl._
import org.apache.http.impl.nio.client.HttpAsyncClientBuilder
import org.apache.http.impl.client.BasicCredentialsProvider
import org.apache.http.auth.UsernamePasswordCredentials
import org.apache.http.client.config.RequestConfig
import org.apache.http.auth.AuthScope

val connectionRequestTimeoutMs = 30000
val socketTimeoutMs = 30000
val url = "http://localhost:920"

// Credential provider
val provider: Option[BasicCredentialsProvider] = for {
  userName <- sys.env.get("ES_USER")
  password <- sys.env.get("ES_PW")
} yield {
  val basicCredentialsProvider = new BasicCredentialsProvider
  val credentials = new UsernamePasswordCredentials(userName, password)
  basicCredentialsProvider.setCredentials(AuthScope.ANY, credentials)
  basicCredentialsProvider
}

// Elasticsearch client
val client: ElasticClient = ElasticClient(
  ElasticProperties(url),
  (requestConfigBuilder: RequestConfig.Builder) => {
    requestConfigBuilder
      .setConnectionRequestTimeout(connectionRequestTimeoutMs)
      .setSocketTimeout(socketTimeoutMs)
  },
  (httpClientBuilder: HttpAsyncClientBuilder) => { provider
    .map { credsProvider => httpClientBuilder.setDefaultCredentialsProvider(credsProvider) }
    .getOrElse(httpClientBuilder)
  }
)

// Create an index...
client.execute(createIndex("idx")).await

RHDZMOTA/es-scala-config.md

Elasticsearch Scala Config

SBT Config

Code Config