Celery, Redis et Django sont utilisés ensemble pour améliorer l'efficacité du traitement des tâches asynchrones-Tutoriel Python-php.cn

Celery, Redis et Django sont utilisés ensemble pour améliorer l'efficacité du traitement des tâches asynchrones

PHPz

Libérer： 2023-09-28 18:27:24

original

926 Les gens l'ont consulté

Celery, Redis et Django sont utilisés ensemble pour améliorer lefficacité du traitement des tâches asynchrones

Celery, Redis et Django sont utilisés ensemble pour améliorer l'efficacité du traitement des tâches asynchrones

Introduction : Dans le processus de développement d'applications Web, nous rencontrons souvent des tâches fastidieuses qui doivent être traitées. Si ces tâches sont exécutées directement dans le processus de traitement des demandes, l'utilisateur devra attendre trop longtemps, ce qui sera extrêmement défavorable à l'expérience utilisateur. Afin de résoudre ce problème, nous pouvons utiliser Celery, Redis et Django pour traiter des tâches chronophages de manière asynchrone, améliorant ainsi les performances du système et l'expérience utilisateur.

Introduction et installation de Celery
Celery est une file d'attente de tâches qui fonctionne sur la base d'une messagerie distribuée et prend également en charge la planification des tâches. L'installation de Celery peut être effectuée via la commande pip :
```
pip install celery
```
Copier après la connexion
Introduction et installation de Redis
Redis est une base de données open source en mémoire qui prend en charge une variété de structures de données et un large éventail de scénarios d'application. Dans notre scénario, Redis est principalement utilisé comme implémentation de stockage backend de la file d'attente des tâches. L'installation de Redis peut être complétée par les étapes suivantes :
Téléchargez Redis et décompressez-le
Entrez dans le répertoire décompressé et utilisez la commande make pour compiler
Utilisez la commande make install pour installer
Configuration de Django
Tout d'abord, vous devez définissez les paramètres du projet Django Ajoutez les éléments de configuration Celery au fichier .py, comme indiqué ci-dessous :
```
# settings.py

# Celery配置
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
```
Copier après la connexion
Dans la configuration ci-dessus, CELERY_BROKER_URL et CELERY_RESULT_BACKEND spécifiez l'adresse et port de Redis, qui sont utilisés comme tâches Backend pour les files d'attente et le stockage des résultats. CELERY_BROKER_URL和CELERY_RESULT_BACKEND指定了Redis的地址和端口，用来作为任务队列和结果存储的后端。

接下来，在项目的urls.py文件中添加Celery的配置，如下所示：

# urls.py

from django.urls import path
from .views import AsyncTaskView

urlpatterns = [
    path('async-task/', AsyncTaskView.as_view(), name='async_task'),
]

Copier après la connexion

创建任务函数
在Django的app中创建tasks.py文件，并在其中定义异步任务的函数。下面是一个示例代码：
```
# app/tasks.py

from celery import shared_task
import time

@shared_task
def process_task():
 # 模拟任务处理过程（等待5秒）
 time.sleep(5)
 return 'Task completed'
```
Copier après la connexion
在上述代码中，@shared_task装饰器用于将函数转换为Celery的任务函数。

视图实现
在Django的views.py文件中定义一个视图类，用于接收请求并调用异步任务函数。下面是一个示例代码：

# app/views.py

from django.views import View
from .tasks import process_task
from django.http import HttpResponse

class AsyncTaskView(View):
 def get(self, request):
     # 调用异步任务
     task = process_task.delay()
     return HttpResponse('Task started')

Copier après la connexion

启动Celery服务
使用以下命令来启动Celery的工作进程：
```
celery -A your_project_name worker --loglevel=info
```
Copier après la connexion
注意将your_project_name替换为你的Django项目名称。
测试
在浏览器中访问http://localhost:8000/async-task/