Atlas Stream Processing Solar Stream Sample Example

stream.js

SAMPLE STREAM SOLAR

//Create the Stream Processor and add the sample_stream_solar connection registry connection first

//Create variablre for source connection

solar={$source:{connectionName:'sample_stream_solar',  timeField: { $dateFromString: { dateString: '$timestamp' }}}}


// Observe sample data

sp.process([solar])


//create a variable for the tumbling windoe

 w =       { $tumblingWindow: {
                interval: {size: NumberInt(10), unit: "second"},
                        "pipeline": [ 
                            {
                                $group: {
                                    "_id" : { "device_id" : "$device_id"}, 
                                    max_temp :  { $max : "$obs.temp"},
                                    max_watts :  { $max : "$obs.watts"},
                                    min_watts : { $min : "$obs.watts"},
                                    avg_watts :  { $avg : "$obs.watts"},
                                    median_watts : { $median :{
                                                    input: "$obs.watts",
                                                    method: "approximate"
                                                  } }                                      
                                }
                            }
                        ],
                     } 
                 }


//observe resuting tumbling window stream
sp.process([solar,w])