Eseguire una pipeline

Finora la pipeline è stata un blueprint puro. La materializzazione è il processo che trasforma quel blueprint in actor in esecuzione, capaci di trasferire effettivamente i dati.

Non accade nulla finché non si esegue esplicitamente il grafo: è questo che rende Akka Streams componibile e riutilizzabile.

La materializzazione richiede un ActorSystem, che fornisce i thread e il dispatcher su cui si basano gli stage dello stream. Nelle versioni moderne di Akka, il sistema funge anche da materializer implicito.

In genere un ActorSystem serve un'intera applicazione e numerosi stream concorrenti.

Il modo più diretto per eseguire un Source è runWith, che collega un Sink e materializza il grafo in un unico passaggio, restituendo il valore materializzato di quel Sink.

In questo caso il risultato è un Future[Int] che si completa con la somma al termine dello stream.

Se ha già costruito un RunnableGraph chiuso con to o toMat, chiami run() per materializzarlo. Il valore restituito è il valore materializzato conservato dal grafo.

In questo modo la costruzione della pipeline viene separata con chiarezza dalla sua esecuzione.

I Source offrono alcune scorciatoie: runForeach, runFold e runReduce collegano ciascuno il Sink corrispondente ed eseguono immediatamente lo stream.

Sono soluzioni concise per le operazioni terminali più comuni su un Source.

I sink terminali restituiscono un Future che si completa quando lo stream termina o fallisce. Registri le callback con onComplete per reagire al successo o all'errore.

Per queste callback usi il dispatcher dell'ActorSystem come ExecutionContext implicito.

Una pipeline di dati tipica legge da una Source, trasforma i dati con i Flow, esegue operazioni di I/O asincrone con mapAsync, raggruppa gli elementi in batch con grouped e scrive in un Sink.

Ogni fase è piccola e l'intera pipeline viene materializzata con una sola chiamata a run.

Per garantire la resilienza, racchiuda una Source o un Flow in RestartSource.withBackoff, in modo che gli errori temporanei, come una connessione interrotta, attivino un riavvio automatico con backoff esponenziale.

In questo modo le pipeline di acquisizione dati di lunga durata rimangono attive senza supervisione manuale.

Un KillSwitch consente al codice esterno di arrestare in modo ordinato uno stream in esecuzione. Inserisca KillSwitches.single tramite viaMat e conservi il relativo valore materializzato per poter chiamare in seguito shutdown().

Questo è essenziale per gli stream di lunga durata che devono arrestarsi quando l'applicazione viene terminata.

Quando l'applicazione termina, termini l'ActorSystem per liberare i relativi thread. Esegua la chiamata a terminate dopo il Future di completamento dello stream, così l'arresto avverrà in modo ordinato.

Lasciare un ActorSystem non terminato mantiene attiva la JVM e lascia aperte le risorse.

Materializzare più volte lo stesso blueprint crea stream indipendenti in esecuzione che condividono le risorse dell'ActorSystem. Il blueprint rimane immutabile e privo di effetti collaterali.

Questo consente di definire una pipeline una sola volta ed eseguirla su richiesta per ogni nuovo job.

Eseguire una pipeline significa materializzare un blueprint con un ActorSystem tramite run, runWith o gli operatori di utilità, ciascuno dei quali restituisce un Future.

Ha visto pipeline realistiche composte da più fasi, riavvii automatici con backoff, arresti ordinati tramite KillSwitch, pulizia delle risorse con system.terminate() e il riutilizzo sicuro di un blueprint immutabile in esecuzioni indipendenti.