В статье Обновление рыночных данных в реальном времени с помощью Elixir мы увидели, как создать клиент Coinbase WebSocket и получать сделки в реальном времени. В комментариях к статье читатель спросил, сколько сделок мы получаем в секунду. В целом скорость торгов зависит от товара и времени суток. В этой статье мы начинаем видеть, как агрегировать эти сделки в режиме реального времени, используя поведение GenServer. Мы создадим процесс агрегации, который группирует и подсчитывает..