Appliance for enterprise information integration and enterprise resource interoperability platform and methods
The invention provides apparatus, platforms and methods according to the invention provide a surveillance, monitoring and real-time events platform to (i) enable the integration and communication of information between government agencies and organizations specifically tasked with ensuring the security and safety of our nation and its communities, (ii) to integrate information systems from federal, state and/or local agencies (from disparate data sources if necessary) in order to obtain a single, real-time view of the entire organization, and (iii) to extract more complete, actionable information from their existing systems, thereby dramatically improving decision making speed and accuracy.
1. A method of enterprise integration, the method comprising, with one or more digital data processors having one or more programmed processors, executing the steps of:
A. obtaining data from one or more first data sources, the data being encoded in a first set of Resource Description Framework (RDF) triples;
B. executing a rules engine to process the first set of RDF triples in order to identify data from the one or more first data sources that relates to a criteria and to classify that data to be one or more of ignored, stored, logged for alert, broadcast, and displayed, wherein identifying data from the one or more first data sources that relates to a criteria comprises:
(i) identifying as related data substantially matching the criteria, and
(ii) identifying as related data that is a direct ancestor of data identified in any of steps (i) and (ii), and that is not in substantial conflict with the criteria;
C. responding to at least selected data classifications by obtaining data from one or more second data sources, the data being encoded in a second set of RDF triples;
D. executing the rules engine to process at least the second set of triples in order to any of further classify the data, ignore the data, store the data, generate an alert, generate a broadcast, and generate a message, and display the data.
2. The method of claim 1 , wherein any of the first and second data sources is a data stream.
3. The method of claim 1 , wherein any of the first and second data sources is a database.
4. The method of claim 1 , wherein the rules engine identifies RDF triples that are related to a selected criteria.
5. The method of claim 1 , wherein the rules engine generates alerts and/or messages for presentation to an operator based on the classification of the data.
6. The method of claim 1 , further comprising extracting data from one or more data sources, and a converting the data into the RDF triples.
7. The method of claim 1 , wherein any of the one or more first data sources and the one or more second data sources are compliant with a public health information network (PHIN) protocol, a health area network (HAN) protocol, National Electronic Disease Surveillance System (NEDSS) protocol, or other protocol for communication of health and/or bioterrorism data.
8. The method of claim 1 , wherein the one or more digital data processors comprise a data processing station resident at a node of a public health information network (PHIN), a health area network (HAN), National Electronic Disease Surveillance System (NEDSS) network, or other network for communication of health and/or bioterrorism data.
9. The method of claim 1 , wherein the one or more digital data processors comprise an integration appliance.
10. A method of enterprise integration, the method comprising, with one or more digital data processors having one or more programmed processors, executing the steps of:
A. receiving one or more RDF data streams comprising data encoded in RDF triples; executing a rules engine to find related RDF triples by the steps of:
(i) identifying as related data substantially matching a criteria, and
(ii) identifying as related data that is a direct ancestor of data identified in any of steps (i) and (ii), and that is not in substantial conflict with the criteria; and
B. responding to related RDF triples by the rules engine applying further processing of the data when certain relationships between the RDF triples are detected by the rules engine.
11. The method of claim 10 , wherein the rules engine identifies RDF triples that are related to criteria in a query.
12. The method of claim 11 , wherein the rules engine generates alerts and/or messages for presentation to an operator based on the identified RDF triples.
13. The method of claim 10 , further comprising a extracting data from one or more data sources, and a converting the data into the RDF triples.
14. The method of claim 10 , wherein the rules engines determines a classification level of data in the RDF data streams, where the classification level determines the further action taken by the rules engine.
15. The method of claim 10 , wherein the one or more RDF data streams comprise information received in accordance with a public health information network (PHIN) protocol, a health area network (HAN) protocol, National Electronic Disease Surveillance System (NEDSS) protocol, or other protocol for communication of health and/or bioterrorism data.
16. The method of claim 10 , wherein the one or more digital data processors comprise a data processing station resident at a node of a public health information network (PHIN), a health area network (HAN), National Electronic Disease Surveillance System (NEDSS) network, or other network for communication of health and/or bioterrorism data.
17. The method of claim 10 , wherein the one or more digital data processors comprise an integration appliance.
18. A method of enterprise integration, the method comprising, with one or more digital data processors having one or more programmed processors, executing the steps of:
A. receiving one or more RDF data streams comprising data encoded in RDF triples;
B. executing a rules engine to process the RDF triples in order to identify data from the one or more RDF data streams that relates to a criteria and to classify that data to be one or more of ignored, stored, logged for alert, broadcast, and displayed, wherein identifying data from the one or more RDF data streams that relates to a criteria comprises:
(i) identifying as related data substantially matching the criteria, and
(ii) identifying as related data that is a direct ancestor of data identified in any of steps (i) and (ii), and that is not in substantial conflict with the criteria;
C. responding to the classification of the data and the related RDF triples by the rules engine applying further processing of the data.
19. The method of claim 18 , wherein the rules engine identifies RDF triples that are related to criteria in a query.
20. The method of claim 19 , wherein the rules engine generates alerts and/or messages for presentation to an operator based on the identified RDF triples.
21. The method of claim 18 , further comprising extracting data from one or more data sources, and converting the data into the RDF triples.
22. The method of claim 18 , wherein the rules engines determines a classification level of data in the RDF data streams, where the classification level determines the further action taken by the rules engine.
23. The method of claim 18 , wherein the one or more RDF data streams comprise information received in accordance with a public health information network (PHIN) protocol, a health area network (HAN) protocol, National Electronic Disease Surveillance System (NEDSS) protocol, or other protocol for communication of health and/or bioterrorism data.
24. The method of claim 18 , wherein the one or more digital data processors comprise a data processing station resident at a node of a public health information network (PHIN), a health area network (HAN), National Electronic Disease Surveillance System (NEDSS) network, or other network for communication of health and/or bioterrorism data.
25. The method of claim 18 , wherein the one or more digital data processors comprise an integration appliance.
26. A data processing system for enterprise integration, the system comprising:
a plurality of data sources; and
one or more digital data processors having one or more processors, storage units, and/or communication devices, said one or more digital data processors being coupled to the data sources and comprising:
conversion functionality to convert data from the data sources into Resource Description Framework (RDF) triples; and
a rules engine coupled to the data sources to process the RDF triples, the processing comprising identifying data from the one or more data sources that relates to a criteria and to classify that data to be one or more of ignored, stored, logged for alert, broadcast, and displayed, wherein identifying data from the one or more data sources that relates to a criteria comprises:
(i) identifying as related data substantially matching the criteria, and
(ii) identifying as related data that is a direct ancestor of data identified in any of steps (i) and (ii), and that is not in substantial conflict with the criteria;
wherein the classification of the RDF triples can trigger additional function of the rules engine.
27. The method of claim 26 , wherein one or more of the plurality of data sources are compliant with a public health information network (PHIN) protocol, a health area network (HAN) protocol, National Electronic Disease Surveillance System (NEDSS) protocol, or other protocol for communication of health and/or bioterrorism data.
28. The method of claim 26 , wherein the one or more digital data processors comprise a data processing station resident at a node of a public health information network (PHIN), a health area network (HAN), National Electronic Disease Surveillance System (NEDSS) network, or other network for communication of health and/or bioterrorism data.
29. The method of claim 26 , wherein the one or more digital data processors comprise an integration appliance.
30. A data processing system for enterprise integration, the system comprising:
a plurality of data sources; and
one or more digital data processors having one or more processors, storage units, and/or communication devices, said one or more digital data processors being coupled to the data sources and comprising:
conversion functionality to convert data from the data sources into Resource Description Framework (RDF) triples; and
a rules engine coupled to the data sources to process the RDF triples, the processing comprising identifying data from the one or more data sources that relates to a criteria and to classify that data to be one or more of ignored, stored, logged for alert, broadcast, and displayed, wherein identifying data from the one or more data sources that relates to a criteria comprises:
(i) identifying as related data substantially matching the criteria, and
(ii) identifying as related data that is a direct ancestor of data identified in any of steps (i) and (ii), and that is not in substantial conflict with the criteria;
wherein the rules engine generates alerts and/or messages for presentation to an operator based on the identified RDF triples.