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-STREAM

Extraer la clave y los contenidos de nivel superior de un JSON grande utilizando streaming

Un procedimiento en un sistema consiste en ‘extraer’ una clave y su valor (objeto) a un archivo dedicado para posteriormente procesarlo de alguna manera en un script (irrelevante). Un subconjunto representativo del archivo JSON original se ve así: { “version”: null, “produced”: “2021-01-01T00:00:00+0000”, “other”: “contenido aquí”, “items”: [ { “code”: . . . Read more

Mejor manera de procesar una respuesta grande (400mb) del HttpClient para ZipArchive.

Intentaré mantenerlo breve y preciso. Requisito: Descargar una respuesta XML grande (400 MB) de un tercero y guardarla como archivo ZipArchive en el disco. Solución actual: using (var memoryStream = new MemoryStream()) { using (var archive = new ZipArchive(memoryStream, ZipArchiveMode.Create, true)) { var file = archive.CreateEntry($”{deliveryDate:yyyyMMdd}.xml”); using(var entryStream = file.Open()) . . . Read more

El objeto “stream” no es miembro del paquete akka.

Tengo el siguiente archivo build.sbt: ThisBuild / version := “0.1.0-SNAPSHOT” ThisBuild / scalaVersion := “2.13.7” val akkaVersion = “2.6.18” lazy val root = (project in file(“.”)) .settings( name := “akka-sbt-multijvm-issue” ) libraryDependencies ++= Seq(“com.typesafe.akka” %% “akka-actor” % akkaVersion, “com.typesafe.akka” %% “akka-stream” % akkaVersion, “com.typesafe.akka” %% “akka-cluster” % akkaVersion) Tengo el . . . Read more

Servicios de transmisión de tuberías en C#

Supongamos que tienes dos servicios externos: “`C# public void Service1(Stream input, Stream output) { // Realiza algunas acciones: toma el flujo de entrada, // lo elabora y devuelve el resultado en el flujo de salida. } <pre><code><br />“`C# public void Service2(Stream input, Stream output) { // Realiza algunas acciones: toma . . . Read more