分布式框架Celery七(Django-Celery-Flower实现异步和定时爬虫及其监控邮件告警)

# 导入必要的模块
from celery import Celery
from celery.schedules import crontab
from django.conf import settings
 
# 创建Celery实例
app = Celery('my_project')
 
# 配置Celery
app.config_from_object('django.conf:settings', namespace='CELERY')
 
# 自动发现任务
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
 
# 设置定时任务
app.conf.beat_schedule = {
    'add-every-minute': {
        'task': 'my_project.tasks.add',
        'schedule': 60.0,
        'args': (16, 16)
    },
}
 
# 在my_project/tasks.py中定义任务
# from celery import shared_task
#
# @shared_task
# def add(x, y):
#     return x + y

这段代码演示了如何在Django项目中集成Celery，并设置定时任务。首先导入Celery模块，然后创建一个Celery实例并配置它。最后，自动发现任务并设置一个定时任务示例。这个例子简洁明了，并且教育意义十足，可以作为Celery学习的入门示例。