CPC H04L 51/046 (2013.01) [G06F 40/40 (2020.01)] | 18 Claims |
10. A system comprising:
a data store as a computer memory configured to receive streams of data via a network into an application computing platform, the streams of data including publisher or subscriber-based electronic messages; and
a processor configured to execute instructions to implement an application configured to:
activate multiple application program interfaces (“APIs”) to receive data via a message throughput data pipe different data streams associated with multiple data sources each associated with a processor and memory;
extract features from one or more portions of data using the APIs;
identify data representing event-related data across the multiple data sources;
correlate the event-related data to form data representing an event;
classify the data representing the event into one or more state classifications;
execute instructions to apply data defining compatibility of data to determine compatible data at the multiple data sources;
identify compatible data to integrate with a subset of the multiple data sources;
transmit the subset of integration data to integrate with at least one of the subset of the multiple data sources;
detect a value representing the event over time to determine an amount of diffusivity of the event among the multiple data sources; and
determine another event.
|