Akka-http logrequest不记录请求正文

Question

我正在使用akka-http，并尝试使用logrequest记录特定路径上的请求：

 path(Segment / "account") { id =>
            logRequest("users/account", Logging.InfoLevel) {
              post {
              entity(as[Account]) { account => ???
                complete(HttpResponse(StatusCodes.NoContent))
              }
            }
          }

然而，在我的日志中我看到了类似这样的东西

HttpRequest(HttpMethod(POST),https://localhost:9009/api/users/123/account,List(Host: localhost:9009, User-Agent: akka-http/10.0.6, Timeout-Access: <function1>),HttpEntity.Chunked(application/json),HttpProtocol(HTTP/1.1))

我正在寻找的是确切的请求，包括请求者发送的正文(json)。

Answer 1

日志的"HttpEntity.Chunked(application/json)"段是HttpEntity.Chunked#toString的输出。要获取作为流实现的整个请求体，您需要调用HttpEntity#toStrict将Chunked请求实体转换为Strict请求实体。您可以在自定义路由中进行此呼叫：

def logRequestEntity(route: Route, level: LogLevel)
                    (implicit m: Materializer, ex: ExecutionContext) = {

  def requestEntityLoggingFunction(loggingAdapter: LoggingAdapter)(req: HttpRequest): Unit = {
    val timeout = 900.millis
    val bodyAsBytes: Future[ByteString] = req.entity.toStrict(timeout).map(_.data)
    val bodyAsString: Future[String] = bodyAsBytes.map(_.utf8String)
    bodyAsString.onComplete {
      case Success(body) =>
        val logMsg = s"$req\nRequest body: $body"
        loggingAdapter.log(level, logMsg)
      case Failure(t) =>
        val logMsg = s"Failed to get the body for: $req"
        loggingAdapter.error(t, logMsg)
    }
  }
  DebuggingDirectives.logRequest(LoggingMagnet(requestEntityLoggingFunction(_)))(route)
}

要使用上述功能，请将您的路由传递给它：

val loggedRoute = logRequestEntity(route, Logging.InfoLevel)