Add celery to colab

Signed-off-by: Gustavo Jaruga <darksshades@gmail.com> Signed-off-by: Luciano Prestes Cavalcanti <lucianopcbr@gmail.com>

Add celery to colab
Signed-off-by: Gustavo Jaruga <darksshades@gmail.com> Signed-off-by: Luciano Prestes Cavalcanti <lucianopcbr@gmail.com>
Gust · Sergio Oliveira
1 parent 31499efd
Showing 5 changed files with 41 additions and 0 deletions Show diff stats
colab/__init__.py
colab/celery.py
colab/settings.py
setup.py
vagrant/centos.sh
@@ -0,0 +1,5 @@
+from __future__ import absolute_import
+
+# This will make sure the app is always imported when
+# Django starts so that shared_task will use this app.
+from .celery import app as celery_app  # noqa
@@ -0,0 +1,27 @@
+from __future__ import absolute_import
+
+import os
+
+from celery import Celery
+
+# set the default Django settings module for the 'celery' program.
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'colab.settings')
+
+from django.conf import settings
+
+app = Celery('colab')
+
+app.config_from_object('django.conf:settings')
+app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
+
+app.conf.update(
+    CELERY_RESULT_BACKEND='djcelery.backends.database:DatabaseBackend',
+)
+app.conf.update(
+    CELERY_RESULT_BACKEND='djcelery.backends.cache:CacheBackend',
+)
+
+
+@app.task(bind=True)
+def debug_task(self):
+    print('Request: {0!r}'.format(self.request))
@@ -8,6 +8,7 @@ For the full list of settings and their values, see
 https://docs.djangoproject.com/en/1.7/ref/settings/
 """
+BROKER_URL = 'amqp://guest:guest@localhost:5672/'
 # Build paths inside the project like this: os.path.join(BASE_DIR, ...)
 import os
 BASE_DIR = os.path.dirname(__file__)
@@ -47,6 +48,7 @@ INSTALLED_APPS = (
     'hitcounter',
     'i18n_model',
     'taggit',
+    'djcelery',
     # Own apps
     'colab.home',
@@ -14,6 +14,9 @@ REQUIREMENTS = [
     # Diazo
     'diazo>=1.0.5',
+    # Celery
+    'django-celery==3.1.16',
+
     ### Move out of colab (as plugins):
     # Deps for badger
@@ -21,6 +21,10 @@ yum -y groupinstall &quot;Development tools&quot;
 yum install -y git unzip mercurial libev-devel gettext libxml2-devel libxslt-devel openssl-devel libffi-devel libjpeg-turbo-devel zlib-devel freetype-devel postgresql-devel python-devel postgresql-server java epel-release
+### Install Rabbitmq
+yum install -y rabbitmq-server
+systemctl start rabbitmq-server
+
 ### Install Virtualenvwrapper
 which pip2.7 > /dev/null ||
     curl -s -L https://raw.githubusercontent.com/pypa/pip/1.5.6/contrib/get-pip.py |
@@ -0,0 +1,5 @@		@@ -0,0 +1,5 @@
	1	+from __future__ import absolute_import
	2	+
	3	+# This will make sure the app is always imported when
	4	+# Django starts so that shared_task will use this app.
	5	+from .celery import app as celery_app # noqa
@@ -0,0 +1,27 @@		@@ -0,0 +1,27 @@
	1	+from __future__ import absolute_import
	2	+
	3	+import os
	4	+
	5	+from celery import Celery
	6	+
	7	+# set the default Django settings module for the 'celery' program.
	8	+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'colab.settings')
	9	+
	10	+from django.conf import settings
	11	+
	12	+app = Celery('colab')
	13	+
	14	+app.config_from_object('django.conf:settings')
	15	+app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
	16	+
	17	+app.conf.update(
	18	+ CELERY_RESULT_BACKEND='djcelery.backends.database:DatabaseBackend',
	19	+)
	20	+app.conf.update(
	21	+ CELERY_RESULT_BACKEND='djcelery.backends.cache:CacheBackend',
	22	+)
	23	+
	24	+
	25	+@app.task(bind=True)
	26	+def debug_task(self):
	27	+ print('Request: {0!r}'.format(self.request))