実践的な戦闘: Celery、Redis、Django を使用した同時非同期タスクの実装
はじめに:
現代の Web アプリケーション開発では、時間のかかるいくつかのタスクに使用されます。 (データ処理、電子メールの送信など) ユーザー エクスペリエンスとシステム パフォーマンスを向上させるために、これらのタスクの処理には非同期タスクがよく使用されます。この記事では、Celery、Redis、Django を使用して同時非同期タスク ソリューションを構築する方法を紹介し、具体的なコード例を示します。
1. Celery、Redis、Django の紹介:
2. 環境のセットアップ:
開始する前に、Python、Django、Celery、Redis がインストールされていることを確認してください。 pip コマンドを使用してインストールできます。例は次のとおりです。
pip install django pip install celery pip install redis
3. Celery と Redis を構成します。
次の構成を Django プロジェクトの構成ファイル settings.py に追加します。
# Celery配置 CELERY_BROKER_URL = 'redis://localhost:6379/0' CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' # Redis配置 CACHES = { 'default': { 'BACKEND': 'redis_cache.RedisCache', 'LOCATION': '127.0.0.1:6379', 'OPTIONS': { 'DB': 0, 'PASSWORD': '', 'PARSER_CLASS': 'redis.connection.HiredisParser' }, } }
4. 非同期タスクを作成します。
Django のアプリケーション ディレクトリに task.py ファイルを作成し、次のコードを記述します。
from celery import shared_task @shared_task def send_email(email): """ 发送邮件的异步任务 """ # 发送邮件的代码 ...
5. 非同期タスクを呼び出します。
Django の view 関数では、delay() メソッドを介して非同期タスクを呼び出します。例は次のとおりです。
from .tasks import send_email def send_email_view(request): # 获取需要发送邮件的用户邮箱 email = request.GET.get('email') # 调用异步任务 send_email.delay(email) # 返回响应 return JsonResponse({'status': 'success'})
6. Celery Worker と Beat を起動します。
プロジェクトのルート ディレクトリに次のコードを記述します。
from __future__ import absolute_import import os from celery import Celery # 设置Django环境变量 os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings') app = Celery('project') app.config_from_object('django.conf:settings', namespace='CELERY') app.autodiscover_tasks()
次に、プロジェクト ルート ディレクトリで次のコマンドを実行して、Celery Worker と Beat を起動します。
celery -A project worker --loglevel=info celery -A project beat --loglevel=info
7. 非同期タスクをテストします。
Django テスト ビュー関数を作成し、非同期タスクを呼び出してテストします。例は次のとおりです:
from .tasks import send_email def test_view(request): # 调用异步任务 send_email.delay('test@example.com') # 返回响应 return JsonResponse({'status': 'success'})
8. 概要:
この記事では、Celery、Redis、Django を使用して同時非同期を実装する方法を紹介します。タスク。 Celery と Redis を構成することで、長時間のタスクを非同期に実行して、システムのパフォーマンスとユーザー エクスペリエンスを向上させることができます。同時に、読者の参考と実践のために、具体的なコード例が示されています。このソリューションを学び、実践することで、読者は同時非同期タスクを自分のプロジェクトに無理なく適用できるようになると思います。
以上が実践的な戦闘: Celery、Redis、Django を使用して同時非同期タスクを実装するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。