System and method
AssigneeCanon Kabushiki Kaisha
InventorTetsu Imai
Life of this patent
Estimating the term…
Abstract
If processing of a first event in response to a stream event is not normally ended due to an occurrence of an exception or a timeout, the processing is executed repeatedly during a predetermined period of time from an occurrence of the first event. Then, after the predetermined period of time passes, an error notification is issued while processing of a second event that has occurred during the predetermined period of time is executed only once.
Claims8
A system configured to manage, for a first time length, a plurality of events issued in response to a plurality of changes made to a database and execute a code corresponding to each of the plurality of changes in response to the plurality of events to process the plurality of events in chronological order, the system comprising:
- one or more processors;
- and
- at least one memory storing instructions, which when executed by the one or more processors, cause the system to:
- perform control to retry event processing on a processing target event if first event processing that is started as the event processing in a case in which a difference between a current time point and a time point at which the processing target event occurs is not greater than a second time length is not normally ended, the second time length being shorter than the first time length;
- and
- execute processing for failure notification of the event processing on the processing target event if second event processing that is started as the event processing in a case in which the difference between the current time point and the time point at which the processing target event occurs is greater than the second time length is not normally ended.
A system configured to manage, for a first time length, a plurality of events issued in response to a plurality of changes made to a database and execute a code corresponding to each of the plurality of changes in response to the plurality of events to process the plurality of events, the system comprising:
- one or more processors;
- and
- at least one memory storing instructions, which when executed by the one or more processors, cause the system to:
- notify a first messaging service of the issued event in response to the issued event;
- and
- control event processing on the issued event in response to an event notification from the first messaging service,
- wherein in a case where the event processing is ended due to an occurrence of an exception or a timeout, a retry of the event processing is executed, and
- wherein in a case where the event processing is ended due to an occurrence of an exception or a timeout and a number of retries is greater than a predetermined number, processing for failure notification of the event processing on the issued event is executed.
A system configured to manage, for a first time length, a plurality of events issued in response to a plurality of changes made to a database and execute a code corresponding to each of the plurality of changes in response to the plurality of events to process the plurality of events, the system comprising:
- a first system configured to perform control to retry event processing on a processing target event that is one of the issued events if first event processing that is started as the event processing in a case in which a difference between a current time point and a time point at which the processing target event occurs is not greater than a second time length is not normally ended, the second time length being shorter than the first time length, and configured to execute processing for failure notification of the event processing on the processing target event if second event processing that is started as the event processing in a case in which the difference between the current time point and the time point at which the processing target event occurs is greater than the second time length is not normally ended;
- and
- a second system configured to control third event processing on a processing target event that is another one of the issued events in response to a notification about the processing target event via a first messaging service,
- wherein in a case where the third event processing is ended due to an occurrence of an exception or a timeout, the second system retries the third event processing, and
- wherein in a case where the third event processing is ended due to an occurrence of an exception or a timeout and a number of retries is greater than a predetermined number, the second system executes processing for failure notification of the event processing.
A method in a system configured to manage, for a first time length, a plurality of events issued in response to a plurality of changes made to a database and execute a code corresponding to each of the plurality of changes in response to the plurality of events to process the plurality of events in chronological order, the method comprising:
- performing control to retry event processing on a processing target event if first event processing that is started as the event processing in a case in which a difference between a current time point and a time point at which the processing target event occurs is not greater than a second time length is not normally ended, the second time length being shorter than the first time length;
- and
- executing processing for failure notification of the event processing on the processing target event if second event processing that is started as the event processing in a case in which the difference between the current time point and the time point at which the processing target event occurs is greater than the second time length is not normally ended.
A method in a system configured to manage, for a first time length, a plurality of events issued in response to a plurality of changes made to a database and execute a code corresponding to each of the plurality of changes in response to the plurality of events to process the plurality of events, the method comprising:
- notifying a first messaging service of the issued event in response to the issued event;
- and
- controlling event processing on the issued event in response to an event notification from the first messaging service,
- wherein in a case where the event processing is ended due to an occurrence of an exception or a timeout, a retry of the event processing is executed, and
- wherein in a case where the event processing is ended due to an occurrence of an exception or a timeout and a number of retries is greater than a predetermined number, processing for failure notification of the event processing on the issued event is executed.
Dependencies are inferred from the claim text.