| 1234567891011121314151617181920212223242526272829 |
- from config.settings import REDIS_URL,DB_URL
- # celery_result_backend = 'db+' + DB_URL
- # Flower持久化配置
- # FLOWER_PERSISTENT = True
- # FLOWER_DB = "flower_monitor.db"
- broker_url = REDIS_URL
- # result_backend = 'db+' + DB_URL
- task_serializer = 'json'
- result_serializer = 'json'
- accept_content = ['json']
- timezone = 'Asia/Shanghai'
- enable_utc = True
- task_track_started = True
- task_default_queue = 'default'
- task_acks_late=True
- worker_prefetch_multiplier=1
- worker_concurrency=4
- worker_send_task_events=True
- worker_pool = 'solo'
- # worker_pool = 'eventlet'
- broker_connection_retry_on_startup=True
- task_routes = {
- 'worker.celery.tasks.search_task': {'queue': 'search_queue'},
- 'worker.celery.tasks.crawl_task': {'queue': 'crawl_queue'},
- 'worker.celery.tasks.html_convert_tasks': {'queue': 'convert_queue'},
- }
|
