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

1 . A method, 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 the 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.

2 . The method of claim 1 , wherein updating the second stream of the streaming event platform further comprises:

receiving, by the computing system, a third event notification comprising the key, the third event notification received via the first stream of the streaming event platform; and

updating, by the computing system, the second stream of the streaming event platform to remove the event indicating the alarm notification and the event indicating the update notification, based at least in part on the third event notification and/or a time-based trigger.

3 . The method of claim 2 , wherein the third event notification indicates that an active alarm associated with the alarm notification has been resolved.

4 . The method of claim 1 , wherein the first event notification comprises an active alarm corresponding to a network component.

5 . The method of claim 4 , wherein the network component is a component of an open radio access network of a 5G wireless network provider.

6 . The method of claim 1 , wherein the first stream of the streaming event platform comprises events associated with an entity associated with a network component.

7 . The method of claim 1 , wherein the second stream of the streaming event platform comprises active alarm notifications associated with one or more entities associated with respective network components.

8 . The method of claim 1 , further comprising:

transmitting, by the computing system and to a user device, data associated with at least one of the first event notification and the second event notification, the data comprising instructions directing the user device to display a most-recent event notification.

9 . 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.

10 . The system of claim 9 , wherein the first event notification comprises an active alarm corresponding to a network component.

11 . The system of claim 10 , wherein a third event notification indicates that the active alarm corresponding to the network component has been cleared.

12 . The system of claim 10 , wherein the network component is a component of an open radio access network of a 5G wireless network provider.

13 . The system of claim 9 , wherein the first stream of the streaming event platform comprises event notifications associated with an entity associated with a network component.

14 . The system of claim 9 , wherein the second stream of the streaming event platform comprises active alarm notifications associated with one or more entities associated with respective network components.

15 . The system of claim 9 , wherein the system further performs operations to:

transmit, to a user device, data associated with at least one of the first event notification and the second event notification, the data used by the user device to display a most-recent event notification.

16 . 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.

17 . The non-transitory computer-readable medium of claim 16 , wherein updating the second stream of the streaming event platform further comprises:

receiving, by the computing system, a third event notification comprising the key, the third event notification received via the first stream of the streaming event platform; and

updating, by the computing system, the second stream of the streaming event platform to remove the event indicating the alarm notification and the event indicating the update notification, based at least in part on the third event notification and/or a time-based trigger.

18 . The non-transitory computer-readable medium of claim 17 , wherein the third event notification indicates that an active alarm associated with the alarm notification has been resolved.

19 . The non-transitory computer-readable medium of claim 16 , wherein the first event notification comprises an active alarm corresponding to a network component.

20 . The non-transitory computer-readable medium of claim 19 , wherein the network component is a component of an open radio access network of a 5G wireless network provider.