我想在我的Django应用程序中每周发送电子邮件。从数据库中提取数据并发送电子邮件消息的代码应该放在哪里？

pip install celery

# Celery配置
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_TIMEZONE = 'Asia/Shanghai'

from django.core.mail import send_mail
from django.core import serializers
from .models import YourModel

@app.task
def send_email_from_database():
    # 从数据库中获取数据
    data = YourModel.objects.all()
    
    # 处理数据并发送电子邮件
    for obj in data:
        # 构造邮件内容
        message = f"Hello {obj.name}, this is your email message."
        
        # 发送电子邮件
        send_mail(
            'Subject',
            message,
            'from@example.com',
            [obj.email],
            fail_silently=False,
        )

from celery.schedules import crontab
from .tasks import send_email_from_database

app.conf.beat_schedule = {
    'send_email_every_week': {
        'task': 'app.tasks.send_email_from_database',
        'schedule': crontab(day_of_week=1, hour=0, minute=0),  # 每周一 00:00 执行
    },
}

celery -A your_project_name worker --loglevel=info
celery -A your_project_name beat --loglevel=info