This repo has the supporting code for the following posts about Akka Streams:
Scala 2.12SbtDocker y docker-compose
-
Example 1: Introduces the main stream components and creation of our first graph. -
Example 2: Playing around with our initial graph in order to show component reutilization. -
Example 3: Shows how to materialize different values -
Example 4 and 5 (BatchClosure and BatchClosureAgain): First examples that show how to create a graph that solves a real world problems usingAkka StreamsandAlpakka. -
TransactionLoader: Another real world problem example and its solution using this technology. -
Also, there are generators (TransactionGenerator and BatchClosureGenerator) for creating dummy data for the previous examples. Those are also pipeline examples you can check it out.
Start up containers:
docker-compose up
Run SBT and select the example you want to run :
sbt runTo generate transactions needed by Example4_BatchClosure and Example5_BatchClosureAgain run:
./batchClosureGenerator.shTo generate transactions needed by TransactionLoader use the following script.
./transactionLoaderGenerator.shIt generates the transaction.txt file.