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.txtEn primer lugar deben inicializar el ambiente de trabajo de Kafka y Zookeper.
docker-compose up -dPara 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/tcpFinalmente deben ejecutar los scripts correspondientes, por ejemplo para el grupo de reddit:
- Productor
python reddit/toad.py- Consumidor
python reddit/frog.pyLa idea es que ejecuten tanto el Productor y Consumidor al mismo tiempo y vean los outputs en cada terminal.