You can find one example of doing aggregation/near real time processing in this CodeCombat case study.
Depending on the complexity of what you want to do there’s various different ways to solve this problem in terms of reading and processing data off the Kinesis stream.