This project deploys a lean, secure, and production-minded pipeline for detecting water leaks (e.g., a continuously running toilet) using short audio snippets analyzed by a pre-deployed SageMaker inference endpoint.
- Edge device (Pi/PC/Phone) records a 1–2s audio snippet when a trigger fires (timer, sound level, manual), base64-encodes it, and sends a JSON payload to Kinesis Data Streams.
- Lambda consumer reads Kinesis records, calls your SageMaker endpoint with the audio, and parses the model’s response.
- If the model predicts your alert label (default:
toilet) with confidence ≥ threshold (default:0.5), Lambda publishes a JSON alert to SNS. - SQS subscribes to the topic so a Streamlit dashboard (or any worker) can read alerts reliably.