METHOD AND SYSTEM FOR SENSING INFORMATION, IMPUTING MEANING TO THE INFORMATION, AND DETERMINING ACTIONS BASED ON THAT MEANING, IN A DISTRIBUTED COMPUTING ENVIRONMENT

• US 20180084073A1
• Filed: 03/25/2016
• Published: 03/22/2018
• Est. Priority Date: 03/27/2015
• Status: Active Grant

• Current Assignee: GlobalLogic Inc. (Hitachi, Ltd.)
• Original Assignee: GlobalLogic Inc. (Hitachi, Ltd.)
• Inventors: WALSH, JAMES FRANCIS, KHAKI, SUHAIL MURTAZA, SINHA, MANU, CARACOCHE, JUAN MANUEL, MYGAIEV, ARTEM, BORKIN, FRANCIS MICHAEL, CHATURVEDI, BHASKAR, GUPTA, MAYANK, VARGHESE, BIJU
• Granted Patent: US 11,258,874 B2
• Time in Patent Office: Days
• CPC Class Codes: G16Y 30/00 IoT infrastructure
• CPC Class Codes: G16Y 40/35 Management of things, i.e. controlling in accordance with a policy or in order to achieve specified objectives
• CPC Class Codes: H04L 67/12 specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
• CPC Class Codes: H04L 67/564 Enhancement of application control based on intercepted application data

Abstract

A machine implemented method and system, including: receiving at a near real-time processor module, one or more tenant-specific business objects from a message handler module; receiving at the near real-time processor module, contextual data related to the received one or more tenant-specific business objects from a platform analytics module; forming at the near real-time processor module, one or more events by applying one or more pre-defined analytic models to the received contextual data and the received one or more tenant-specific business objects; receiving at a message publisher module, one or more events from the near real-time processor module; and transmitting the received one or more events to one or more subscribers for the one or more events.

Claims

1. A computer implemented method comprising executing on a processor the steps of:

receiving at a platform gateway module, data transmitted from one or more resources;

forming at the platform gateway module one or more messages based on the data from the one or more resources;

receiving at a message collector module one or more messages formed by the platform gateway module;

transmitting from the message collector module, the received one or more messages to a platform persistence module for storage;

receiving at a tenant handler module, one or more messages from the message collector module;

mapping at the tenant handler module, the received one or more messages to a tenant of a plurality of tenants;

receiving at a message handler module, the one or more messages mapped to the tenant from the tenant handler module;

forming at the message handler module, one or more tenant-specific business objects by applying a business logic to the one or more messages based on the mapped tenant;

forming at a near real-time processor module, one or more events by applying one or more pre-defined analytic models to contextual data and the one or more tenant-specific business objects;

receiving at a message publisher module, one or more events from the near real-time processor module; and

transmitting the received one or more events to one or more subscribers for the one or more events.

2. The computer-implemented method of claim 1 further comprising:

receiving at the near real-time processor module, the one or more tenant-specific business objects from the message handler module.

3. The computer-implemented method of claim 2 further comprising:

receiving at the near real-time processor module, the contextual data related to the received one or more tenant-specific business objects from a platform analytics module.

4. The computer-implemented method of claim 1 further comprising:

transmitting from the message handler module, the one or more tenant-specific business objects to the platform persistence module for storage.

5. The computer-implemented method of claim 4 further comprising:

receiving at the platform persistence module, external data from an external services orchestrator module.

6. The computer-implemented method of claim 5 further comprising:

receiving at the platform analytics module, data from the platform persistence module, wherein the data from the platform persistence module comprises at least one of;

messages from the message collector module, tenant-specific business objects from the message handler module, and external data from the external services orchestrator module.

7. The computer-implemented method of claim 6 further comprising:

forming at the platform analytics module, the contextual data containing a real-time view generator module comprising a near-real time view of data and a batch view generator module comprising a historical data that does not overlap with the near-real time view of data.

8. The computer-implemented method of claim 1 further comprising:

receiving at the near real-time processor module, contextual data derived from machine learning based on previously received messages, business objects and external data from the platform analytics module.

9. The computer-implemented method of claim 1 wherein the received data comprises at least one of:

an observed status data, a request data, and an automated sensor data.

10. The computer-implemented method of claim 1 wherein the one or more resources comprise one or more of:

a sensor, an actuator, a smart device, a smartphone, a set-top box, an external machine-to-machine (M2M) enabler, a human input, and an organism input.

11. The computer-implemented method of claim 1 wherein forming the one or more messages at the platform gateway module further comprises:

determining at the platform gateway module, a type of resource for the received data; and

transforming at the platform gateway module, the received data into the message based on the determined type of resource, wherein the message is a format usable by the message collector module.

12. The computer-implemented method of claim 11 wherein transforming the received data into the message at the platform gateway module further comprises:

forming at the platform gateway module, an abstracted data, wherein the abstracted data abstracts out any device-specific or communication protocol-specific information based on the determined type of resource.

13. The computer-implemented method of claim 1 wherein the message collector module receives the one or more messages formed by the platform gateway module asynchronously.

14. The computer-implemented method of claim 1 wherein transmitting the one or more events to one or more subscribers further comprises:

receiving at a message listener module, the one or more events; and

determining at an app platform module, a next step in a workflow based on the received event.

15. The computer-implemented method of claim 14 wherein executing the next step in the workflow further comprises:

receiving at a workflow manager module, a workflow task that requires triggering an actuator in resources, wherein a Worker associated with the workflow task does cause;

sending a message to a Platform SDK to trigger the Actuator, wherein the Platform Services does cause;

sending an activation message to the platform Gateway module, which maps the activation message to the appropriate data format to activate such device and initiates;

sending such actuator data to resources;

wherein such data is used to trigger such actuator by at least one of;

controller, software systems, and external M2M enablers.

16. The computer-implemented method of claim 1 wherein a platform management portal or apps does seek to activate an actuator in resources:

sending of an activation message to Platform API Services, to trigger such actuator, wherein the platform services does cause

sending of an activation message to Platform Gateway, which maps such message to the appropriate data format to activate such actuator and initiates; and

sending such actuator data to Resources;

wherein such data is used to trigger such actuator by at least one of;

controller, software systems or external M2M enablers.

17. The computer-implemented method of claim 1 further comprising:

forming at the platform analytics module, the contextual data, wherein the contextual data contains the results of one or more analytic models that algorithmically combine data from one or more of;

data from the platform persistence module, external data obtained through an external services orchestrator module, data from an external machine-to-machine (M2M) enabler, data from a software system, data from an enterprise systems, data interactively supplied by one or more users of applications, other contextual data, predictive data inferred source or other contextual data, and machine learning data inferred from source or other contextual data.

18. A system comprising:

a resources module configured to sense information using one or more distributed sensor devices;

a platforms module configured to impute meaning to the sensed information based on one or more of;

the context of the sensed information and analyzing the sensed information using current information, historical information, and other information relevant to the context; and

an applications module configured to determine one or more actions based on the imputed meaning of the sensed information.

19. The system of claim 18 wherein the resources module is further configured to:

receive data from the distributed sensor devices; and

form one or more messages based on the received data.

20. The system of claim 19 wherein the platforms module is further configured to:

receive one or more formed messages;

transmit the received one or more messages to a platform persistence module for storage;

map the received one or more messages to a client of a plurality of clients;

form one or more business objects by applying a business logic to the one or more messages based on the mapped client; and

form one or more events by applying one or more pre-defined analytic models and context to the one or more business objects.

21. The system of claim 20 wherein the applications module is further configured to determine a next step in a workflow based on the received event to determine one or more actions.

22. The system of claim 20 wherein the applications module is further configured to:

transmit the one or more events to one or more subscribers for the one or more events.

23. The system of claim 22 wherein one or more of the subscribers are the client.

24. The system of claim 20 wherein the formed one or more messages are based on at least one of:

a client rule, a data aggregation, an abstraction of device-specific information, and an abstraction of protocol-specific information.

25. The system of claim 20 wherein the platforms module is further configured to:

transmit the one or more business objects to the platform persistence module for storage.

26. The system of claim 25 wherein the platform persistence module is further configured to:

receive external data from an external services orchestrator module for supporting data federation from one or more of;

external sources of information through an application program interface (API), a database, and a query.

27. The system of claim 26 wherein the platforms module is further configured to:

receive data from the platform persistence module, wherein the data from the platform persistence module comprises at least one of;

messages, business objects, and external data.

28. The system of claim 27 wherein the platforms module is further configured to:

form contextual data containing a real-time view generator module comprising a near-real time view of data and a batch view generator module comprising a historical data that does not overlap with the near-real time view of data.

29. The system of claim 18 wherein the platforms module is further configured to:

receive contextual data derived from machine learning based on previously received messages, business objects and external data.

30. The system of claim 18 wherein the sensed information comprises at least one of:

an observed status data, a request data, and an automated sensor data.

31. The system of claim 18 wherein the one or more distributed sensor devices comprise one or more of:

a sensor, an actuator, a smart device, a smartphone, a set-top box, an external machine-to-machine (M2M) enabler, a human input, and an organism input.

32. The system of claim 20 wherein the platforms module is further configured to:

determine a type of resource for the sensed information; and

transform the sensed information into the message based on the determined type of resource, wherein the message is a format usable by the platforms module.

33. The system of claim 32 wherein the platforms module is further configured to:

form an abstracted data, wherein the abstracted data abstracts out any device-specific or communication protocol-specific information based on the determined type of resource.

34. The system of claim 20 wherein the platforms module receives the one or more formed messages asynchronously.

35. The system of claim 18 wherein the platforms module is further configured to:

form contextual data, wherein the contextual data contains a result of an analytic model that algorithmically combines a source data from one or more of;

data from the platform persistence module, external data, data from an external machine-to-machine (M2M) enabler, data from a software system, data from an enterprise systems, data interactively supplied by one or more users of applications, predictive data inferred from the source data, and machine learning data inferred from the source data.

36. A computer implemented method comprising executing on a processor the steps of:

sensing at a resources module, information using one or more distributed sensor devices;

imputing at a platforms module, meaning to the sensed information based on one or more of;

the context of the sensed information and analyzing the sensed information using current information, historical information, and other information relevant to the context; and

determining at an applications module, one or more actions based on the imputed meaning of the sensed information.

37. The computer-implemented method of claim 36 further comprising:

receiving at the resources module, data from the distributed sensor devices; and

forming at the resources module, one or more messages based on the received data.

38. The computer-implemented method of claim 37 further comprising:

receiving at the platforms module, one or more formed messages;

transmitting by the platforms module, the received one or more messages to a platform persistence module for storage;

mapping by the platforms module, the received one or more messages to a client of a plurality of clients;

forming by the platforms module, one or more business objects by applying a business logic to the one or more messages based on the mapped client; and

forming by the platforms module, one or more events by applying one or more pre-defined analytic models and context to the one or more business objects.

39. The computer-implemented method of claim 38 further comprising:

determining by the applications module, a next step in a workflow based on the received event to determine one or more actions.

40. The computer-implemented method of claim 38 further comprising:

transmitting by the applications module, the one or more events to one or more subscribers for the one or more events.

41. The computer-implemented method of claim 40 wherein one or more of the subscribers are the client.

42. The computer-implemented method of claim 38 wherein the formed one or more messages are based on at least one of:

a client rule, a data aggregation, an abstraction of device-specific information, and an abstraction of protocol-specific information.

43. The computer-implemented method of claim 38 further comprising:

transmitting by the platforms module, the one or more business objects to the platform persistence module for storage.

44. The computer-implemented method of claim 43 further comprising:

receiving by the platform persistence module, external data from an external services orchestrator module for supporting data federation from one or more of;

external sources of information through an application program interface (API), a database, and a query.