example/

README

Examples

All examples can be run by Task, following the Install Task, execute task -l in this directory will list all the examples.

$ task -l |grep example

* example-basic: 			YoMo basic usage
* example-pipeline: 			Unix pipeline to cloud
* example-iopipe: 			IO Pipe
* example-multi-sfn: 			Multiple stream functions
* example-cascading-zipper: 		Cascading zippers

can run each example directly by task example-basic, task example-cascading-zipper and etc.

Basic example

• 0-basic: process the streams from IoT sound sensor.

Linux Pipeline over cloud

• 1-pipeline: read the local streams (f.e. /dev/urandom) and use yomo-source to send the streams over cloud.
• 2-iopipe: use io.Copy() to pipe the local streams (f.e. /dev/urandom) to yomo-source.

Multiple stream functions

• 3-multi-sfn: use 3 stream functions to process the streams in different cases.
  • stream-fn-1: calculate the sound value in real-time.
  • stream-fn-2: print the warning message when the sound value reaches a threshold.
  • stream-fn-3: calculate the average value in a sliding window.

Cascading zippers

• 4-cascading-zipper: source connect to zipper-1, then zipper-1 will broadcast the streams to the zippers in other regions.