Django 和 Celery - 更改后将代码重新加载到 Celery 中

使用Django和Celery的组合可以实现异步任务的处理，提高应用程序的性能和可伸缩性。在开发过程中，我们可能需要对Celery中的代码进行修改，并且希望能够快速地将更改后的代码重新加载到Celery中。本文将介绍如何实现这一目标，并提供相应的案例代码。

myproject/
    manage.py
    myapp/
        __init__.py
        tasks.py

python
from celery import shared_task
@shared_task
def add(x, y):
    return x + y

celery -A myproject worker --autoreload

celery -A myproject worker --autoreload

python
from celery import shared_task
from django.core.mail import send_mail
@shared_task
def send_email(subject, message, from_email, recipient_list):
    send_mail(subject, message, from_email, recipient_list)

python
from celery import shared_task
import time
@shared_task
def long_running_task():
    print("Start long running task...")
    time.sleep(10)
    print("Long running task completed.")

celery -A myproject worker --autoreload