Cómo usar Redis con apio

Esta guía simple cubrirá los huesos de implementación de apio con Python.

Requisitos

Instale la última versión de Python 3 y Redis Server.

Conocimientos básicos en Redis y Python.

Instalación

Para usar el apio con Redis, debe instalar dependencias. Podemos hacer esto instalando el paquete Redis como se muestra en el comando a continuación:

$ PIP3 Install -U Celery [Redis]

Configurar el apio

El siguiente paso es crear un archivo que mantenga el código fuente para nuestra aplicación. Puede nombrar el archivo con cualquier término o etiqueta que vea en forma.

$ Mkdir Redis-Celery
$ CD Redis-Celery

Crea el archivo de origen.

$ touch main.py

Edite el archivo con su editor de texto y agregue el código.

de Celery Import Celery
Broker_url = "redis: //: contraseñ[email protected]: 6379/0 "
app = CELERY ('Main', Broker_url)
@App.principal
Def lo máximo (x, y):
Si x> y:
regreso x
demás:
regresar y

En el código que se muestra arriba, comience importando los módulos requeridos.

A continuación, establecemos el Broker_Url que contiene la URL en la base de datos de Redis.

La URL sigue el formato que se muestra a continuación:

redis: //: contraseña@host: puerto/db_index

Luego, creamos una instancia de la clase de apio y pasamos el módulo actual y la URL como parámetros.

También creamos una función simple que devuelve un máximo de dos números.

Ejecutar el trabajador como:

$ Python3 -M Celery -A Información principal del trabajador principal

Tarea de llamadas

Llame a la tarea utilizando el método de retraso como:

del máximo de importación principal
agregar.retraso (100,30)

Ejecución de la tarea Devuelve un resultado asincrónico que puede usar para verificar el estado de la tarea o obtener el resultado.

Conclusión

Este breve artículo ilustra cómo usar el proyecto de apio con Redis cubriendo los hechos básicos de implementar el apio con Python. Consulte los documentos para obtener artículos y tutoriales más impresionantes y fáciles.