Implementation of a web scale data fabric

摘要

Methods and systems for processing machine accelerated and augmented customer data using a Web-Scale Data Fabric (WSDF). According to embodiments, the data may be received as data transfer objects from a set of business operations client applications. The data transfer objects may be analyzed using complex event processing (CEP) and, based on the analyzing, rules specific to the business operations client application may be applied. The methods and systems may semantically classify text specific to the business operations client application. A federated database (FD) may archive the receive data transfer objects as well as analysis data specific to the business operations client application.

主权项

1. A method of stream processing machine accelerated and augmented customer data, the method comprising:
receiving, as data transfer objects, machine accelerated and augmented customer data from one or more business operations client applications via an external computer network, wherein the data transfer objects are (1) received by a message broker component and (2) implemented as an advanced message queuing protocol (AMQP) message with a data transfer object as a payload; analyzing, by a processor, the received data transfer objects using complex event processing (CEP) configured to inspect at least one attribute of the received data transfer objects for a given window of time; based on the analyzing, detecting at least one event and applying at least one rule that is specific to business operations client application processing; semantically classifying text in the received data transfer objects that is specific to the business operations client application processing; archiving the received data transfer objects in a federated database (FD); and routing analysis data that is specific to the business operations client application processing to the FD for archiving.