celery_config.py 643 B

123456789101112131415161718192021222324
  1. from config.settings import CFG,DB_URL,OUTPUT_DIR
  2. # celery_result_backend = 'db+' + DB_URL
  3. # Flower持久化配置
  4. FLOWER_PERSISTENT = True
  5. FLOWER_DB = str(OUTPUT_DIR / "celery" / "flower_monitor.db")
  6. broker_url = CFG.redis_url
  7. celery_result_backend = CFG.celery_reulst_url
  8. task_serializer = 'json'
  9. result_serializer = 'json'
  10. accept_content = ['json']
  11. timezone = 'Asia/Shanghai'
  12. enable_utc = True
  13. task_track_started = True
  14. task_default_queue = 'default'
  15. task_acks_late=True
  16. worker_prefetch_multiplier=1
  17. worker_concurrency=4
  18. worker_send_task_events=True
  19. worker_pool = 'solo'
  20. # worker_pool = 'eventlet'
  21. broker_connection_retry_on_startup=True