Systems and methods for dynamic transaction migration in an event-driven, multi-silo architecture
View Patent ↗Systems and methods may include providing a first silo configured to operate a first set of event-driven processing stages, and a second silo configured to operate a second set of event-driven processing stages; arranging at least one shared transaction cache between the first set of processing stages and the second set of processing stages of the respective first and second silos, where each processing stage of the first and second sets of processing stages can obtain or receive one or more transactions from the at least one shared transaction cache for processing, and where when a distressed processing stage in the first silo fails to process a first transaction designated for the distressed processing stage in a predefined amount of time, a non-distressed processing stage in the second silo obtains or receives the first transaction from the at least one shared transaction cache to process the first transaction on behalf of the distressed processing stage.
1. A computer-implemented method, comprising:
providing a first silo comprising a first cluster of one or more first computers configured to operate a first set of event-driven processing stages;
providing a second silo comprising a second cluster of one or more second computers configured to operate a second set of event-driven processing stages, wherein the first and second sets of processing stages include substantially identical processing stages such that during normal operations of the first and second silos, transactions are allocated between the first and second silos;
arranging at least one shared transaction cache between the first set of processing stages and the second set of processing stages of the respective first and second silos, wherein the at least one transaction cache stores one or more transactions designated for processing by respective processing stages of the first set or the second set,
wherein each processing stage of the first and second sets of processing stages can obtain or receive one or more transactions from the at least one shared transaction cache for processing,
wherein when a distressed processing stage in the first silo fails to process a first transaction designated for the distressed processing stage in a predefined amount of time, a non-distressed processing stage in the second silo obtains or receives the first transaction from the at least one shared transaction cache to process the first transaction on behalf of the distressed processing stage.
2. The method of claim 1 , wherein the distressed processing stage and non-distressed processing stage have substantially identical processing logic.
3. The method of claim 1 , wherein the first processing silo and the second processing silo are physically located at a same data center.
4. The method of claim 1 , wherein a messaging service is utilized to deliver one or more transactions between the at least one shared transaction cache and each processing stage of the first and second sets of processing stages.
5. The method of claim 4 , wherein the messaging service provides an asynchronous communications channel for delivering one or more transactions between the at least one shared transaction cache and each processing stage of the first and second sets of processing stages.
6. The method of claim 1 , wherein the first and second silos are replicated silos having substantially identical functions, and are operative to process respective transactions in parallel during normal operations.
7. The method of claim 1 , wherein a result of the first transaction being processed by the non-distressed processing stage is provided to the at least one transaction cache as a second transaction request for processing by the second silo.
8. The method of claim 1 , wherein the non-distressed processing stage of the second set is a final processing stage of the second set, wherein the second transaction request is designated for delivery to an external service computer.
9. The method of claim 1 , wherein the first transaction is triggered based at least in part upon receipt of a healthcare transaction request from an external event source computer by a load balancer computer in communication with the first silo and the second silo.
10. The method of claim 1 , wherein the healthcare transaction request is at least one of: (i) an eligibility verification request, (ii) a preauthorization request, or (iii) a claim status request.
11. A system, comprising:
at least one memory for storing computer-executable instructions; and
at least one processor in communication with the at least one memory, wherein the at least one processor is configured to execute the computer-executable instructions to:
provide a first silo comprising a first cluster of one or more first computers configured to operate a first set of event-driven processing stages;
provide a second silo comprising a second cluster of one or more second computers configured to operate a second set of event-driven processing stages, wherein the first and second sets of processing stages include substantially identical processing stages such that during normal operations of the first and second silos, transactions are allocated between the first and second silos;
arrange at least one shared transaction cache between the first set of processing stages and the second set of processing stages of the respective first and second silos, wherein the at least one transaction cache stores one or more transactions designated for processing by respective processing stages of the first set or the second set,
wherein each processing stage of the first and second sets of processing stages can obtain or receive one or more transactions from the at least one shared transaction cache for processing,
wherein when a distressed processing stage in the first silo fails to process a first transaction designated for the distressed processing stage in a predefined amount of time, a non-distressed processing stage in the second silo obtains or receives the first transaction from the at least one shared transaction cache to process the first transaction on behalf of the distressed processing stage.
12. The system of claim 11 , wherein the distressed processing stage and non-distressed processing stage have substantially identical processing logic.
13. The system of claim 11 , wherein the first processing silo and the second processing silo are physically located at a same data center.
14. The system of claim 11 , wherein a messaging service is utilized to deliver one or more transactions between the at least one shared transaction cache and each processing stage of the first and second sets of processing stages.
15. The system of claim 14 , wherein the messaging service provides an asynchronous communications channel for delivering one or more transactions between the at least one shared transaction cache and each processing stage of the first and second sets of processing stages.
16. The system of claim 11 , wherein the first and second silos are replicated silos having substantially identical functions, and are operative to process respective transactions in parallel during normal operations.
17. The system of claim 11 , wherein a result of the first transaction being processed by the non-distressed processing stage is provided to the at least one transaction cache as a second transaction request for processing by the second silo.
18. The system of claim 11 , wherein the non-distressed processing stage of the second set is a final processing stage of the second set, wherein the second transaction request is designated for delivery to an external service computer.
19. The system of claim 11 , wherein the first transaction is triggered based at least in part upon receipt of a healthcare transaction request from an external event source computer by a load balancer computer in communication with the first silo and the second silo.
20. The system of claim 11 , wherein the healthcare transaction request is at least one of: (i) an eligibility verification request, (ii) a preauthorization request, or (iii) a claim status request.