実践的な戦闘: Celery、Redis、Django を使用して同時非同期タスクを実装する

実践的な戦闘: Celery、Redis、Django を使用した同時非同期タスクの実装

はじめに:
現代の Web アプリケーション開発では、時間のかかるいくつかのタスクに使用されます。 (データ処理、電子メールの送信など) ユーザー エクスペリエンスとシステム パフォーマンスを向上させるために、これらのタスクの処理には非同期タスクがよく使用されます。この記事では、Celery、Redis、Django を使用して同時非同期タスク ソリューションを構築する方法を紹介し、具体的なコード例を示します。

1. Celery、Redis、Django の紹介:

1. Celery:
   Celery は、Python アプリケーションで広く使用されている非同期タスク キュー/メッセージ ミドルウェアです。これにより、時間のかかるタスクをメイン アプリケーションから分離して、システムのパフォーマンスを向上させる簡単な方法が提供されます。
2. Redis:
   Redis は、Celery のメッセージ ブローカーとして使用できる高性能のメモリ内データ構造ストレージ システムです。 Celery は Redis を使用してタスク メッセージを保存し、タスクの非同期実行を実現します。
3. Django:
   Django は、豊富な機能とプラグインを提供する Python ベースの Web アプリケーション開発フレームワークです。 Django の構造とパターンを活用して、非同期タスクを整理および管理し、Celery および Redis と統合できます。

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 サイトの他の関連記事を参照してください。