A basic factorial program written using an asynchronous loop to yield control to Pub/Sub listeners. This component is mainly used for doing health checks on the system.

Video Streamer

Depends on: stream-buffers, fluent-ffmpeg

This Component reads from a video source at /data/sample.mp4 and then publishes the video stream to things-videostream/raw.

Motion Detector

Depends on: jimp

This Component subscribes to the video stream at things-videostream/raw and performs image differencing on subsequent frames. It publishes the diff-images as a stream to things-videostream/motion. If the image difference is larger than a specified threshold, it will publish a message to things-videostream/alarm.

RIoT Benchmarks

The library also includes a subset of the RIoT Benchmarks ported into JavaScript. The following benchmarks are available:

  • Extraction, Transform and Load dataflow (ETL)
  • Statistical Summarization dataflow (STATS)
  • Predictive Analytics dataflow (PRED)
  • Model Training dataflow (TRAIN)

results matching ""

    No results matching ""