Akka HTTP 클라이언트 응답 실패를 처리하는 방법

Question

Akka HTTP 클라이언트 요청이 미래의 [HttpResponse]를 반환합니다. 미래를 처리하는 방법은 무엇입니까? 오류를 기록하거나 감독관에게 다시 던지기 만하면됩니까?

Furure가 실패 할 수있는 오류는 물론 클라이언트가 던져서 반환 할 수있는 오류 유형에 대한 문서가 있으므로 관리자에게 자동으로 전파됩니다.

Answer 1

대부분 맛의 문제입니다. 난 당신이 또한 오류

val decider: Decider = { 
    case ex => 
    ex.printStackTrace() 
    Supervision.Stop // Passes error down to subscriber 
} 

를 처리하고 다음 중 하나 materializer

에서 사용하는 Decider을 지정할 수 있습니다 일반적으로 Future[Try[HttpResponse]]에 Future[HttpResponse] 변환 및 플로우 기반 클라이언트를 사용하는 경우 다음

response.flatMap { tryResp => 

    tryResp match { 
    case Success(res) => 
     res.status match { 
     case OK => 
      // Unmarshal response here into Future[Something] 
     case Found => 
      // Handle redirect by calling requestBlhBlah() again with anotehr URI 
     case _ => 
      // I got status code I didn't expect so I wrap it along with body into Future failure 
      Unmarshal(res.entity).to[String].flatMap { body => 
      Future.failed(new IOException(s"The response status is ${res.status} [${request.uri}] and response body is $body")) 
      } 
     } 
    case Failure(ex) => 
     Future.failed(ex) 
    } 
} 

로 처리 .withAttributes(ActorAttributes.supervisionStrategy(decider))

,369 통해

implicit val materializer = ActorMaterializer(ActorMaterializerSettings(system).withSupervisionStrategy(decider))(system) 

또는 플로우 별 기반에서

Future 실패마다 처리 방법은 사용자에게 달려 있습니다. recoverWith을 사용하여 오류를 다른 것으로 변환하거나 Future.onFailure에 로그인하십시오.