Distributed smart grid processing

1. A computer-implemented method for generating network-based data services, the method comprising:

configuring a first cloud computing environment to acquire a sequence of data values and convert the sequence of data values into a first data stream;

configuring a second cloud computing environment to accumulate the first data stream into a data archive and to perform a historical analysis on the first data stream to identify a first trend associated with the first data stream;

configuring a third cloud computing environment to perform one or more real-time processing operations on the first data stream to determine that a first condition associated with the first data stream has been met; and

providing a subscriber to the network-based data services with access to the first data stream, the first trend, and an indication that the first condition has been met.

2. The computer-implemented method of claim 1 , wherein configuring the first cloud computing environment comprises configuring the first cloud computing environment to:

receive the sequence of data values;

encrypt the sequence of data values to generate encrypted data; and

push the encrypted data into a first queue that resides behind a firewall.

3. The computer-implemented method of claim 2 , wherein configuring the first cloud computing environment further comprises configuring the first cloud computing environment to:

retrieve the encrypted data from the first queue;

convert the encrypted data from a first format to a second format;

decrypt the encrypted data to generate decrypted data;

generate anonymized data based on the decrypted data;

compress the anonymized data to generate the first data stream; and

push the first data stream onto a second queue.

4. The computer-implemented method of claim 1 , wherein configuring the second cloud computing environment comprises:

configuring a master node and a plurality of slave nodes to implement a distributed, parallel processing environment; and

configuring the data archive to receive data streams and queries and, in response to one or more of the queries, to provide access to data associated with the first data stream.

5. The computer-implemented method of claim 1 , wherein configuring the third cloud computing environment comprises:

configuring a message queue to queue the first data stream;

configuring a stream actor to execute a sequence of stream functions on the first data stream to generate first stream data; and

configuring a database to store the first stream data.

6. The computer-implemented method of claim 1 , wherein creating the data service comprises causing a web-based service to provide access, via a uniform resource indicator (URI), to the first data stream, the first trend, and the indication that the first condition has been met.

7. The computer-implemented method of claim 1 , further comprising configuring the second cloud computing environment to identify the first trend associated with the first data stream and, in response, trigger the third cloud computing environment to perform the real-time processing analysis.

8. The computer-implemented method of claim 7 , wherein the first condition is that the first data stream complies with the first trend.

9. The computer-implemented method of claim 1 , further comprising configuring the third cloud-computing environment to determine that the first condition has been met and, in response to the first condition being met, triggering the second cloud computing environment to perform the historical analysis.

10. The computer-implemented method of claim 9 , wherein the first trend indicates that the first condition associated with the first data stream was previously met.

11. A computer-implemented method for performing a cloud computing operation, the method comprising:

configuring a first cloud computing environment to perform a first processing operation on a sequence of data values to produce a first result;

configuring a second cloud computing environment to perform a second processing operation on the sequence of data values, in response to the first result, to produce a second result; and

generating a notification based on the first result and the second result.

12. The computer-implemented method of claim 11 , wherein the first cloud computing environment comprises a distributed processing cloud, the first operation comprises a historical analysis on the sequence of data values, and the first result indicates a trend associated with the sequence of data values.

13. The computer-implemented method of claim 12 , wherein the second cloud computing environment comprises a real-time processing cloud, the second operation comprises a real-time analysis on the sequence of data values, and the second result indicates that the sequence of data values follows the trend.

14. The computer implemented method of claim 11 , wherein the first cloud computing environment comprises a real-time processing cloud, the first operation comprises a real-time analysis on the sequence of data values, and the first result indicates that a condition associated with the sequence of data values has been met.

15. The computer implemented method of claim 14 , wherein the second cloud computing environment comprises a distributed processing cloud, the second operation comprises a historical analysis on the sequence of data values, and the second result indicates that the sequence of data values has previously met the condition.

16. The computer-implemented method of claim 11 , wherein the sequence of data values is generated from a plurality of sensor readings collected by a node within a network, and wherein the node is configured to monitor a utility distribution infrastructure.

17. A system for performing historical and real-time analysis on a sequence of data values, comprising:

a first cloud computing environment, configured to:

accumulate the sequence of data values for storage in a data archive, and

perform a historical analysis on data stored in the data archive;

a second cloud computing environment configured to:

monitor the sequence of data values in real time, and

determine when one or more conditions associated with sequence of data values has been met; and

a computing device, configured to:

instantiate the first cloud computing environment,

instantiate the second cloud computing environment, and

configure a network of nodes coupled to an underlying network to record data associated with the underlying network and to transmit the data to the first cloud computing environment and to the second cloud computing environment.

18. The system of claim 17 , wherein the first cloud computing environment is further configured to cause the second cloud computing environment to monitor the sequence of data values and determine when the one or more conditions have been met in response to performing the historical analysis on the sequence of data values.

19. The system of claim 17 , wherein the second cloud computing environment is further configured to cause the first cloud computing environment to perform the historical analysis in response to determining that the one or more conditions have been met.

20. The system of claim 17 , wherein the first cloud computing environment provides access to a first data service that indicates results associated with the historical analysis, and the second cloud computing environment provides access to a second data service that indicates when the one or more conditions have been met.