Data storage system having a unified container layer for an active data store
First Claim
1. A data storage system, comprising:
- an active data store comprising stored data;
a rules engine adapted to apply at least one rule to modify data of the stored data in the active data store,a unified container layer adapted to transmit and receive data using a data communication mechanism and further adapted to publish a message to a broker located external to the data storage system by transmitting the message across the data communications mechanism to the broker,said message being derived from the data of the stored data in the active data store that had been modified by the rules engine,said message being received from the active data store by the unified container layer,said unified container layer adapted to validate both externally-generated data and data of the active data store generated by the rules engine,a first list of subscribers being stored in a data store of the broker,each subscriber listed on the first list of subscribers subscribing to a topic associated with the message and adapted to receive the message published from the broker,said unified container layer being listed on the first list of subscribers,said unified container layer adapted to receive the message published from the broker due to the unified container layer being listed on the first list of subscribers,said unified container layer adapted to process the published message received from the broker and to transmit the processed published message to the active data store;
said unified container layer comprising a sender and a receiver such that the sender and the receiver are adapted to communicate using the data communication mechanism;
said unified container layer further comprising a validator and a filter, wherein the unified container layer is adapted to process the published message received from the broker by having the published message validated by the validator and by having the validated published message filtered by the filter;
said data communication mechanism further adapted to receive data from application inputs and user inputs such that no direct access to the active data store is permitted for said inputs;
said data communication mechanism comprising a publish and subscribe data communication mechanism;
said data communication mechanism adapted to participate in data communication with said broker, using said publish and subscribe mechanism, in which said broker acts as a bus by;
(1) receiving published messages by means of transmissions across said data communication mechanism, and (2) making said published messages available to subscribers by transmission of said published messages across said data communication mechanism, wherein said subscribers comprise an application or system that has registered as a first subscriber with said broker, wherein said first subscriber is on said first list of subscribers;
said broker adapted to examine subscription data in its data store and determine that said data storage system has subscribed to the topic associated with the message, as has a second data storage system;
said broker adapted to transmit the message to said subscribers, including to said data storage system, to said second data storage system, and to other subscribers, said other subscribers including applications and databases.
1 Assignment
0 Petitions
Accused Products
Abstract
The present invention provides a data storage system, method and computer program product having an active data store and a data communication mechanism comprising a unified container layer for validating both externally-generated data and data generated within the active data store, wherein the unified container layer transmits and receives data using the data communication mechanism. In a preferred embodiment, the active data store is an entity-relationship-attribute data store which comprises a relational database. The unified container layer may validate data using a syntax checker and a semantics checker, which may comprise a rules engine. Preferably, the data communication mechanism is one of a publish/subscribe system, a synchronous communication system, and an asynchronous communication system.
-
Citations
15 Claims
-
1. A data storage system, comprising:
-
an active data store comprising stored data; a rules engine adapted to apply at least one rule to modify data of the stored data in the active data store, a unified container layer adapted to transmit and receive data using a data communication mechanism and further adapted to publish a message to a broker located external to the data storage system by transmitting the message across the data communications mechanism to the broker, said message being derived from the data of the stored data in the active data store that had been modified by the rules engine, said message being received from the active data store by the unified container layer, said unified container layer adapted to validate both externally-generated data and data of the active data store generated by the rules engine, a first list of subscribers being stored in a data store of the broker, each subscriber listed on the first list of subscribers subscribing to a topic associated with the message and adapted to receive the message published from the broker, said unified container layer being listed on the first list of subscribers, said unified container layer adapted to receive the message published from the broker due to the unified container layer being listed on the first list of subscribers, said unified container layer adapted to process the published message received from the broker and to transmit the processed published message to the active data store; said unified container layer comprising a sender and a receiver such that the sender and the receiver are adapted to communicate using the data communication mechanism; said unified container layer further comprising a validator and a filter, wherein the unified container layer is adapted to process the published message received from the broker by having the published message validated by the validator and by having the validated published message filtered by the filter; said data communication mechanism further adapted to receive data from application inputs and user inputs such that no direct access to the active data store is permitted for said inputs; said data communication mechanism comprising a publish and subscribe data communication mechanism; said data communication mechanism adapted to participate in data communication with said broker, using said publish and subscribe mechanism, in which said broker acts as a bus by;
(1) receiving published messages by means of transmissions across said data communication mechanism, and (2) making said published messages available to subscribers by transmission of said published messages across said data communication mechanism, wherein said subscribers comprise an application or system that has registered as a first subscriber with said broker, wherein said first subscriber is on said first list of subscribers;said broker adapted to examine subscription data in its data store and determine that said data storage system has subscribed to the topic associated with the message, as has a second data storage system; said broker adapted to transmit the message to said subscribers, including to said data storage system, to said second data storage system, and to other subscribers, said other subscribers including applications and databases. - View Dependent Claims (2, 3, 4, 5)
-
-
6. A method for operating a data storage system that includes a unified container layer, an active data store comprising stored data, and a rules engine, said method comprising:
-
applying by the rules engine at least one rule to modify data of the stored data in the active data store; receiving, by the unified container layer from the active data store, a message derived from the data of the stored data in the active data store that had been modified by the rules engine, said unified container layer adapted to transmit and receive data using a data communication mechanism; publishing, by the unified container layer, the message to a broker located external to the data storage system by transmitting the message across the data communications mechanism to the broker, wherein a first list of subscribers is stored in a data store of the broker, each subscriber listed on the first list of subscribers subscribing to a topic associated with the message and adapted to receive the message published from the broker, said unified container layer being listed on the first list of subscribers, said unified container layer adapted to validate both externally-generated data and data of the active data store generated by the rules engine; receiving, by the unified container layer, the message published from the broker due to the unified container layer being listed on the first list of subscribers; and processing, by the unified container layer, the published message received from the broker and transmitting the processed published message to the active data store; said unified container layer comprising a sender and a receiver such that the sender and the receiver are adapted to communicate using the data communication mechanism; said unified container layer further comprising a validator and a filter, wherein the unified container layer is adapted to process the published message received from the broker by having the published message validated by the validator and by having the validated published message filtered by the filter; said data communication mechanism further adapted to receive data from application inputs and user inputs such that no direct access to the active data store is permitted for said inputs; said data communication mechanism comprising a publish and subscribe data communication mechanism; said data communication mechanism adapted to participate in data communication with said broker, using said publish and subscribe mechanism, in which said broker acts as a bus by;
(1) receiving published messages by means of transmissions across said data communication mechanism, and (2) making said published messages available to subscribers by transmission of said published messages across said data communication mechanism, wherein said subscribers comprise an application or system that has registered as a first subscriber with said broker, wherein said first subscriber is on said first list of subscribers;said broker adapted to examine subscription data in its data store and determine that said data storage system has subscribed to the topic associated with the message, as has a second data storage system; said broker adapted to transmit the message to said subscribers, including to said data storage system, to said second data storage system, and to other subscribers, said other subscribers including applications and databases. - View Dependent Claims (7, 8, 9, 10)
-
-
11. A computer program product, comprising computer program instructions tangibly embodied in a computer-readable medium, said instructions when loaded into a computer system and executed cause said computer system to operate a data storage system by performing a method, said data storage system including a unified container layer, an active data store comprising stored data, and a rules engine, said method comprising:
-
applying by the rules engine at least one rule to modify data of the stored data in the active data store; receiving, by the unified container layer from the active data store, a message derived from the data of the stored data in the active data store that had been modified by the rules engine, said unified container layer adapted to transmit and receive data using a data communication mechanism; publishing, by the unified container layer, the message to a broker located external to the data storage system by transmitting the message across the data communications mechanism to the broker, wherein a first list of subscribers is stored in a data store of the broker, each subscriber listed on the first list of subscribers subscribing to a topic associated with the message and adapted to receive the message published from the broker, said unified container layer being listed on the first list of subscribers, said unified container layer adapted to validate both externally-generated data and data of the active data store generated by the rules engine; receiving, by the unified container layer, the message published from the broker due to the unified container layer being listed on the first list of subscribers; and processing, by the unified container layer, the published message received from the broker and transmitting the processed published message to the active data store; said unified container layer comprising a sender and a receiver such that the sender and the receiver are adapted to communicate using the data communication mechanism; said unified container layer further comprising a validator and a filter, wherein the unified container layer is adapted to process the published message received from the broker by having the published message validated by the validator and by having the validated published message filtered by the filter; said data communication mechanism further adapted to receive data from application inputs and user inputs such that no direct access to the active data store is permitted for said inputs; said data communication mechanism comprising a publish and subscribe data communication mechanism; said data communication mechanism adapted to participate in data communication with said broker, using said publish and subscribe mechanism, in which said broker acts as a bus by;
(1) receiving published messages by means of transmissions across said data communication mechanism, and (2) making said published messages available to subscribers by transmission of said published messages across said data communication mechanism, wherein said subscribers comprise an application or system that has registered as a first subscriber with said broker, wherein said first subscriber is on said first list of subscribers;said broker adapted to examine subscription data in its data store and determine that said data storage system has subscribed to the topic associated with the message, as has a second data storage system; said broker adapted to transmit the message to said subscribers, including to said data storage system, to said second data storage system, and to other subscribers, said other subscribers including applications and databases. - View Dependent Claims (12, 13, 14, 15)
-
Specification