basic/

README

Basic example

This example represents how YoMo works with the mock data of sound sensor.

Code structure

• source: Mocking data of a Noise Decibel Detection Sensor. yomo.run/source
• stream-fn (formerly flow): Detecting noise pollution in real-time and print the warning message when it reaches the threshold. yomo.run/stream-function
• zipper: Orchestrate a workflow that receives the data from source, stream computing in stream-fn yomo.run/zipper

How to run the example

1. Install YoMo CLI

Please visit YoMo Getting Started for details.

2. Run zipper

yomo serve -c ./zipper/workflow.yaml

Using config file: ./zipper/workflow.yaml
2021/11/11 16:09:54 [yomo:zipper] [AddWorkflow] 0, Noise
ℹ️   Running YoMo-Zipper...
2021/11/11 16:09:54 [yomo:zipper] Listening SIGTERM/SIGINT...
2021/11/11 16:09:54 [core:server] ✅ (name:Service) Listening on: 127.0.0.1:9000, QUIC: [v1 draft-29]

3. Run stream-function

go run ./flow/main.go

2021/11/11 16:11:05 [core:client] use credential: [AppKey]
2021/11/11 16:11:05 handshake frame=&frame.HandshakeFrame{Name:"Noise", ClientType:0x5d, authType:0x1, authPayload:[]uint8{0x61, 0x62, 0x63, 0x31, 0x32, 0x33}},err=<nil>
2021/11/11 16:11:05 [core:client] ❤️  [Noise] is connected to YoMo-Zipper localhost:9000

4. Run yomo-source

go run ./source/main.go

2021/11/11 16:12:01 [core:client] use credential: [AppKey]
2021/11/11 16:12:01 handshake frame=&frame.HandshakeFrame{Name:"yomo-source", ClientType:0x5f, authType:0x1, authPayload:[]uint8{0x61, 0x62, 0x63, 0x31, 0x32, 0x33}},err=<nil>
2021/11/11 16:12:01 [core:client] ❤️  [yomo-source] is connected to YoMo-Zipper localhost:9000
2021/11/11 16:12:01 [source] ✅ Emit {192.13399 1636618321242 localhost} to YoMo-Zipper
2021/11/11 16:12:01 [source] ✅ Emit {132.86566 1636618321547 localhost} to YoMo-Zipper
2021/11/11 16:12:01 [source] ✅ Emit {199.17604 1636618321851 localhost} to YoMo-Zipper

Results

stream-function

The terminal of stream-function will print the real-time noise decibel value, and show the warning when the value reaches the threshold.

2021/11/11 16:12:01 >> [flow] got tag=0x33, data={ 0x1.80449ap+07  0x17d0e0dbd5a 0x6c 0x6f 0x63 0x61 0x6c 0x68 0x6f 0x73 0x74}
2021/11/11 16:12:01 >> [flow] got tag=0x33, data={ 0x1.09bb38p+07  0x17d0e0dbe8b 0x6c 0x6f 0x63 0x61 0x6c 0x68 0x6f 0x73 0x74}
2021/11/11 16:12:01 >> [flow] got tag=0x33, data={ 0x1.8e5a22p+07  0x17d0e0dbfbb 0x6c 0x6f 0x63 0x61 0x6c 0x68 0x6f 0x73 0x74}