celery_app.py 425 B

123456789101112131415161718
  1. # -*- coding: utf-8 -*-
  2. """Celery 异步处理耗时任务"""
  3. from celery import Celery
  4. from backend.config import get_settings
  5. settings = get_settings()
  6. celery_app = Celery(
  7. "ai_teaching",
  8. broker=settings.CELERY_BROKER_URL,
  9. backend=settings.CELERY_RESULT_BACKEND,
  10. include=["backend.tasks"],
  11. )
  12. celery_app.conf.update(
  13. task_serializer="json",
  14. accept_content=["json"],
  15. result_serializer="json",
  16. )