SensorDataProject

ECE NTUA Analysis and Design of Information Systems

Project setup

1. Run Kafka setup
2. Run IoTDB setup

Run

1. Run Flink App
2. Run Data Gen with option -k.

For debugging purposes, we can run data_gen.py with options:

• -1: all sensors values are 1.
• -k: produces to Kafka. MANDATORY FOR KAFKA.
• -d: prints generated messages on stdout.

In file data_gen.py we can modify the array sensor_threads to select which sensors produce messages.