Data Harvester

About

The full problem is described here. We need to deal with server sent events produced by the streaming platform.

I've decided to move on with a spring module using io.projectreactor implementation under the hood, because I wanted to end up with nice integration tests.

Usage

Run the streaming platform as explained in the last section of the corresponding document:

For Intel/AMD x64 based CPUs:

docker run -p 8080:8080 sytacdocker/video-stream-server:latest

For Arm based CPUs (Apple with M1/M2 chip):

docker run -p 8080:8080 sytacdocker/video-stream-server-arm:latest

Then run the data harvester as follows, for instance:

mvn spring-boot:run -Dspring-boot.run.arguments="sytac 4p9g-Dv7T-u8fe-iz6y-SRW2"

The aggregation result serialized in JSON will be printed to standard output.