es.davy.ai

Preguntas y respuestas de programación confiables

¿Tienes una pregunta?

Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.

Tag: AKKA-HTTP

Akka Streams divide el flujo para el manejo de errores.

Estoy utilizando akka http y streams para cumplir las solicitudes de API. Cuando la solicitud es inválida, quiero devolver un 400 y si es válida, quiero continuar con la computación y devolver el resultado posteriormente. El problema al que me enfrento es que el Payload que recibo de la solicitud . . . Read more

Cómo consumir HttpResponse en Akka Http

import akka.actor.ActorSystem import akka.http.scaladsl.Http import akka.http.scaladsl.model.{HttpMethods, HttpRequest, Uri} import akka.stream.scaladsl.{Flow, Source} import akka.stream.{ActorMaterializer, OverflowStrategy} import spray.json._ import java.util.UUID import scala.concurrent.duration.DurationInt import scala.language.postfixOps import scala.util.{Failure, Success} object SoftwareRegistry extends App with Formatter { implicit val system = ActorSystem(“NPMRegistry”) implicit val materializer = ActorMaterializer() case class NPMPackage(name: String) // leyendo los paquetes . . . Read more

Cómo envolver mis rutas en una directiva de autenticación que luego otorgue visibilidad a una clase personalizada para que mis rutas puedan acceder a ella.

Mis clientes de API pasarán el token de sesión en el encabezado o en la cadena de consulta de la siguiente manera: Encabezado HTTP con clave/valor como MyApp-Token abc123 URL: https://api.example.com/v1/board?authToken=abc123 val secureRoutes = authenticateToken() { contextoAutenticado => path("board") { get { complete(s"ruta de Índice de la tabla ${contextoAutenticado.user.username}") } . . . Read more

Obteniendo datos de S3 con akka-streams, akka-http

Estoy intentando leer un archivo de S3 y enviarlo de vuelta al cliente desde un endpoint de rest basado en akka-http, así: def fetchFromS3(s3Uri: String): Future[Either[CustomError, Source[ByteString, NotUsed]]] = { val data = fetchDataAsStream(s3Uri) .map { case None => Left(CustomError(“Data not found”)) case Some((_, _, source)) => Right(source) } .recover . . . Read more