Near real-time Campaign Reporting Part 2 — Aggregation/Reduction

This series of articles discusses a simplified example of near real-time Ad Campaign reporting using Kafka, Aerospike's edge-to-core data pipeline technology, and Apollo GraphQL. Part 1 covered the real-time capture of Ad events via an Aerospike edge datastore and Kafka messaging. In this second part, aggregation and reduction of Ad events are leveraged using Aerospike Complex Data Types (CDTs) to create actionable Ad Campaign Key Performance Indicators (KPIs). The values are stored in a data cube implemented as a Document or CDT in Aerospike. Part 3 will describe how an Ad Campaign user interface displays those KPIs using GraphQL and retrieves data stored in an Aerospike Cluster.