Scenario driven data modelling: a method for integrating diverse sources of data and data streams

• US 9,129,039 B2
• Filed: 10/17/2012
• Issued: 09/08/2015
• Est. Priority Date: 10/18/2011
• Status: Active Grant

• Current Assignee: UT-Battelle LLC
• Original Assignee: UT-Battelle LLC
• Inventors: Brettin, Thomas S., Cottingham, Robert W., Griffith, Shelton D., Quest, Daniel J.
• Primary Examiner(s): Reyes, Mariela
• Assistant Examiner(s): Jacobs, Edward
• Application Number:
  US13/654,152
• Publication Number:
  US 20130124574A1
• Time in Patent Office: 1,056 Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/9024 Graphs; Linked lists G06F16/9027 takes precedence
• CPC Class Codes: G16B 50/00 ICT programming tools or database systems specially adapted for bioinformatics
• CPC Class Codes: G16B 50/20 Heterogeneous data integration
• CPC Class Codes: G16H 50/80 for detecting, monitoring or modelling epidemics or pandemics, e.g. flu

Abstract

A system and method of integrating diverse sources of data and data streams is presented. The method can include selecting a scenario based on a topic, creating a multi-relational directed graph based on the scenario, identifying and converting resources in accordance with the scenario and updating the multi-directed graph based on the resources, identifying data feeds in accordance with the scenario and updating the multi-directed graph based on the data feeds, identifying analytical routines in accordance with the scenario and updating the multi-directed graph using the analytical routines and identifying data outputs in accordance with the scenario and defining queries to produce the data outputs from the multi-directed graph.

Claims

1. A computer readable storage device storing a program of instructions executable by a machine to perform a method of integrating diverse sources of data and data streams, the method comprising:

selecting a scenario for refinement based on a topic, the scenario comprising a text document that describes the topic to be examined, the scenario identifying one or more downstream data users and uses that drive said refinement of the scenario;

creating a multi-relational directed graph based on the scenario;

identifying and converting resources in accordance with the scenario and updating the multi-directed graph based on the converted resources;

identifying data feeds in accordance with the scenario and updating the multi-directed graph based on the data feeds;

creating detectors operable to continuously provide data related to the topic, the detectors receiving said data from said data feeds;

identifying analytical routines that compare information in said data to the scenario and updating the multi-directed graph using the analytical routines, the analytical routines comprising sensors that subscribe to said detectors and responsive to receiving said data, perform at least one of;

comparing, based on alignment, sequences in a data stream to sequences in entities of the multi-relational directed graph, and adding one or more statements to the multi-directed graph based on finding a match;

performing analysis among the entities, literals associated with the scenario and represented as a node in the multi-directed graph and ontologies associated with the scenario and linked to the multi-directed graph, wherein one or more relationship statements are generated between two or more of an entity, a literal, and an ontology in the multi-directed graph; and

linking the entities to samples corresponding to events; and

identifying data outputs in accordance with the scenario at least based on one of the one or more statements and the one or more relationship statements and defining queries to produce the data outputs from the multi-directed graph,

the method further comprising consuming one or more messages from one or more of the sensors indicating a match in said data, the consuming performed by a controller comprising a state machine, and the controller publishing an advisory responsive to finding that all conditions in the scenario are met based on said one or more consumed messages.

2. The computer readable storage device of claim 1, the selecting the scenario comprising:

obtaining one or more of particular text in accordance with the scenario, geo-location information associated with the particular text, and number of times of occurrence of the particular text.

3. The computer readable storage device of claim 1, the identifying and converting resources comprising:

converting the resources into RDF format; and

linking the converted resources into the multi-relational directed graph.

10. The computer readable storage device of claim 1, wherein the data feeds comprise a web crawler, DNA sequencing machine, weather sensor, and satellite imagery.

11. The computer readable storage device of claim 1, wherein the sensors are customized per the scenario.

4. A method of integrating diverse sources of data and data streams comprising:

selecting a scenario for refinement based on a topic, the scenario comprising a text document that describes the topic to be examined, the scenario identifying one or more downstream data users and uses that drive said refinement of the scenario;

creating a multi-relational directed graph based on the scenario;

identifying and converting resources in accordance with the scenario and updating the multi-directed graph based on the converted resources;

identifying data feeds in accordance with the scenario and updating the multi-directed graph based on the data feeds;

creating detectors operable to continuously provide data related to the topic, the detectors receiving said data from said data feeds;

identifying analytical routines that compare information in said data to the scenario and updating the multi-directed graph using the analytical routines, the analytical routines comprising sensors that subscribe to said detectors and responsive to receiving said data, perform at least one of;

comparing, based on alignment, sequences in a data stream to sequences in entities of the multi-relational directed graph, and adding one or more statements to the multi-directed graph based on finding a match;

performing analysis among the entities, literals associated with the scenario and represented as a node in the multi-directed graph and ontologies associated with the scenario and linked to the multi-directed graph, wherein one or more relationship statements are generated between two or more of an entity, a literal, and an ontology in the multi-directed graph; and

linking the entities to samples corresponding to events; and

identifying data outputs in accordance with the scenario at least based on one of the one or more statements and the one or more relationship statements and defining queries to produce the data outputs from the multi-directed graph,

the method further comprising consuming one or more messages from one or more of the sensors indicating a match in said data, the consuming performed by a controller comprising a state machine, and the controller publishing an advisory responsive to finding that all conditions in the scenario are met based on said one or more consumed messages.

5. The method of claim 4, the selecting the scenario comprising:

obtaining one or more of particular text in accordance with the scenario, geo-location information associated with the particular text, and number of times of occurrence of the particular text.

6. The method of claim 4, the identifying and converting resources comprising:

converting the resources into RDF format; and

linking the converted resources into the multi-relational directed graph.

13. The method of claim 4, further comprising connecting the scenario that is refined to another scenario.

14. The method of claim 4, wherein the identifying resources in accordance with the scenario comprises identifying resources required by the scenario but absent in a semantic web.

15. The method of claim 4, wherein the ontologies comprise one or more of a scenario ontology, bio2rdf ontology, or geoname ontology, or combinations thereof.

16. The method of claim 4, wherein the literals comprise one or more of date, match score, or scenario description, or combinations thereof.

7. A system of integrating diverse sources of data and data streams comprising:

a processor; and

a module operable to execute on the processor and to select a scenario for refinement based on a topic, the scenario identifying one or more downstream data users and uses that drive said refinement of the scenario,

create a multi-relational directed graph based on the scenario, identify and convert resources in accordance with the scenario and update the multi-directed graph based on the converted resources, identify data feeds in accordance with the scenario and update the multi-directed graph based on the data feeds, create detectors operable to continuously provide data related to the topic, the detectors receiving said data from said data feeds, identify analytical routines that compare information in said data to the scenario and update the multi-directed graph using the analytical routines, and identify data outputs in accordance with the scenario and define queries to produce the data outputs from the multi-directed graph, the analytical routines comprising sensors that subscribe to said detectors and responsive to receiving said data, perform at least one of;

comparing, based on alignment, sequences in a data stream to sequences in entities of the multi-relational directed graph, and adding one or more statements to the multi-directed graph based on finding a match;

performing analysis among the entities, literals associated with the scenario and represented as a node in the multi-directed graph and ontologies associated with the scenario and linked to the multi-directed graph, wherein one or more relationship statements are generated between two or more of an entity, a literal, and an ontology in the multi-directed graph; and

linking the entities to samples corresponding to events,

wherein the data output is identified at least based on one of the one or more statements and the one or more relationship statements,

the system further comprising a controller comprising a state machine that consumes one or more messages from one or more of the sensors indicating a match in said data, the controller publishing an advisory responsive to finding that all conditions in the scenario are met based on said one or more consumed messages.

8. The system of claim 7, the module further operable to select the scenario by:

obtaining one or more of particular text in accordance with the scenario, geo-location information associated with the particular text, and number of times of occurrence of the particular text.

9. The system of claim 7, the module further operable to identify and convert resources by:

converting the resources into RDF format; and

linking the converted resources into the multi-relational directed graph.

12. The system of claim 7, wherein said controller is one of a plurality of controllers and said scenario is one of a plurality of instantiated scenarios, wherein one controller runs per an instantiated scenario.