sepet

An example system simulating some thermometers sending temperature metrics. It is also possible to query these statistics for a given timespan.

Info

• Project contains two parts. Collector is responsible for collecting temperature metrics. Server is responsible for persisting and aggregating metrics. Spring Boot used for both of them.
• Collector collects readings and publishes readings to Redis. Collector collects reading with gRPC streaming.
• Server subscribes that topic and persists them to the database. TimescaleDB used for persistence. It is a time series database built on PostgreSQL.
• For querying temperature metrics Swagger UI is available at localhost:8081/swagger-ui.html. localhost:8081/query accepts time range and machine-ids and returns map of machine-id and statistics. localhost:8081/query/machine-id returns existing machine-ids in database.
• There is a simple simulator for thermometer data. It accepts parameters -n -h -p. n is the number of simulators, h is host and p is port of Collector. It uses sine function to generate temperature. Default configuration spans 50 simulators.
• There is no security or machine-id/reading validation implemented.

Requirements

• Docker > 18.0.0
• Docker Compose > 1.23.0

Used Technologies

• Docker
• Docker Compose
• Java 15
• Spring Boot 2
• Spring Webflux
• Redis
• gRPC
• TimescaleDB

How To Run

Go to root folder and run build.sh. It compiles applications, creates docker images and runs.

What is sepet?

Turkish word for basket. Better than gRPC-SpringBoot-RedisPubSub-TimescaleDB-Example.