Method and system for determining active events in a 5G network

A system, comprising:

• one or more processors;
• and
• a non-transitory computer-readable medium comprising instructions that, when executed by the one or more processors, cause the system to perform operations to:
• receive a first event notification comprising a key, the first event notification received via a first stream of a streaming event platform;
• generate a record of the first event notification in a database, the record of the first event notification comprising a correlation identifier (ID) and the key;
• generate an event based on the first event notification in a second stream of the streaming event platform, the event indicating an alarm notification;
• receive a second event notification comprising the key, the second event notification received via the first stream of the streaming event platform;
• generate a record of the second event notification in the database, the record of the second event notification comprising the correlation ID and the key;
• determine that the second event notification is related to the first event notification based at least in part on the correlation ID and the key;
• and
• generate an event indicating an update notification based on the second event notification in the second stream of the streaming event platform;
• and
• update, by the computing system, the second stream to remove the event indicating the alarm notification and the event indicating the update notification such that the second stream is an active-only stream while maintaining a historical record of the events in the first stream, wherein the removal is triggered by a third event notification indicating that the alarm notification has been resolved.

A non-transitory computer-readable medium comprising instructions that, when executed by one or more processors, cause the one or more processors to perform operations comprising:

• receiving, by a computing system, a first event notification comprising a key, the first event notification received via a first stream of a streaming event platform;
• generating, by the computing system, a record of the first event notification in a database, the record of the first event notification comprising a correlation identifier (ID) and the key;
• generating, by the computing system, an event based on the first event notification in a second stream of the streaming event platform, the event indicating an alarm notification;
• receiving, by the computing system, a second event notification comprising the key, the second event notification received via the first stream of the streaming event platform;
• generating, by the computing system, a record of the second event notification in the database, the record of the second event notification comprising a correlation ID and the key;
• determining, by the computing system, that the second event notification is related to the first event notification based at least in part on the correlation ID and the key;
• generating, by the computing system, an event indicating an update notification based on the second event notification in the second stream of the streaming event platform;
• and
• updating, by the computing system, the second stream to remove the event indicating the alarm notification and the event indicating the update notification such that the second stream is an active-only stream while maintaining a historical record of the events in the first stream, wherein the removal is triggered by a third event notification indicating that the alarm notification has been resolved.