1. Instalación de Celery
El primer paso para utilizar Celery en Python es instalarlo en tu entorno de desarrollo. Puedes hacerlo utilizando el administrador de paquetes de Python, pip. Abre tu terminal y ejecuta el siguiente comando:
pip install celery
Esto instalará Celery y todas sus dependencias necesarias.
2. Configuración de Celery
Una vez que hayas instalado Celery, necesitarás configurarlo para que funcione correctamente en tu proyecto de Python. La configuración de Celery se realiza a través de un archivo de configuración llamado celery.py. Crea este archivo en la raíz de tu proyecto y agrega la siguiente configuración básica:
from celery import Celery
app = Celery(‘myapp’, broker=’pyamqp://guest@localhost//’)
En este ejemplo, estamos creando una instancia de la clase Celery llamada ‘myapp’ y configurando el broker para que utilice el protocolo AMQP con el usuario ‘guest’ y la contraseña ‘guest’ en el host local.
3. Definición de tareas en Celery
Una vez que hayas configurado Celery, puedes comenzar a definir tareas que serán ejecutadas de forma asíncrona. Las tareas en Celery son funciones de Python decoradas con el decorador @app.task. Aquí hay un ejemplo de cómo definir una tarea en Celery:
@app.task
def add(x, y):
return x + y
En este ejemplo, estamos definiendo una tarea llamada ‘add’ que toma dos argumentos, ‘x’ e ‘y’, y devuelve la suma de los dos números.
4. Ejecución de tareas en Celery
Una vez que hayas definido tus tareas en Celery, puedes ejecutarlas utilizando el método delay(). Aquí hay un ejemplo de cómo ejecutar la tarea ‘add’ que definimos anteriormente:
result = add.delay(5, 10)
En este ejemplo, estamos ejecutando la tarea ‘add’ con los argumentos 5 y 10 y almacenando el resultado en la variable ‘result’.
5. Monitoreo y gestión de tareas en Celery
Celery proporciona una interfaz de línea de comandos llamada celery que te permite monitorear y gestionar tus tareas. Puedes utilizar comandos como celery -A myapp inspect active para ver las tareas activas, celery -A myapp inspect reserved para ver las tareas reservadas y celery -A myapp control shutdown para detener el worker de Celery.
6. Integración de Celery con otros frameworks y herramientas
Celery se puede integrar fácilmente con otros frameworks y herramientas populares de Python. Por ejemplo, puedes utilizar Celery junto con Django para ejecutar tareas asíncronas en tu aplicación web. También puedes utilizar Celery con herramientas de encolado de mensajes como RabbitMQ o Redis para gestionar colas de tareas.
Además, Celery proporciona una API que te permite personalizar y extender su funcionalidad según tus necesidades. Puedes utilizar esta API para implementar características avanzadas como la programación de tareas, la gestión de errores y la priorización de tareas.
Celery es una poderosa herramienta de Python que te permite ejecutar tareas de forma asíncrona y distribuida. Con los pasos mencionados anteriormente, puedes comenzar a utilizar Celery en tu proyecto de Python y aprovechar sus beneficios en términos de rendimiento y escalabilidad.
