Gunakan Celery Redis Django untuk mencipta platform pemprosesan tugas tak segerak yang sangat tersedia

Gunakan Celery Redis Django untuk mencipta platform pemprosesan tugas tak segerak dengan ketersediaan tinggi

Ikhtisar
Dengan perkembangan pesat Internet dan kerumitan sistem aplikasi, permintaan untuk pemprosesan tugas tak segerak juga semakin tinggi dan lebih tinggi. Saderi ialah rangka kerja baris gilir tugas teragih yang berkuasa yang menyediakan cara yang mudah digunakan untuk mengendalikan tugas tak segerak. Redis ialah sistem storan data dalam memori berprestasi tinggi yang digunakan secara meluas dalam cache, baris gilir dan senario lain. Django ialah rangka kerja aplikasi web yang cekap dengan fungsi yang kaya dan kebolehskalaan yang baik. Artikel ini akan memperkenalkan cara menggunakan Celery Redis Django untuk membina platform pemprosesan tugas tak segerak yang sangat tersedia dan menyediakan contoh kod khusus.

Pasang dan konfigurasikan Celery dan Redis
Pertama, kita perlu memasang Celery dan Redis. Dalam persekitaran maya Python, gunakan arahan berikut untuk memasang:

pip install celery
pip install redis

Selepas pemasangan selesai, kita perlu melakukan beberapa konfigurasi yang berkaitan. Mula-mula, tambahkan konfigurasi berikut pada fail settings.py Django:

# Celery配置
CELERY_BROKER_URL = 'redis://localhost:6379/0'  # Redis的地址
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

Seterusnya, buat fail bernama celery.py dan tambahkan maklumat konfigurasi berkaitan Celery pada fail:

from celery import Celery
import os

# 设置Django环境变量
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'your_django_project.settings')

# 实例化Celery
app = Celery('your_django_project')

# 加载Django配置
app.config_from_object('django.conf:settings', namespace='CELERY')

# 自动发现异步任务
app.autodiscover_tasks()

Dengan cara ini, kami selesai Pemasangan dan konfigurasi Saderi dan Redis.

Buat tugas tak segerak
Seterusnya, kita perlu mencipta tugas tak segerak. Dalam aplikasi Django, cipta fail tasks.py dan laksanakan tugas tak segerak:

from celery import shared_task

# 定义异步任务
@shared_task
def process_task(file_path):
    # 任务逻辑代码
    # 处理文件
    with open(file_path, 'r') as file:
        content = file.read()
        # 具体的处理逻辑
        ...

Dalam tugasan ini, kami mentakrifkan fungsi process_task, menerima laluan fail sebagai parameter dan melaksanakan logik tugasan tertentu.

Panggil tugas tak segerak
Di mana kita perlu memanggil tugas tak segerak, kita hanya perlu memanggil fungsi process_task dan hantar parameter kepadanya:

from your_django_project.tasks import process_task

...

# 调用异步任务
result = process_task.delay(file_path)

Kod di atas melaksanakan tugas tak segerak dengan memanggil kaedah kelewatan, menghantar laluan fail sebagai parameter.

Memantau status dan keputusan tugasan
Seterusnya, kita perlu memantau dan mendapatkan status dan hasil tugasan. Dalam Django, kita boleh mencipta pandangan untuk melaksanakan fungsi ini:

from your_django_project.tasks import app

...

# 获取任务状态和结果
def get_task_status(request, task_id):
    task = app.AsyncResult(task_id)
    response_data = {
        "status": task.status,
        "result": task.result
    }
    return JsonResponse(response_data)

Dalam kod di atas, kita mendapat status dan hasil tugas dengan memanggil kaedah AsyncResult, dan merangkumnya sebagai respons format JSON dan mengembalikannya ke hadapan tamat.

Mulakan pekerja Saderi
Akhir sekali, kita perlu memulakan pekerja Saderi untuk mengendalikan tugasan tak segerak. Dalam direktori akar, laksanakan arahan berikut:

celery -A your_django_project worker --loglevel=info

Dengan cara ini, kami telah menyelesaikan keseluruhan proses menggunakan Celery Redis Django untuk membina platform pemprosesan tugas tak segerak dengan ketersediaan tinggi.

Ringkasan
Artikel ini memperkenalkan cara menggunakan Celery Redis Django untuk membina platform pemprosesan tugas tak segerak yang sangat tersedia, dan menyediakan contoh kod khusus. Dengan cara ini, kami boleh mengendalikan pelbagai tugas tak segerak dengan mudah dan meningkatkan kelajuan tindak balas dan kebolehpercayaan sistem. Saya harap artikel ini dapat memberikan sedikit bantuan kepada semua orang dalam membina platform pemprosesan tugas tak segerak.

Atas ialah kandungan terperinci Gunakan Celery Redis Django untuk mencipta platform pemprosesan tugas tak segerak yang sangat tersedia. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!