-
Build each stream application in the
Stream Application
section. -
Build Task Application
-
Create the table required for the demo by executing the scripts in the
Setup DB
section. -
Build and launch the sensor application as show below.
-
Use your Database client to see the data appear in the bananas table.
mvn dockerfile:build
Note
|
If you are using minikube be sure to execute this command prior to the docker build, eval $(minikube docker-env) .
|
To setup a slack channel for alerts using web-hooks follow the instructions here.
From the Spring Cloud Data Flow Shell
app register --name filteroutbadcpm --type processor --uri maven://io.spring:filterbadcpm:1.0.0.BUILD-SNAPSHOT
app register --name transformcpm --type processor --uri maven://io.spring:transformcpm:1.0.0.BUILD-SNAPSHOT
app register --name alertsink --type sink --uri maven://io.spring:bananaalert:1.0.0.BUILD-SNAPSHOT
app register --name logbananaaverage --type task --uri maven://io.spring:logbananaaverage:1.0.0.BUILD-SNAPSHOT
app register --name filteroutbadcpm --type processor --uri docker:cppwfs/filterbadcpm:1.0.0.BUILD-SNAPSHOT
app register --name transformcpm --type processor --uri docker:cppwfs/transformcpm:1.0.0.BUILD-SNAPSHOT
app register --name alertsink --type sink --uri docker:cppwfs/bananaalert:1.0.0.BUILD-SNAPSHOT
app register --name logbananaaverage --type task --uri docker:cppwfs/logbananaaverage:1.0.0.BUILD-SNAPSHOT
stream create --name edgeinput --definition "http --server.port=9000 > :storestream"
stream create --name iotinput --definition "http --server.port=9001 | transformcpm > :storestream"
stream create --name storedata --definition ":storestream > filteroutbadcpm | jdbc --tableName=bananas --columns=countsPerMinute,microSieverts,bananas,unitId,timestamp --spring.datasource.driver-class-name=org.mariadb.jdbc.Driver --spring.datasource.url='jdbc:mysql://<URL>/<DB>' --spring.datasource.username=<user> --spring.datasource.password=<password>"
stream create --name alertstream --definition ":storedata.filteroutbadcpm > alertsink --slackURL=your web hook url"
cd sensorapp
java -jar target/sensorapp-0.0.1-SNAPSHOT.jar --generateSampleData=true --url=http://<your http source>