Celery、Redis、Django を使用して非同期タスク キューを実装する方法

Celery、Redis、Django を使用して非同期タスク キューを実装する方法

はじめに:
Web 開発では、長期的なタスクを処理する必要があることがよくあります。電子メールの送信、レポートの生成、大量のデータの処理など。これらのタスクをビュー関数で直接処理すると、リクエストの応答時間が長すぎて、ユーザー エクスペリエンスが低下します。システムのパフォーマンスと応答速度を向上させるために、非同期タスク キューを使用してこれらの時間のかかるタスクを処理できます。 Celery は広く使用されている Python 用の非同期タスク キュー フレームワークであり、Redis はそのデフォルトのメッセージ ミドルウェアです。この記事では、Celery、Redis、Django を使用して非同期タスク キューを実装する方法を紹介し、具体的なコード例を示します。

ステップ 1: Celery、Redis、および Django をインストールする
最初に Celery、Redis、および Django をインストールし、Django 構成ファイルで関連する構成を行う必要があります。

1. Celery のインストール: コマンド ラインで次のコマンドを実行して Celery をインストールします:

$ pip install Celery

2. Redis のインストール: Celery はデフォルトで Redis をメッセージ ミドルウェアとして使用します。 Redis をインストールし、Redis サーバーが実行されていることを確認する必要があります。
3. Django の構成: 次の構成を Django 構成ファイル (settings.py) に追加します:

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

ステップ 2: Celery タスクを作成する
次に、 Celery タスクを実行し、対応するタスク関数を定義します。たとえば、電子メールを送信するタスクを作成してみましょう。

1. Django のプロジェクト ディレクトリに task.py という名前のファイルを作成し、次のコードを追加します:

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. Django のビュー関数 Celery タスクを呼び出します:

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!')

ステップ 3: Celery ワーカーの開始
Celery は分散アーキテクチャで実行され、タスクの処理を担当する複数のワーカーが存在します。タスクキュー内のタスクを処理するには、コマンドラインで Celery ワーカーを起動する必要があります。

次のコマンドを実行してワーカーを開始します:

$ celery -A your_project_name worker -l info

注、「your_project_name」を Django プロジェクトの名前に置き換えてください。

ステップ 4: Django サーバーを実行する
Celery ワーカーを開始する前に、Django サーバーを実行する必要があります。プロジェクトのルート ディレクトリで次のコマンドを実行します。

$ python manage.py runserver

これで、ブラウザで対応する表示機能にアクセスし、Celery のログを観察してタスクの実行を確認できるようになります。

概要:
Celery、Redis、Django を使用すると、非同期タスク キューを簡単に実装できます。時間のかかるタスクをタスクキューに入れることで、システムのパフォーマンスと応答速度が大幅に向上し、ユーザーエクスペリエンスが向上します。同時に、Celery の分散アーキテクチャにより、システムの処理能力を柔軟に拡張できます。この記事が、Celery、Redis、Django を使用して非同期タスク キューを実装する方法を理解するのに役立つことを願っています。

参考リンク:

• Celery 公式ドキュメント: https://docs.celeryproject.org/en/stable/index.html
• Django 公式ドキュメント: https ://docs.djangoproject.com/

以上がCelery、Redis、Django を使用して非同期タスク キューを実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。