How to Aggregate Asynchronous Messagges from a Queue into a Final Result at Scale?

I’m working on a system where:

How to Aggregate Asynchronous Messagges from a Queue into a Final Result at Scale?

I’m working on a system where: