Ce guide simple couvrira les os nus de la mise en œuvre du céleri avec Python.
Exigences
Installez la dernière version de Python 3 et Redis Server.
Connaissances de base dans Redis et Python.
Installation
Pour utiliser le céleri avec redis, vous devez installer des dépendances. Nous pouvons le faire en installant le bundle Redis comme indiqué dans la commande ci-dessous:
$ pip3 install -u Celeri [redis]
Configurer le céleri
L'étape suivante consiste à créer un fichier qui conservera le code source de notre application. Vous pouvez nommer le fichier avec n'importe quel terme ou étiquette que vous voyez.
$ mkdir redis-celery
$ CD Redis-celery
Créer le fichier source.
$ Touch Main.py
Modifiez le fichier avec votre éditeur de texte et ajoutez le code.
de Celey Import Celeri
Courtier_url = "redis: //: mot de passe @ 127.0.0.1: 6379/0 "
app = Cery ('Main', Broker_Url)
@app.principal
Def maximum (x, y):
Si x> y:
retour x
autre:
retour y
Dans le code indiqué ci-dessus, commencez par importer les modules requis.
Ensuite, nous définissons le courtier_url qui contient l'URL à la base de données redis.
L'URL suit le format illustré ci-dessous:
redis: //: mot de passe @ hôte: port / db_index
Ensuite, nous créons une instance de la classe de céleri et passons le module actuel et l'URL comme paramètres.
Nous créons également une fonction simple qui renvoie un maximum de deux nombres.
Exécutez le travailleur comme:
$ python3 -m céleri -a travailleur principal -l infos
Tâche d'appel
Appelez la tâche en utilisant la méthode de retard comme:
à partir du maximum d'importation principale
ajouter.retard (100,30)
L'exécution de la tâche renvoie un résultat asynchrone que vous pouvez utiliser pour vérifier l'état de la tâche ou obtenir le résultat.
Conclusion
Ce court article illustre comment utiliser le projet de céleri avec Redis en couvrant les faits de base de la mise en œuvre du céleri avec Python. Consultez les documents pour des articles et tutoriels de guide plus impressionnants et plus faciles.