celery_config.py 787 B

1234567891011121314151617181920212223242526
  1. # Redis 作为 Broker 和 Backend
  2. BROKER_URL = 'redis://:Wqsd@2019@r-bp1ps6my7lzg8rdhwx682.redis.rds.aliyuncs.com:6379/0'
  3. RESULT_BACKEND = 'redis://:Wqsd@2019@r-bp1ps6my7lzg8rdhwx682.redis.rds.aliyuncs.com:6379/1'
  4. # Celery 配置
  5. CELERY_CONFIG = {
  6. 'broker_url': BROKER_URL,
  7. 'result_backend': RESULT_BACKEND,
  8. 'task_serializer': 'json',
  9. 'result_serializer': 'json',
  10. 'accept_content': ['json'],
  11. 'timezone': 'Asia/Shanghai',
  12. 'enable_utc': True,
  13. 'imports': ['celery_tasks'],
  14. 'task_routes': {
  15. 'celery_tasks.*': {"queue": "dev"},
  16. },
  17. 'beat_schedule': {
  18. 'run-sample-task-every-10-seconds': {
  19. 'task': 'celery_tasks.test_task',
  20. 'schedule': 10.0,
  21. 'args': (),
  22. 'kwargs': {}
  23. },
  24. }
  25. }