Concurrent Data Processing in Elxir by The Pragmatic Programmer-01.png

myDokcer.tar.gz

ch1_1

ch_3

ch_3.1

ch1_1-task supervisor

ch_4.1

ch_5.1 RabbitMQ

Ch_5.2 RabbitMQ

Most engineers don’t think that concurrency is distinct from programming. Data processing includes transforming information in some way, like reporting, data aggregation, or analytics. On the other hand, concurrency involves significantly improving performance.

This course is designed to help you navigate the world of concurrency tools available in the Elixir ecosystem. You’ll explore popular modules and libraries like GenServer, GenStage, Flow, and Broadway. You’ll be able to ingest data, set up pipelines, and run concurrent processes with Elixir.

By the end of the course, you’ll have a wide range of new techniques to simplify your product, improve code performance, and make your application more resilient to increased workloads.

Concurrent Data Processing in Elixir

## GenStage producers

The `Broadway` library is an excellent choice when working with popular message brokers. However, it's not limited to just that. `Broadway` could be useful in a wide range of use cases where we need a data-processing pipeline with built-in dynamic batching. We only have to bring our own `GenStage` producer and `Broadway` will happily do the work for us. We'll see how this works by revisiting the `scraper` project one last time. We already used `GenStage` and `Flow` to implement it, so it will be great to implement another version using `Broadway`, for comparison.

## Replace `:flow` with `:broadway`

Let's start by replacing `:flow` with `:broadway` in the dependencies' list:


# GenStage producers

The `Broadway` library is an excellent choice when working with popular message brokers. However, it's not limited to just that. `Broadway` could be useful in a wide range of use cases where we need a data-processing pipeline with built-in dynamic batching. We only have to bring our own `GenStage` producer and `Broadway` will happily do the work for us. We'll see how this works by revisiting the `scraper` project one last time. We already used `GenStage` and `Flow` to implement it, so it will be great to implement another version using `Broadway`, for comparison.

# Replace `:flow` with `:broadway`

Let's start by replacing `:flow` with `:broadway` in the dependencies' list:


Learn to use GenStage for processing data pipelines with dynamic batching.

Getting Started

Easy Concurrency with the Task Module

Long-Running Processes Using GenServer

Data Processing Pipelines with GenStage

Process Collections with Flow

Data Ingestion Pipelines with Broadway

Concluding the Course

Use GenStage Producers

GenStage producers

Replace `:flow` with `:broadway`