阿卡-HTTP logrequest不記錄我使用請求主體

Question

阿卡-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)) 

我在找的是確切的請求，包括請求者發送的body（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)