- aiokafka - Asynchronous Kafka Streaming
- asyncio - Asynchronous Python Threading
- aiomysl
- cassandra-driver - Cassandra Connector/Sink
- aiocassandra - Asynchronous Cassandra Writing
The following are screenshots for the app in this repo.
Main Dashboard & Callback Graph Navigation:
Alert Table:
Sensor Reading Map:
Filtering the Map:
Heart Rate, Body Temperature and Bloog Sugar Graphs:
Blood Pressure Graphs:
All Patient Stats:
To view diagrams and schematics for the project please view this link: https://github.com/JoseliaReis/Realtime_HealthCare_Analytics/tree/master/diagrams
$ sudo curl -L "https://github.com/docker/compose/releases/download/1.26.2/docker-compose-$(uname -s)-$(uname -m)" -o /usr/local/bin/docker-compose
$ sudo chmod +x /usr/local/bin/docker-compose
$ docker–compose -–version
$ ./deploy.sh
$ ./destory.sh
$ docker network create healthcare_pipeline
$ docker-compose -f docker-compose-kafka.yaml up -d --remove-orphans
$ docker-compose -f docker-compose-kafka.yaml logs -f broker | grep "started"
$ docker-compose -f docker-compose-cassandra.yaml up -d --remove-orphans
$ docker-compose up --build
$ docker-compose -f docker-compose-kafka.yaml exec broker kafka-console-consumer --bootstrap-server localhost:9092 --topic queueing.healthcare --from-beginning
$ docker exec -it cassandra cqlsh localhost 9042
cqlsh> use healthcare_db;
cqlsh:healthcare_db> select * from healthcare_db.device_patient;
id | content | type ----+---------+------
(0 rows)
cqlsh:healthcare_db> exit
$ docker-compose down --remove-orphans
$ docker-compose -f docker-compose-kafka.yaml stop
$ docker-compose -f docker-compose-kafka.yaml down
$ docker-compose -f docker-compose-cassandra.yaml down $ docker rm container cassandra
$ docker network rm healthcare_pipeline