add celery

apps/core/tasks.py

@@ -3,7 +3,10 @@ import os
 from .models import Video
 from .s3_uploader import upload_file
 
+from cp_video.celery import app
 
+
+@app.task(soft_time_limit=60)
 def send_video_to_s3():
     local_videos = Video.objects.filter(local_file__isnull=False)
 

cp_video/__init__.py

+from .celery import app as celery_app
+
+__all__ = ['celery_app']

cp_video/celery.py

+import os
+
+from celery import Celery
+from celery.schedules import crontab
+from celery.signals import after_setup_logger
+
+# set the default Django settings module for the 'celery' program.
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'cp_video.settings.local')
+
+app = Celery('cp_video')
+
+# Using a string here means the worker don't have to serialize
+# the configuration object to child processes.
+# - namespace='CELERY' means all celery-related configuration keys
+#   should have a `CELERY_` prefix.
+app.config_from_object('django.conf:settings', namespace='CELERY')
+
+# Erase all messages from all known task queues.
+app.control.purge()
+
+# Load task modules from all registered Django app configs.
+app.autodiscover_tasks()
+
+
+app.conf.beat_schedule = {
+    'send_video_to_s3': {
+        'task': 'apps.core.tasks.send_video_to_s3',
+        'schedule': 60.0,
+    },
+}

cp_video/settings/base.py

@@ -125,4 +125,7 @@ STATIC_URL = '/static/'
 STATIC_ROOT = os.path.join(BASE_DIR, 'static/')
 
 
+# Celery
+CELERY_BROKER_URL = 'redis://127.0.0.1:6379'
+