Gabungan sempurna: Gunakan Celery Redis Django untuk mengendalikan tugas tak segerak berkonkurensi tinggi

Kombinasi Sempurna: Menggunakan Celery Redis Django untuk mengendalikan tugas tak segerak serentak tinggi

Pengenalan: #🎜

Celery ialah perpustakaan gilir tugas/gilir kerja tak segerak berdasarkan pemesejan yang diedarkan, yang membolehkan pembangun mengagihkan tugas dengan mudah kepada sistem yang diedarkan. Ia adalah alat berkuasa yang sering digunakan oleh pembangun Python untuk mengendalikan sejumlah besar tugas serentak.

Redis ialah sistem storan struktur data dalam memori sumber terbuka. Ia menyimpan data dalam bentuk pasangan nilai kunci dan menyokong pelbagai jenis data seperti rentetan, senarai, set, dll. Redis juga mempunyai prestasi baca dan tulis berkelajuan tinggi serta ketersediaan yang tinggi, yang menjadikannya sesuai untuk mengendalikan tugasan berkonkurensi tinggi.

Django ialah rangka kerja web Python untuk membina aplikasi web. Ia menyediakan cara yang mudah, fleksibel dan cekap untuk mengendalikan tugas pembangunan web. Modul tugas tak segerak Django boleh disepadukan dengan lancar dengan Celery dan Redis untuk mencapai pemprosesan tugas yang cekap.

Berikut ialah contoh kod yang menunjukkan cara menggunakan Celery, Redis dan Django untuk mengendalikan tugas tak segerak serentak tinggi.

pip install Celery Redis Django

# settings.py

# Celery配置
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

# tasks.py

from celery import shared_task

@shared_task
def send_email_task(email):
    # 发送电子邮件的代码
    # ...
    return 'Email sent successfully'

@shared_task
def process_data_task(data):
    # 处理数据的代码
    # ...
    return 'Data processed successfully'

接下来，我们可以创建一个tasks.py文件，其中包含异步任务的定义：

celery -A project worker --loglevel=info

在使用Celery处理异步任务之前，我们需要运行Celery worker进程。在命令行中执行以下命令：

# views.py

from django.shortcuts import render
from .tasks import send_email_task, process_data_task

def send_email_view(request):
    email = request.GET.get('email')
    send_email_task.delay(email)
    return render(request, 'success.html')

def process_data_view(request):
    data = request.GET.get('data')
    process_data_task.delay(data)
    return render(request, 'success.html')

最后，在Django视图中，我们可以调用异步任务：

以上示例代码中，send_email_view和process_data_viewSeterusnya, kita boleh mencipta fail tasks.py yang mengandungi takrifan tugas tak segerak:

Menggunakan Saderi untuk memproses tak segerak tugasan Sebelum ini, kita perlu menjalankan proses pekerja Saderi. Jalankan arahan berikut dalam baris arahan:

Akhir sekali, dalam paparan Django, kita boleh memanggil tugas tak segerak:

Atas ialah kandungan terperinci Gabungan sempurna: Gunakan Celery Redis Django untuk mengendalikan tugas tak segerak berkonkurensi tinggi. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!