Cara menggunakan Celery untuk melaksanakan penjadualan tugas teragih

Cara menggunakan Celery untuk melaksanakan penjadualan tugas teragih

Gambaran keseluruhan:
Celery ialah salah satu perpustakaan baris gilir tugas teragih yang paling biasa digunakan dalam Python, yang boleh digunakan untuk melaksanakan penjadualan tugas tak segerak. Artikel ini akan memperkenalkan cara menggunakan Celery untuk melaksanakan penjadualan tugas teragih dan melampirkan contoh kod.

1. Memasang dan Mengkonfigurasi Saderi

Pertama, kita perlu memasang perpustakaan Saderi. Celery boleh dipasang melalui arahan berikut:

pip install celery

Selepas pemasangan selesai, kita perlu mencipta fail konfigurasi Celery. Cipta fail bernama celeryconfig.py dan tambah kandungan berikut: celeryconfig.py的文件，并添加以下内容：

broker_url = 'amqp://guest@localhost//'     # RabbitMQ服务器地址
result_backend = 'db+sqlite:///results.sqlite'   # 结果存储方式（使用SQLite数据库）
task_serializer = 'json'    # 任务序列化方式
result_serializer = 'json'  # 结果序列化方式
accept_content = ['json']   # 接受的内容类型
timezone = 'Asia/Shanghai'  # 时区设置

2. 创建Celery应用

在代码中，我们需要导入Celery库，并创建一个Celery应用。以下是一个示例：

from celery import Celery

app = Celery('mytasks', include=['mytasks.tasks'])
app.config_from_object('celeryconfig')

在上面的代码中，我们创建了一个名为mytasks的Celery应用，并将celeryconfig.py中的配置应用到Celery应用中。

3. 创建任务

接下来，我们需要创建一个任务。任务是一个独立的函数，可以执行单独的操作。以下是一个示例：

# tasks.py
from mytasks import app

@app.task
def add(x, y):
    return x + y

在上面的代码中，我们定义了一个名为add的任务，用于计算两个数的和。

4. 启动Celery Worker

要使任务能够分布式执行，我们需要启动一个或多个Celery Worker来处理任务。可以通过以下命令来启动Celery Worker：

celery -A mytasks worker --loglevel=info

启动完成后，Celery Worker将会监听并处理队列中的任务。

5. 提交任务

在其他代码中，我们可以提交任务到Celery队列中。以下是一个示例：

# main.py
from mytasks.tasks import add

result = add.delay(4, 6)
print(result.get())

在上面的代码中，我们导入了之前定义的add任务，然后使用delay方法提交一个任务。delay方法将会返回一个AsyncResult对象，我们可以通过调用get方法来获取任务的结果。

6. 监控任务完成状态

我们可以使用AsyncResult对象来监控任务的执行状态。以下是一个示例：

# main.py
from mytasks.tasks import add

result = add.delay(4, 6)
while not result.ready():
    print("Task is still running...")
    time.sleep(1)

print(result.get())

在上面的代码中，我们通过循环来监控任务的执行状态。readyrrreee

Buat apl Saderi




Dalam kod, kita perlu mengimport perpustakaan Saderi dan Buat aplikasi Saderi. Berikut ialah contoh: 🎜rrreee🎜 Dalam kod di atas, kami mencipta apl Saderi yang dipanggil mytasks dan menggunakan konfigurasi dalam celeryconfig.py pada aplikasi Celery In. 🎜
🎜Buat tugasan🎜🎜🎜Seterusnya, kita perlu mencipta tugasan. Tugas ialah fungsi bebas yang boleh melaksanakan operasi individu. Berikut ialah contoh: 🎜rrreee🎜Dalam kod di atas, kami mentakrifkan tugas bernama add untuk mengira jumlah dua nombor. 🎜
🎜Mulakan Pekerja Saderi🎜🎜🎜Untuk mendayakan pelaksanaan tugas yang diedarkan, kita perlu memulakan satu atau lebih Pekerja Saderi untuk memproses tugas. Pekerja Saderi boleh dimulakan dengan arahan berikut: 🎜rrreee🎜Selepas permulaan selesai, Pekerja Saderi akan mendengar dan memproses tugasan dalam baris gilir. 🎜
🎜Serahkan tugasan🎜🎜🎜Dalam kod lain, kita boleh menghantar tugasan ke baris gilir Saderi. Berikut ialah contoh: 🎜rrreee🎜Dalam kod di atas, kami mengimport tugasan tambah yang ditakrifkan sebelum ini dan kemudian menggunakan kaedah delay untuk menyerahkan tugasan. Kaedah delay akan mengembalikan objek AsyncResult Kita boleh mendapatkan hasil tugasan dengan memanggil kaedah get. 🎜
🎜Pantau status penyelesaian tugas🎜🎜🎜Kita boleh menggunakan objek AsyncResult untuk memantau status pelaksanaan tugas. Berikut ialah contoh: 🎜rrreee🎜Dalam kod di atas, kami memantau status pelaksanaan tugas melalui gelung. Kaedah sedia akan mengembalikan nilai Boolean yang menunjukkan sama ada tugasan telah selesai. 🎜🎜Ringkasan: 🎜Artikel ini memperkenalkan secara ringkas cara menggunakan Celery untuk melaksanakan penjadualan tugas teragih. Dengan memasang dan mengkonfigurasi Saderi, mencipta aplikasi Saderi, menentukan tugas, memulakan Pekerja Saderi dan menyerahkan tugas ke baris gilir, kami boleh melaksanakan penjadualan tugas teragih. Menggunakan Celery boleh meningkatkan kecekapan pelaksanaan tugas dan sesuai untuk situasi di mana pengkomputeran selari atau pemprosesan tak segerak diperlukan. 🎜

Atas ialah kandungan terperinci Cara menggunakan Celery untuk melaksanakan penjadualan tugas teragih. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!