Techniques to provide streaming data resiliency utilizing a distributed message queue system

    公开(公告)号:US11509619B2

    公开(公告)日:2022-11-22

    申请号:US16881469

    申请日:2020-05-22

    Abstract: Embodiments include techniques to receive and process data from a data service provider, communicate a plurality of messages comprising the data to a streaming data platform and detect a failure of delivery of the plurality of messages to the streaming data platform. Embodiments further include techniques communicate the plurality of messages to a distributed message queue service of a distributed message queue system, publish each of the plurality of messages to the streaming data platform, determine each of the plurality of messages published to the streaming data platform was successful or unsuccessful, and retry publication of each unsuccessfully published message of plurality of messages to the streaming data platform.

    Techniques to provide streaming data resiliency utilizing a distributed message queue system

    公开(公告)号:US12074840B2

    公开(公告)日:2024-08-27

    申请号:US17967060

    申请日:2022-10-17

    CPC classification number: H04L51/23 G06F9/546 H04L63/08

    Abstract: Embodiments include techniques to receive and process data from a data service provider, communicate a plurality of messages comprising the data to a streaming data platform and detect a failure of delivery of the plurality of messages to the streaming data platform. Embodiments further include techniques communicate the plurality of messages to a distributed message queue service of a distributed message queue system, publish each of the plurality of messages to the streaming data platform, determine each of the plurality of messages published to the streaming data platform was successful or unsuccessful, and retry publication of each unsuccessfully published message of plurality of messages to the streaming data platform.

    Replica reliability
    3.
    发明授权

    公开(公告)号:US12033085B2

    公开(公告)日:2024-07-09

    申请号:US17539691

    申请日:2021-12-01

    CPC classification number: G06N5/02 G06Q20/202

    Abstract: A system for processing and verifying real-time calculations in a cloud computing environment is disclosed. In embodiments, the system performs implements methods to receive, at a first data center, a request from a point of sale (POS) system to perform a real-time calculation, where the real-time calculation is used to make automated decisions about a transaction. The system can transmit the request to a decision handler. The decision handler can determine which of a plurality of decision engine queues to further transmit the request to. The decision handler can transmit the request to a decision engine queue from the plurality of decision engine queues. The decision engine queue can scatter the request to at least two decision engines. The decision engine queue can receive a result of the real-time calculation and transmit the results through other components to the POS system.

Patent Agency Ranking