Comment implémenter une file d'attente de tâches asynchrone à l'aide de Celery, Redis et Django

Comment implémenter une file d'attente de tâches asynchrone à l'aide de Celery, Redis et Django

Introduction :
Dans le développement Web, nous devons souvent gérer certaines tâches à long terme, telles que l'envoi d'e-mails, la génération de rapports, le traitement de grandes quantités de données, etc. Si ces tâches sont gérées directement dans la fonction d'affichage, le temps de réponse aux requêtes sera trop long et l'expérience utilisateur sera mauvaise. Afin d'améliorer les performances et la vitesse de réponse du système, nous pouvons utiliser des files d'attente de tâches asynchrones pour gérer ces tâches chronophages. Celery est un framework de file d'attente de tâches asynchrone largement utilisé pour Python, et Redis est son middleware de messages par défaut. Cet article expliquera comment utiliser Celery, Redis et Django pour implémenter des files d'attente de tâches asynchrones et fournira des exemples de code spécifiques.

Étape 1 : Installer Celery, Redis et Django
Nous devons d'abord installer Celery, Redis et Django, et effectuer les configurations pertinentes dans le fichier de configuration de Django.

1. Installer Celery : Exécutez la commande suivante dans la ligne de commande pour installer Celery :

$ pip install Celery

2. Installer Redis : Celery utilise Redis comme middleware de message par défaut, nous devons installer Redis et nous assurer que le serveur Redis est en cours d'exécution.
3. Configurer Django : ajoutez la configuration suivante au fichier de configuration de Django (settings.py) :

# 使用Redis作为消息中间件
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

Étape 2 : Créer une tâche Céleri
Ensuite, nous devons créer une tâche Céleri et définir la fonction de tâche correspondante. Par exemple, créons une tâche pour envoyer des e-mails.

1. Créez un fichier nommé tâches.py dans le répertoire du projet Django et ajoutez le code suivant :

from celery import shared_task
from django.core.mail import send_mail

@shared_task
def send_email_task(subject, message, from_email, recipient_list):
    send_mail(subject, message, from_email, recipient_list)

2. Appelez la tâche Celery dans la fonction d'affichage de Django :

from .tasks import send_email_task

def send_email_view(request):
    # 获取邮件的相关参数
    subject = 'Test Email'
    message = 'This is a test email.'
    from_email = 'sender@example.com'
    recipient_list = ['recipient@example.com']
    
    # 调用Celery任务
    send_email_task.delay(subject, message, from_email, recipient_list)
    
    return HttpResponse('Email sent!')

Étape 3 : Démarrez le travailleur Celery
Celery s'exécute dans une architecture distribuée, où plusieurs travailleurs sont responsables du traitement des tâches. Nous devons démarrer les travailleurs Celery dans la ligne de commande pour traiter les tâches dans la file d'attente des tâches.

Exécutez la commande suivante pour démarrer le travailleur :

$ celery -A your_project_name worker -l info

Remarque, remplacez "votre_nom_projet" par le nom de votre projet Django.

Étape 4 : Exécuter le serveur Django
Avant de démarrer le travailleur Celery, nous devons exécuter le serveur Django. Exécutez la commande suivante dans le répertoire racine du projet :

$ python manage.py runserver

Vous pouvez désormais accéder à la fonction d'affichage correspondante dans le navigateur et observer le journal de Celery pour voir l'exécution de la tâche.

Résumé :
En utilisant Celery, Redis et Django, nous pouvons facilement implémenter des files d'attente de tâches asynchrones. En plaçant les tâches fastidieuses dans la file d'attente des tâches, nous pouvons considérablement améliorer les performances et la vitesse de réponse du système et améliorer l'expérience utilisateur. Dans le même temps, l’architecture distribuée de Celery nous permet d’étendre de manière flexible les capacités de traitement du système. J'espère que cet article vous aidera à comprendre comment implémenter des files d'attente de tâches asynchrones à l'aide de Celery, Redis et Django.

Liens de référence :

• Documentation officielle de Celery : https://docs.celeryproject.org/en/stable/index.html
• Documentation officielle de Django : https://docs.djangoproject.com/

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!