RabbitMQ permite gestionar colas de mensajes entre emisores y destinatarios, en el siguiente post vamos a utilizar en python Pika para su implementación.
Introducción: ¿Que es RabbitMQ?
RabbitMQ es un intermediario que envia mensajes 📩 entre un productor y un consumidor por medio de la utilización de una cola.
Los principales conceptos que se deben tener en cuenta son:
- Productor: Es el que envía mensajes.
- Cola: Es el buffer en donde se almacenan los mensajes.
- Consumidor: El que recibe los mensajes.
Implementación
Para la implementación en `Python 🐍 utilizaremos pika y vamos a desarrollar dos programas: productor y consumidor.
Pika tiene un set de objetos para la comunicación con RabbitMQ.
En nuestro ejemplo vamos a imaginar que un productor es un app que tiene como objetivo tomar pedidos de delivery 🛵de comida, la misma necesita enviar multiples mensajes📝 relacionados a los pedidos que realizar usuarios 📱.
Por lo cual vamos a realizar los siguientes pasos...
1. Instalar pika
!pip install pika
2. Generar el script send.py 📄
3. Generar el script receive.py 📄
Mongodb + Pika
A continuación vamos a modificar el script para que pueda conectarse a un mongodb atlas y realice el insert de los mensajes recibidos.
Para descargar el código de estos dos archivos puedes hacerlo desde el siguiente link
Para conocer más de Rabbitmq puedes ver los siguientes sitios:
📄 Documentación Oficial con el Tutorial
🐍 Pika
已为社区贡献126483条内容
所有评论(0)