精选开源:Django-Celery —— 让任务调度更丝滑
# 导入Django设置模块
from django.conf import settings
# 初始化Celery实例,确保DJANGO_SETTINGS_MODULE环境变量已设置
app = Celery('my_project')
# 配置Celery,确保它知道在哪里找到Django的配置
app.config_from_object('django.conf:settings', namespace='CELERY')
# 自动发现Celery任务模块,确保它们被自动导入到任务列表中
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
# 使用Celery提供的装饰器来标记任务函数
@app.task
def add(x, y):
return x + y
这段代码演示了如何在Django项目中初始化Celery,并配置它以便它可以发现和执行任务。add
函数是一个简单的Celery任务示例,它可以在Django的任何地方被调用,并且可以异步执行。这种模式是使用Celery进行异步任务处理的基础。
评论已关闭