没有找到参数sprayJsonReader 的隐式：JsonReader[T]

如何解决没有找到参数sprayJsonReader 的隐式：JsonReader[T]

我创建了一个 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