Machine to machine data aggregator
First Claim
Patent Images
1. A method comprising:
- generating, by a computer device, a plurality of schemas, wherein particular ones of the plurality of schemas convert data items of particular data types into a common data format;
associating, by the computer device, particular ones of the plurality of schemas with particular ones of a plurality of aggregation sockets, wherein different ones of the plurality of aggregation sockets are configured to ingest data items of different data types;
ingesting, by the computer device, a data item from a data source via an aggregation socket, of the plurality of aggregation sockets, wherein the aggregation socket is configured to ingest data items of a particular data type;
identifying, by the computer device, a schema, of the plurality of schemas, associated with the aggregation socket;
converting, by the computer device, the data item into a common data format using the identified schema;
storing, by the computer device, the converted data item in a common data format storage associated with the computer device;
providing, by the computer device, the stored data item to a data utilization system;
sending, by the computer device, an indication to a provenance engine that the data item has been stored in the common data format storage;
generating, by the provenance engine, a provenance record for the stored data item, in response to receiving the indication that the data item has been stored in the common data format storage, wherein the provenance record stores information identifying each event that includes accessing or modifying the stored data item, and wherein the provenance record is stored separately from the common data format storage;
detecting an event that includes accessing or modifying the stored data item;
sending, to the provenance engine, an alert that the stored data items has been accessed or modified, in response to detecting the event;
generating, by the provenance engine, a provenance event record in the generated provenance record in response to the detected event;
storing, by the provenance engine, one or more provenance parameters associated with the detected event in the generated provenance record;
determining a reputation score associated with the data source;
assigning the determined reputation score to the stored data item;
determining that a particular entity, associated with a particular reputation score, has requested to access or modify the stored data item; and
modifying the reputation score associated with the data source based on the particular reputation score associated with the particular entity.
1 Assignment
0 Petitions
Accused Products
Abstract
A computer system may include data aggregator logic configured to ingest a data item from a data source via an aggregation socket, wherein the aggregation socket is configured to ingest data items of a particular data type; identify a schema associated with the aggregation socket; convert the data item into a common data format using the identified schema; store the converted data item in a common data format storage associated with the computer device; and provide the stored data item to a data utilization system. The computer system may further maintain and record provenance and reputation models associated with data items stored in the common data format storage.
46 Citations
20 Claims
-
1. A method comprising:
-
generating, by a computer device, a plurality of schemas, wherein particular ones of the plurality of schemas convert data items of particular data types into a common data format; associating, by the computer device, particular ones of the plurality of schemas with particular ones of a plurality of aggregation sockets, wherein different ones of the plurality of aggregation sockets are configured to ingest data items of different data types; ingesting, by the computer device, a data item from a data source via an aggregation socket, of the plurality of aggregation sockets, wherein the aggregation socket is configured to ingest data items of a particular data type; identifying, by the computer device, a schema, of the plurality of schemas, associated with the aggregation socket; converting, by the computer device, the data item into a common data format using the identified schema; storing, by the computer device, the converted data item in a common data format storage associated with the computer device; providing, by the computer device, the stored data item to a data utilization system; sending, by the computer device, an indication to a provenance engine that the data item has been stored in the common data format storage; generating, by the provenance engine, a provenance record for the stored data item, in response to receiving the indication that the data item has been stored in the common data format storage, wherein the provenance record stores information identifying each event that includes accessing or modifying the stored data item, and wherein the provenance record is stored separately from the common data format storage; detecting an event that includes accessing or modifying the stored data item; sending, to the provenance engine, an alert that the stored data items has been accessed or modified, in response to detecting the event; generating, by the provenance engine, a provenance event record in the generated provenance record in response to the detected event; storing, by the provenance engine, one or more provenance parameters associated with the detected event in the generated provenance record; determining a reputation score associated with the data source; assigning the determined reputation score to the stored data item; determining that a particular entity, associated with a particular reputation score, has requested to access or modify the stored data item; and modifying the reputation score associated with the data source based on the particular reputation score associated with the particular entity. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A computer system comprising:
-
one or more memory devices storing instructions; and one or more processors configured to execute the instructions to; generate a plurality of schemas, wherein particular ones of the plurality of schemas convert data items of particular data types into a common data format; associate particular ones of the plurality of schemas with particular ones of a plurality of aggregation sockets, wherein different ones of the plurality of aggregation sockets are configured to ingest data items of different data types; ingest a data item from a data source via an aggregation socket, of the plurality of aggregation sockets, wherein the aggregation socket is configured to ingest data items of a particular data type; identify a schema, of the plurality of schemas, associated with the aggregation socket; convert the data item into a common data format using the identified schema; store the converted data item in a common data format storage associated with the computer system; provide the stored data item to a data utilization system; send an indication to a provenance engine that the data item has been stored in the common data format storage; generate a provenance record for the stored data item, in response to receiving the indication that the data item has been stored in the common data format storage, wherein the provenance record stores information identifying each event that includes accessing or modifying the stored data item, and wherein the provenance record is stored separately from the common data format storage; detect an event that includes accessing or modifying the stored data item based on receiving an alert that the stored data item has been accessed or modified; generate a provenance event record in the generated provenance record in response to the detected event; store one or more provenance parameters associated with the detected event in the generated provenance record; determine a reputation score associated with the data source; assign the determined reputation score to the stored data item; determine that a particular entity, associated with a particular reputation score, has requested to access or modify the stored data item; and modify the reputation score associated with the data source based on the particular reputation score associated with the particular entity. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
-
15. One or more non-transitory computer-readable memory devices storing instructions executable by one or more processors, the one or more non-transitory computer-readable memory devices comprising:
-
one or more instructions to generate a plurality of schemas, wherein particular ones of the plurality of schemas convert data items of particular data types into a common data format; one or more instructions to associate particular ones of the plurality of schemas with particular ones of a plurality of aggregation sockets, wherein different ones of the plurality of aggregation sockets are configured to ingest data items of different data types; one or more instructions to ingest a data item from a data source via an aggregation socket, of the plurality of aggregation sockets, wherein the aggregation socket is configured to ingest data items of a particular data type; one or more instructions to identify a schema, of the plurality of schemas, associated with the aggregation socket; one or more instructions to convert the data item into a common data format using the identified schema; one or more instructions to store the converted data item in a common data format storage; one or more instructions to provide the stored data item to a data utilization system; one or more instructions to send an indication to a provenance engine that the data item has been stored in the common data format storage; one or more instructions to generate, by the provenance engine, a provenance record for the stored data item, in response to receiving the indication that the data item has been stored in the common data format storage, wherein the provenance record stores information identifying each event that includes accessing or modifying the stored data item, and wherein the provenance record is stored separately from the common data format storage; one or more instructions to detect an event that includes accessing or modifying the stored data item; one or more instructions to send, to the provenance engine, an alert that the stored data items has been accessed or modified, in response to detecting the event that includes accessing or modifying the stored data item; one or more instructions to generate, by the provenance engine, a provenance event record in the generated provenance record in response to the detected event; one or more instructions to store, by the provenance engine, one or more provenance parameters associated with the detected event in the generated provenance record; one or more instructions to determine a reputation score associated with the data source; one or more instructions to assign the determined reputation score to the stored data item; one or more instructions to determine that a particular entity, associated with a particular reputation score, has requested to access or modify the stored data item; and one or more instructions to modify the reputation score associated with the data source based on the particular reputation score associated with the particular entity. - View Dependent Claims (16, 17, 18, 19, 20)
-
Specification