Ejecutar un pipeline

Hasta ahora, la canalización ha sido un esquema puro. La materialización es el proceso que convierte ese esquema en actores en ejecución que realmente mueven los datos.

No ocurre nada hasta que ejecuta explícitamente el grafo, lo que permite que Akka Streams sea componible y reutilizable.

La materialización requiere un ActorSystem, que proporciona los hilos y el dispatcher en los que se ejecutan las etapas del flujo. En Akka moderno, el sistema también actúa como materializer implícito.

Normalmente, un ActorSystem sirve a una aplicación completa y a muchos flujos simultáneos.

La forma más directa de ejecutar un Source es runWith, que asocia un Sink y materializa todo en un solo paso, devolviendo el valor materializado de ese Sink.

En este caso, el resultado es un Future[Int] que se completa con la suma cuando termina el flujo.

Si ya ha creado un RunnableGraph cerrado con to o toMat, llame a run() para materializarlo. El valor devuelto es el valor materializado que haya conservado el grafo.

Esto separa claramente la construcción de la canalización de su ejecución.

Los Sources ofrecen accesos directos: runForeach, runFold y runReduce asocian el Sink correspondiente y ejecutan el flujo de inmediato.

Son opciones concisas para operaciones terminales habituales sobre un Source.

Los Sinks terminales devuelven un Future que se completa cuando el flujo termina o falla. Registre callbacks con onComplete para reaccionar ante un resultado correcto o un error.

Use el dispatcher del ActorSystem como ExecutionContext implícito para estos callbacks.

Una canalización de datos típica lee de un Source, transforma los datos con Flows, realiza E/S asíncrona con mapAsync, agrupa con grouped y escribe en un Sink.

Cada etapa es pequeña y todo se materializa con un único run.

Para aumentar la resiliencia, envuelva un Source o un Flow con RestartSource.withBackoff para que los fallos transitorios (como una conexión interrumpida) activen un reinicio automático con espera exponencial.

Esto mantiene activas las canalizaciones de ingesta de larga duración sin supervisión manual.

Un KillSwitch permite que el código externo detenga un flujo en ejecución de forma limpia. Inserte KillSwitches.single mediante viaMat y conserve su valor materializado para llamar posteriormente a shutdown().

Esto es esencial para los flujos de larga duración que deben detenerse cuando se apaga la aplicación.

Cuando la aplicación se cierra, termine el ActorSystem para liberar sus hilos. Encadene la llamada a terminate después del Future de finalización del flujo para que el apagado sea ordenado.

Dejar un ActorSystem sin liberar mantiene activa la JVM y conserva los recursos abiertos.

Materializar el mismo esquema varias veces crea flujos independientes en ejecución que comparten los recursos del ActorSystem. El esquema en sí permanece inmutable y sin efectos secundarios.

Esto permite definir una canalización una sola vez y ejecutarla bajo demanda para cada trabajo entrante.

Considere qué se necesita para que un flujo procese realmente los elementos.

Ejecutar una canalización significa materializar un esquema con un ActorSystem mediante run, runWith u operadores de conveniencia, cada uno de los cuales devuelve un resultado Future.

Ha visto canalizaciones realistas de varias etapas, reinicios automáticos con espera progresiva, apagado ordenado mediante KillSwitch, limpieza de recursos con system.terminate() y reutilización segura de un esquema inmutable en ejecuciones independientes.