A template to create applications that consume from a stream.
This template consumes from a websocket stream but it can be anything, a messaging queue ( mqtt, amqp etc.), or any async generatior.
Clone the repo and
docker-compose up
And you are done.
pip install -r requirements.txt
In producer directory:
cd producer
uvicorn main:app --port 8000
In consumer/src directory:
cd consumer
cd src
streamlit run main.py