如何用Elastic4s实现类似Kibana的ElasticSearch单文档查询

我来帮你搞定这个问题！你现在用字符串拼接JSON查询的方式不仅容易出语法错误，还没用到Elastic4s提供的类型安全DSL优势。针对你的ES 5.5.1版本，我们可以用更简洁可靠的方式实现和Kibana查询一样的效果，甚至更高效。

首先确认版本兼容性 #

Elastic4s的版本必须和你的ES版本严格对应，ES 5.5.1对应的Elastic4s版本是5.5.x系列（比如5.5.11）。如果依赖版本不对，很可能会出现各种奇怪的兼容性问题，这点一定要注意。

方法1：用DSL实现和Kibana完全一致的Terms查询 #

如果你想完全对应Kibana里的terms查询写法，用Elastic4s的DSL可以这样写：

// 导入必要的包
import com.sksamuel.elastic4s.http.HttpClient
import com.sksamuel.elastic4s.http.ElasticDsl._
import com.sksamuel.elastic4s.ElasticsearchClientUri
import scala.concurrent.ExecutionContext.Implicits.global

// 配置参数
val esHosts = "your-es-host-address" // 替换成你的ES主机地址
val customerId = "0231545"

// 创建HTTP客户端
val client = HttpClient(ElasticsearchClientUri(esHosts, 9200))

// 构建查询：对应Kibana里的GET /crm/profiles/_search {"query":{"terms":{"_id":["0231545"]}}}
val searchRequest = search("crm" / "profiles").query(termsQuery("_id", customerId))

// 执行查询并处理结果
client.execute(searchRequest).map { response =>
  if (response.isSuccess) {
    val hits = response.result.hits.hits
    hits.foreach { hit =>
      // 获取文档源数据，这里可以直接打印或者转换成自定义对象
      println(s"找到目标文档：${hit.sourceAsString}")
    }
  } else {
    println(s"查询失败：${response.error}")
  }
}.recover {
  case ex: Exception => println(s"查询出现异常：${ex.getMessage}")
}

方法2：用更高效的ID查询（推荐） #

因为你只需要获取单个ID的文档，用idQuery比termsQuery更贴合需求，代码也更简洁：

// 替换上面的searchRequest为：
val searchRequest = search("crm" / "profiles").query(idQuery(customerId))

方法3：直接用Get API获取文档（最优选择） #

如果明确是根据文档ID获取单个文档，用ES的Get API比Search API更高效（省去了搜索的开销），对应Kibana里的GET /crm/profiles/0231545，Elastic4s的写法如下：

// 构建Get请求
val getRequest = get(customerId).from("crm" / "profiles")

// 执行请求并处理结果
client.execute(getRequest).map { response =>
  if (response.isSuccess) {
    response.result.sourceAsString.foreach { source =>
      println(s"成功获取文档：$source")
    }
  } else {
    println(s"获取文档失败：${response.error}")
  }
}

额外提示：解析文档为自定义对象 #

如果需要把返回的JSON文档转换成Scala case class，可以用Jackson来解析：

import com.fasterxml.jackson.databind.ObjectMapper
import com.fasterxml.jackson.module.scala.DefaultScalaModule

// 初始化Jackson mapper
val mapper = new ObjectMapper().registerModule(DefaultScalaModule)

// 定义你的Profile case class
case class Profile(_id: String, name: String, email: String /* 其他字段根据实际情况定义 */)

// 在处理结果时转换：
hits.foreach { hit =>
  val profile = mapper.readValue(hit.sourceAsString, classOf[Profile])
  println(s"解析后的用户信息：$profile")
}

内容的提问来源于stack exchange，提问作者T Chevalier