| CPC G06F 11/0787 (2013.01) [G06F 11/0721 (2013.01)] | 18 Claims |
|
1. A system comprising:
a non-transitory memory; and
one or more hardware processors coupled to the non-transitory memory and configured to read instructions from the non-transitory memory to cause the system to perform operations comprising:
detecting, by an event failure tracker of an event processing application, a failure by event processing application to process an event in a first processing queue, wherein the event is associated with an event message having an event identifier (ID) and an event payload, wherein the event payload includes transmitted data processable for use by a downstream computing service, wherein the event failure tracker comprises a software daemon executable with a new event handler for a data streamer of the event processing application, and wherein the new event handler manages processing of the event in the first processing queue and a retry event handler manages processing of the event in a second processing queue;
based on the failure, storing, by the event failure tracker, the event ID in a failed event data storage structure of a key-value database;
increasing, by the event failure tracker, a counter based on the failure to process the event;
republishing, for the event by the event failure tracker, at least the event ID and the event payload in the second processing queue for processing of the event;
monitoring, by the event failure tracker, for a successful completion of processing the event from the second processing queue using the event ID from the failed event data storage structure; and
determining, by the event failure tracker, whether to update the counter in the failed event data storage structure based on the monitoring.
|