Para la ejecución de scripts es necesario tener instalado:
- Python 3.X
- Docker
- Docker-compose
Nota: Se recomienda utilizar algún entorno virtual (conda o virtualenv) para instalar librerías mediante pip
.
Luego se debe instalar las librerías a utilizar,
git clone https://github.com/JavierArredondo/INFO-USACH-13228-AY.git
cd INFO-USACH-13228-AY/
pip install -r requirements.txt
En primer lugar deben inicializar el ambiente de trabajo de Kafka y Zookeper.
docker-compose up -d
Para verificar que los servicios están ejecutándose:
docker-compose ps
Name Command State Ports
-----------------------------------------------------------------------------------------------------------------
info-usach-13228-ay_kafka_1 /opt/bitnami/scripts/kafka ... Up 0.0.0.0:9092->9092/tcp
info-usach-13228-ay_zookeeper_1 /opt/bitnami/scripts/zooke ... Up 2181/tcp, 2888/tcp, 3888/tcp, 8080/tcp
Finalmente deben ejecutar los scripts correspondientes, por ejemplo para el grupo de reddit:
- Productor
python reddit/toad.py
- Consumidor
python reddit/frog.py
La idea es que ejecuten tanto el Productor y Consumidor al mismo tiempo y vean los outputs en cada terminal.