Description
Currently, our FastAPI gateway validates incoming IoT payloads and pushes them to a Redis queue. However, the data just sits there. We need to implement the asynchronous Python worker (worker.py) that pops valid sensor measurements off the Redis queue and safely batches them into our PostGIS database.
Task List
Description
Currently, our FastAPI gateway validates incoming IoT payloads and pushes them to a Redis queue. However, the data just sits there. We need to implement the asynchronous Python worker (
worker.py) that pops valid sensor measurements off the Redis queue and safely batches them into our PostGIS database.Task List