Stream - Cola de tareas - Python
Aquí tienes un ejemplo más detallado de cómo utilizar Redis Streams para simular un sistema de cola de tareas, donde se añaden tareas a un Stream y luego son procesadas por diferentes consumidores: Ejemplo: Cola de Tareas con Redis Streams 1. Configuración: Instalación: Asegúrate de tener Redis instalado y funcionando. Cliente Redis: Utiliza un cliente Redis como redis-py para Python o redis para Node. js. 2. Creación del Stream: Python import redis r = redis.Redis(host= 'localhost' , port= 6379 , db= 0 ) # Crear un Stream llamado 'task_queue' r.xgroup_create( 'task_queue' , 'group1' , 0 ) Esto crea un Stream llamado task_queue y un grupo de consumidores llamado group1 . 3. Añadir Tareas: Python def add_task ( task_data ): r.xadd( 'task_queue' , task_data) # Ejemplo de añadir una tarea add_task({ 'task' : 'enviar_email' , 'to' : 'ejemplo@ejemplo.com' , 'subject' : 'Asunto' }) La fu...