Files
diary-family/diary_family/celery.py

20 lines
521 B
Python
Raw Normal View History

2026-01-04 19:17:33 +08:00
import os
from celery import Celery
from django.conf import settings
# 设置默认的Django设置模块
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'diary_family.settings')
# 创建Celery应用实例
app = Celery('diary_family')
# 从Django设置中读取配置
app.config_from_object('django.conf:settings', namespace='CELERY')
# 自动发现任务
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
@app.task(bind=True)
def debug_task(self):
"""调试任务"""
print(f'Request: {self.request!r}')