django celery简单 例子

# 首先安装celery和redis依赖
# pip install celery redis
 
# 在你的Django项目的目录中创建一个名为celery.py的文件
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
 
# 设置Django的环境
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'your_project_name.settings')
 
# 创建Celery应用
app = Celery('your_project_name')
 
# 配置Celery以使用Django设置，并指定消息代理
app.config_from_object('django.conf:settings', namespace='CELERY')
 
# 自动从所有已安装的Django应用程序中发现任务
app.autodiscover_tasks()
 
# 你的Django应用中的tasks.py文件
from your_app.models import YourModel
 
@app.task
def sample_task():
    # 示例任务，查询并打印YourModel的对象数量
    count = YourModel.objects.count()
    print(f"Number of objects: {count}")
    return count
 
# 使用这个任务的视图或其他部分
# from your_app.tasks import sample_task
# sample_task.delay()

这个例子展示了如何在Django项目中设置和使用Celery进行异步任务。首先，你需要安装celery和redis（作为消息代理）的依赖。然后，在Django项目的根目录中创建一个名为celery.py的文件，配置Celery实例并指定它使用Django设置。最后，你可以定义自己的异步任务并使用它们。