Cara menggunakan Celery Redis Django untuk meningkatkan kecekapan pemprosesan tugas tak segerak tapak web

Cara menggunakan Celery Redis Django untuk meningkatkan kecekapan pemprosesan tugas tak segerak tapak web

Dengan perkembangan pesat Internet, kerumitan fungsi laman web juga semakin meningkat. Untuk memberikan pengalaman pengguna yang lebih baik, kami selalunya perlu mengendalikan pelbagai tugas yang memakan masa, seperti menghantar e-mel, menjana laporan, pemprosesan data perangkak, dsb. Dalam kaedah pemprosesan segerak tradisional, semua tugasan akan menyekat utas utama, menyebabkan pengguna menunggu terlalu lama atau malah tapak web ranap. Untuk menyelesaikan masalah ini, kami boleh menggunakan kombinasi Celery Redis Django untuk melaksanakan pemprosesan tugas tak segerak untuk meningkatkan kecekapan dan prestasi tapak web.

Celery ialah baris gilir tugasan teragih berdasarkan Python, yang melaksanakan pelaksanaan tugasan tak segerak melalui perisian tengah mesej (seperti Redis). Django ialah rangka kerja web Python yang berkuasa yang boleh disepadukan dengan mudah dengan Celery. Di bawah, kami akan memperkenalkan cara menggunakan Celery Redis Django untuk melaksanakan pemprosesan tugas tak segerak.

Langkah Pertama: Pasang dan Konfigurasikan Saderi dan Redis

Pertama, kita perlu memasang Saderi dan Redis. Anda boleh menggunakan arahan pip untuk memasang Celery dan Redis-py:

pip install celery
pip install redis

Seterusnya, kita perlu mengkonfigurasi maklumat sambungan Celery dan Redis dalam tetapan fail konfigurasi.py projek Django:

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

# 配置Celery Worker数量
CELERYD_CONCURRENCY = 4

Langkah 2: Buat Tugasan saderi

Di bawah Apl dalam projek Django, cipta fail tasks.py dan tulis kod untuk tugas tak segerak. Sebagai contoh, kami membuat tugasan untuk menghantar e-mel:

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)

Dalam contoh ini, kami menggunakan penghias @shared_task untuk menukar fungsi menjadi tugasan Saderi. Ambil perhatian bahawa tugas ini adalah bebas daripada sebarang permintaan Django dan boleh dipanggil di tempat lain. @shared_task装饰器将函数转换为Celery任务。注意，这个任务是独立于任何Django请求的，并且可以在其他地方调用。

第三步：启动Celery Worker

在项目的根目录下，创建一个celery.py文件，并配置Celery应用：

from __future__ import absolute_import
import os
from celery import Celery

# 设置Django默认的配置模块
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'your_project.settings')

app = Celery('your_project')

# 从Django项目的配置文件中加载Celery配置
app.config_from_object('django.conf:settings')

# 自动加载tasks.py中的任务
app.autodiscover_tasks()

完成以上配置后，我们可以通过以下命令来运行Celery Worker：

celery -A your_project worker --loglevel=info

第四步：在Django视图中调用异步任务

在Django的视图函数或类中，可以通过以下方式来调用异步任务：

from your_app.tasks import send_email_task

def send_email_view(request):
    subject = 'Hello'
    message = 'This is a test email'
    from_email = 'noreply@example.com'
    recipient_list = ['user1@example.com', 'user2@example.com']

    # 异步调用发送邮件的任务
    send_email_task.delay(subject, message, from_email, recipient_list)

    return HttpResponse('Email sent successfully!')

在这个例子中，我们使用delay()方法来异步调用发送邮件的任务。注意，delay()

Langkah 3: Mulakan Pekerja Saderi

Dalam direktori akar projek, buat fail celery.py dan konfigurasikan aplikasi Saderi:

rrreee

Selepas melengkapkan konfigurasi di atas, kita boleh menjalankan Pekerja Saderi melalui arahan berikut:

rrreee

Langkah 4: Panggil tugas tak segerak dalam paparan Django

Dalam fungsi atau kelas paparan Django, anda boleh memanggil tugas tak segerak dengan cara berikut:

rrreee
• Dalam contoh ini, kami menggunakan kaedah delay() code> untuk memanggil tugas menghantar e-mel secara tak segerak. Ambil perhatian bahawa kaedah <code>delay() tidak menyekat, ia kembali serta-merta dan melaksanakan tugas secara tidak segerak di latar belakang.
• Melalui langkah di atas, kami berjaya melaksanakan pemprosesan tugas tak segerak menggunakan Celery Redis Django. Saderi akan meletakkan tugasan ke dalam baris gilir mesej, dan Pekerja Saderi akan memproses tugasan ini secara tidak segerak, meningkatkan kecekapan pemprosesan dan prestasi tapak web.
• Ringkasan:

Menggunakan Celery Redis Django boleh meningkatkan kecekapan pemprosesan tugas tak segerak tapak web dengan berkesan. Dengan melaksanakan tugas yang memakan masa secara tidak segerak, kami boleh mengelak daripada menyekat utas utama dan mempercepatkan kelajuan respons tapak web. Semasa mengkonfigurasi dan menulis tugas, anda perlu memberi perhatian kepada konfigurasi dan kaedah panggilan yang berkaitan dengan Celery. Pada masa yang sama, untuk meningkatkan prestasi, bilangan Pekerja Saderi serentak boleh dilaraskan dengan sewajarnya. 🎜🎜Contoh kod boleh merujuk kepada dokumen rasmi berikut: 🎜🎜🎜Dokumen rasmi saderi: http://docs.celeryproject.org/en/latest/ 🎜🎜Django dokumen rasmi: https://docs.djangoproject.com/🎜 🎜Redis -py dokumentasi rasmi: https://redis-py.readthedocs.io/🎜🎜

Atas ialah kandungan terperinci Cara menggunakan Celery Redis Django untuk meningkatkan kecekapan pemprosesan tugas tak segerak tapak web. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!