Tag: AKKA-HTTP
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
Tengo un caso de uso que implica manejar la carga de un archivo en 3 pasos: Crear entrada en la base de datos Extraer metadatos del archivo y guardarlos en la base de datos utilizando el id anterior Guardar el archivo en una carpeta en la nube Quiero que el . . . Read more
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
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
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