Python Web Stream Processing

I’m building a Python-powered web application focused on data processing—specifically stream data processing—and I need your help to get the first working version online.

What I need
• A server-side component in Python that accepts a live data stream, performs on-the-fly transformations (filtering, aggregation, enrichment, etc.), and publishes the processed results immediately. I’m comfortable with FastAPI, Flask, or Django Channels as long as the final code is clean and documented.
• A lightweight browser client that connects over WebSocket (or comparable real-time transport), receives the processed events, and displays them—raw JSON is fine for now, but a minimal chart or table helps confirm everything is flowing.
• Clear separation between ingestion, processing, and broadcasting layers so I can swap in production sources later (Kafka, MQTT, or another broker).
• Containerisation with a Dockerfile plus a concise README so I can spin the whole stack up quickly.
• Unit tests covering the main processing functions and a sample script that fires 100 events per second to demonstrate end-to-end latency below 200 ms.

Deliverables
1. Python server code with real-time processing pipeline.
2. Simple HTML/JS client to visualise live output.
3. Dockerfile, README, and test suite.
4. Git repository hand-over.

If you’ve built real-time data pipelines or WebSocket services in Python before, I’d love to see a quick note on your chosen framework and any similar projects.