Ingestion and segmentation of real-time event data

A computing device, comprising:

• one or more non-transitory memories;
• and
• one or more processors in communication with the one or more non-transitory memories and configured to execute instructions stored in the one or more non-transitory memories to:
• receive, by an ingestion engine, event data comprising a stream of received event instances, wherein each received event instance is associated with an entity of a plurality of entities and a capacity change;
• generate, by a management engine, segmented sets of instances from the stream of received event instances by operations to:
• identify, by the ingestion engine, an event time for each received event instance of the stream of received event instances;
• sort, by the management engine, the received event instances into a plurality of sets of instances, wherein each set of instances of the plurality of sets of instances is associated with a respective entity of the plurality of entities;
• and
• segment, by the management engine, each set of instances of the plurality of sets of instances into a plurality of subsets of instances based on the event time for each event instance of the set of instances, wherein each of the plurality of subsets of instances corresponds to a corresponding time period;
• identify, by the management engine, a net capacity change for a subset of instances of the subsets of instances, the net capacity change being based at least in part on a capacity change of each received event instance in the subset of instances;
• compare, by a modeling engine, the net capacity change for the subset of instances to a capacity threshold;
• and
• provide, by an interface engine, a notification in response to the respective net capacity change exceeding the capacity threshold.

A non-transitory computer-readable medium storing a plurality of instructions that, when executed by one or more processors of a computing device, cause the one or more processors to:

• receive, by an ingestion engine, event data comprising a stream of received event instances, wherein each received event instance is associated with an entity of a plurality of entities and a capacity change;
• generate, by a management engine, segmented sets of instances from the stream of received event instances by operations to:
• identify, by the ingestion engine, an event time for each received event instance of the stream of received event instances;
• sort, by the management engine, the received event instances into a plurality of sets of instances, wherein each set of instances of the plurality of sets of instances is associated with a respective entity of the plurality of entities;
• and
• segment, by the management engine, each set of instances of the plurality of sets of instances into a plurality of subsets of instances based on the event time for each event instance of the set of instances, wherein each of the plurality of subsets of instances corresponds to a corresponding time period;
• identify, by the management engine, a net capacity change for a subset of instances of the subsets of instances, the net capacity change being based at least in part on a capacity change of each received event instance in the subset of instances;
• compare, by a modeling engine, the net capacity change for the subset of instances to a capacity threshold;
• and
• provide, by an interface engine, a notification in response to the respective net capacity change exceeding the capacity threshold.