A system for data aggregation and distribution comprises a context builder that receives a data request from a consumer, and a producers locator that communicates with producers. A producers filter receives a list of producers and selects producers capable of providing data relevant to context information. A data requests formatter receives the context information, and sends the data request to the selected producers. A data responses validator validates data responses from producers, and a data responses processor processes validated data responses. A data predictor receives processed data responses and context information, and generates data prediction information. A data fusion module receives processed data responses, context information, data prediction information, and data history. The data fusion module combines processed data responses with data prediction information to generate a consolidated data response for the consumer. The data fusion module also considers data prediction information upon receiving a request for predicted data when real-time data is unavailable.