DEBS 2014 Grand Challenge - YoMo Implementation

This repository accompanies our blog post "DEBS Grand Challenge: Real-Time Stream Processing with YoMo."

Introduction

DEBS or the ACM International Conference on Distributed Event Based Systems aims to "provide a forum dedicated to the dissemination of original research, the discussion of practical insights, and the reporting of experiences relevant to event based computing that were previously scattered across several scientific and professional communities" (reference).

The DEBS 2014 Grand Challenge - Smart Grid is the 8th ACM International Conference on Distributed Event Based Systems. It focused on two problems which are relevant to the industry: real-time load prediction and anomaly detection. The data for the challenge was collected from a number of smart-home installations deployed in Germany.

System Architecture

With YoMo, we can build a real-time stream processing system like the following:

Getting Started

1. Install yomo CLI: go install -v github.com/yomorun/yomo/cmd/yomo@latest && yomo --version.
2. Clone this repository by typing git clone git@github.com:yomorun/debs-2014.git && cd debs-2014.
3. Start yomo-zipper: yomo wf run workflow.yaml
4. Start streaming function load-prediction: go run cmd/stream-fn-realtime-load-prediction/load-prediction.go
5. Start mock data-source to generate IoT data: go run cmd/mock-data-source/mock-data.go
6. Start streaming function outliers: go run cmd/stream-fn-realtime-outliers/outliers.go

You should be able to see some exciting results! :)

Join Our Community

If you have any questions, let us know! We hope to see you around.

• yomorun/yomo
• Discord