问题描述
我创建了一个 sbt 项目来学习如何在 akka 中使用弹性搜索。我遇到了提供此功能的 alpakka
(用于连接 elasticsearch)。
根据文档,要从 ES 搜索,我们有以下代码:
val connectionSettings = ElasticsearchConnectionSettings("http://localhost:9200")
val sourceSettings = ElasticsearchSourceSettings(connectionSettings)
val elasticsearchParamsV7 = ElasticsearchParams.V7("index")
val copy = ElasticsearchSource
.typed[User](
elasticsearchParamsV7,query = """{"match_all": {}}""",sourceSettings
)
import spray.json.{DefaultJsonProtocol,RootJsonFormat}
case class User(first_name: String,last_name: String,email: String)
object MyJsonProtocol extends DefaultJsonProtocol {
implicit val userFormat: RootJsonFormat[User] = jsonFormat3(User)
}
我发现一个错误显示与spray json reader说...
No implicits found for parameter sprayJsonReader: JsonReader[User]
我不知道我在这里遗漏了什么。
我已经导入了两个库
"akka-http-spray-json"
"spray-json"
在 build.sbt 文件中
解决方法
您的 dec_output
不在 userFormat
的范围内,因此请导入它,例如:
ElasticsearchSource.typed