Python中如何使用Django + Celery实现定时任务

Django + Celery 定时任务配置指南

要在Django里用Celery搞定时任务，得先装几个包：

pip install celery django-celery-beat redis

1. 基础配置

在settings.py里加上这些配置：

# Celery配置
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_TIMEZONE = 'Asia/Shanghai'
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'

2. 创建Celery实例

在项目目录下建个celery.py：

import os
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'your_project.settings')
app = Celery('your_project')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

然后在__init__.py里导入：

from .celery import app as celery_app
__all__ = ('celery_app',)

3. 写任务函数

在某个app的tasks.py里：

from celery import shared_task
from django.utils import timezone

@shared_task
def send_daily_report():
    print(f"每日报告发送时间：{timezone.now()}")
    # 这里写你的业务逻辑

@shared_task
def cleanup_old_data():
    print("清理过期数据任务执行")
    # 清理逻辑

4. 配置定时计划

两种方式设置计划：

方式A：代码配置（settings.py）

CELERY_BEAT_SCHEDULE = {
    'daily-report': {
        'task': 'your_app.tasks.send_daily_report',
        'schedule': 86400.0,  # 每天执行
    },
    'hourly-cleanup': {
        'task': 'your_app.tasks.cleanup_old_data',
        'schedule': 3600.0,  # 每小时
    },
}

方式B：数据库配置（推荐）

# 先迁移数据库
python manage.py migrate django_celery_beat

# 然后在代码里创建计划
from django_celery_beat.models import PeriodicTask, IntervalSchedule

# 创建间隔计划（每30分钟）
schedule, _ = IntervalSchedule.objects.get_or_create(
    every=30,
    period=IntervalSchedule.MINUTES,
)

# 创建定时任务
PeriodicTask.objects.create(
    interval=schedule,
    name='每30分钟任务',
    task='your_app.tasks.some_task',
)

5. 启动服务

开三个终端分别运行：

# 启动Redis
redis-server

# 启动Celery worker
celery -A your_project worker --loglevel=info

# 启动Celery beat（定时任务调度器）
celery -A your_project beat --loglevel=info

6. 动态管理任务

用数据库方式的话，可以在Django admin里管理任务：

# admin.py
from django.contrib import admin
from django_celery_beat.models import PeriodicTask

admin.site.register(PeriodicTask)

这样就搞定了。用数据库存储计划的好处是能在运行时修改任务，不用重启服务。记得worker和beat要一直运行着。

总结：装包、配Redis、写任务、设计划、启服务。