Calculation engine and calculation providers

• US 8,984,034 B2
• Filed: 09/28/2010
• Issued: 03/17/2015
• Est. Priority Date: 09/28/2010
• Status: Active Grant

• Current Assignee: Schneider Electric USA, Inc. (Schneider Electric SE)
• Original Assignee: Schneider Electric USA, Inc. (Schneider Electric SE)
• Inventors: Lloyd, Chad Andrew, McClanahan, Jason D., Dodson, John Jeffrey, Yeo, Jeffrey W., Little, Marcus E., Zheng, Yixiong, Wall, Theresa K., Wimsatt, Coni Christine
• Primary Examiner(s): Chen, Susan
• Application Number:
  US12/892,504
• Publication Number:
  US 20120078944A1
• Time in Patent Office: 1,631 Days
• Field of Search: 707/899, 707/769, 705/4, 705/412, 705/35, 705/41, 717/128, 717/168, 713/164, 726/26
• US Class Current: 707/899
• CPC Class Codes: G05B 23/027 Alarm generation, e.g. communication protocol; Forms of alarm

Abstract

A method of acquiring data and performing calculations on the data using a provider service. A provider ticket service (PTS) receives tickets from one or more clients. Each ticket includes a calculation identifier and a payload. The calculation identifier identifies a calculation to be performed using information in the payload. The PTS associates a unique ticket identifier with each ticket. A ticket manager submits a selected ticket from the PTS to a provider host service (PHS), which determines which provider is to perform the calculation identified by the selected ticket by inspecting provider identification information in the selected ticket. The PHS launches a provider host thread (PHT) that invokes the provider determined to perform the calculation identified by the calculation identifier of the selected ticket. The provider performs the calculation and returns its result to the PHS, which passes the result back to the PTS, which returns the result to the requesting client.

Claims

1. A method of acquiring data and performing calculations on a computer system using a provider service, comprising:

receiving, at a provider ticket service implemented in a first process on the computer system, a plurality of tickets from one or more clients, each of the tickets including a calculation identifier and a payload, the calculation identifier identifying a calculation to be performed using at least information indicated in the payload of the ticket;

associating a unique ticket identifier with each of the tickets received at the provider ticket service;

submitting, by a ticket manager implemented in a second process on the computer system, a selected ticket from the provider ticket service to a provider host service implemented in a third process on the computer system;

determining which one or more of a plurality of providers is to perform the calculation identified by the calculation identifier of the selected ticket;

launching, by the provider host service, at least one provider host thread that invokes or instantiates the one or more providers determined to perform the calculation identified by the calculation identifier of the selected ticket;

receiving at the provider ticket service from the provider host service a result of the calculation carried out by the invoked one or more providers; and

returning the result to the requesting client associated with the selected ticket.

2. The method of claim 1, further comprising, prior to performing the calculation requested by the selected ticket, determining whether the calculation requested by the selected ticket has been performed already, and, if so, retrieving the previously calculated result and returning the previously calculated result as the result to be returned to the requesting client associated with the selected ticket.

3. The method of claim 1, further comprising, prior to performing the calculation requested by the selected ticket, determining whether another of the providers is in the process of performing the calculation requested by the selected ticket, and if so, waiting for the other provider to perform the calculation and provide the result and returning the result from the other provider as the result to be returned to the requesting client associated with the selected ticket.

4. The method of claim 1, further comprising:

determining whether to store the result based on at least one criterion; and

responsive to the at least one criterion being satisfied, storing the result in a data store of the provider ticket service.

5. The method of claim 4, wherein the at least one criterion includes whether the calculation requested by the selected ticket has been requested by at least one other of the clients.

6. The method of claim 4, wherein the at least one criterion includes a frequency with which the result is expected to be requested or has been requested.

7. The method of claim 4, wherein the at least one criterion includes whether data used to perform the calculation is within a predetermined time period.

8. The method of claim 1, further comprising:

receiving, from the client that provided the first ticket, a request for the result using the ticket identifier associated with the first ticket; and

responsive to receiving the request from the requesting client, querying the data store for the result.

9. The method of claim 1, further comprising inserting into the selected ticket a provider identification that identifies which of the one or more of providers is to be invoked for carrying out the calculation identified by the calculation identifier of the selected ticket.

10. The method of claim 1, further comprising:

communicating to the client that communicated the selected ticket the ticket identifier associated with the selected ticket;

receiving from the one or more clients a request for a status of the selected ticket;

responsive to receiving the request for the status of the selected ticket, the provider ticket service querying a ticket status table for the status of the selected ticket; and

the provider ticket service communicating, to the client that requested the status of the selected ticket, the status of the selected ticket, the status including an indication of whether processing of the selected ticket is pending or in-progress, and if the status of the selected ticket is in-progress, the ticket provider service further communicating an indication as to how much processing has been completed or remains to be completed to produce the result.

11. The method of claim 1, wherein the invoked provider carries out the calculation to be performed using input data hosted locally by the provider host service or externally to the provider host service based at least in further part on the local or external data.

12. The method of claim 1, further comprising:

the invoked provider requesting the information indicated in the payload of the ticket from a data store hosted by the provider ticket service or from a data service hosted external to the provider host service and to the provider ticket service; and

responsive to the invoked provider requesting the information, the invoked provider receiving input data from the data store or external data service and using the received input data to perform the calculation requested by the selected ticket.

13. The method of claim 1, further comprising:

storing, using a ticket manager, the tickets in a ticket store according to a queue;

identifying a status of each of the tickets and storing an indication of the status of each of the tickets, including the selected ticket, in a ticket status table;

increasing a pending ticket counter each time the status of selected ones of the tickets is identified as pending;

querying the ticket store for a first one of the tickets at the front of the queue; and

identifying from the first ticket at least a provider to be invoked from the plurality of providers for carrying out the calculation indicated by the calculation identifier of the first ticket.

14. The method of claim 13, further comprising, responsive to receiving the selected ticket at the provider ticket service, updating the status of the selected ticket in the ticket status table from pending to in-progress.

15. The method of claim 14, further comprising:

storing the result in a data store of the provider ticket service; and

responsive to storing the result in the data store of the provider ticket service, updating the status of the selected ticket in the ticket status table from in-progress to completed.

16. The method of claim 13, wherein each of at least some of the tickets further includes a priority field indicating a priority order of invocation relative to the other tickets, the first ticket including a higher priority order in the corresponding priority field compared to at least some of the other tickets.

17. The method of claim 1, further comprising:

receiving, at the provider ticket service, a request to cancel one of the tickets;

the provider ticket service determining which of the providers to notify based on provider identification information in the ticket to be canceled;

notifying the provider determined to be associated with the ticket to be canceled that the ticket to be canceled has received the request to cancel; and

canceling the ticket to be canceled.

18. The method of claim 1, wherein the payload includes a set of inputs or parameters needed to perform the calculation associated with the calculation identifier.

19. The method of claim 18, wherein the set of inputs or parameters includes a source identification indicating a source of at least some of the data needed to perform the calculation associated with the calculation identifier.

20. The method of claim 1, further comprising the provider host service notifying the provider ticket service how many provider host threads are available to perform calculations requested by the tickets.

21. The method of claim 1, wherein the launching the at least one provider host thread includes invoking a plurality of providers and chaining the plurality of providers together, some of the chained providers performing an intermediate calculation and producing an intermediate result to produce the result as the result to be returned to the requesting client associated with the selected ticket.

22. The method of claim 1, wherein the selected ticket includes a source identification, a topic identification, and a date or a date range, the source identification identifying a source of data used to perform the calculation identified by the calculation identifier of the selected ticket, the topic information identifying topical information about the data from the source identification, and the date or date range corresponding to a date or date range of the topical data from the source of the data.

23. The method of claim 22, wherein the selected ticket further includes a dependency identification associated with the source identification and the topic identification, the dependency identification having a unique value relative to dependency identifications associated with every other one of the tickets to permit multiple instances of the same source-topic combinations having the same source identification and the same topic identification.

24. The method of claim 23, wherein the dependency identification identifies one of a plurality of time-of-use (TOU) schedules, each of the TOU schedules being associated with the same source identification and the same topic identification, the calculation determining a time-of-use (TOU) pricing or an energy usage based on the TOU schedule identified by the dependency identification.

25. The method of claim 1, wherein the information includes values indicative of or calculated from a characteristic of a utility that is measured by one or more intelligent electronic devices in a utility system.