initial

Author: Siddharth

.gitignore

@@ -0,0 +1,2 @@
+venv/*
+*.pyc

Dockerfile

@@ -0,0 +1,18 @@
+FROM python:3.7.3-slim-stretch
+
+ENV PYTHONDONTWRITEBYTECODE 1
+ENV PYTHONUNBUFFERED 1
+
+RUN mkdir /app
+
+RUN apt update && apt upgrade -y && \
+    apt install gcc default-libmysqlclient-dev -y && \
+    pip install --upgrade pip
+WORKDIR /app
+
+COPY . /app/
+RUN pip install -r requirements.txt
+
+EXPOSE 8000
+
+CMD ["python", "manage.py", "runserver", "0.0.0.0:8000"]

Procfile

@@ -0,0 +1,2 @@
+web: python manage.py runserver 0.0.0.0:8000
+cmd: celery -A proj worker -l INFO

README.rst

@@ -0,0 +1,66 @@
+==============================================================
+ Example Django project using Celery
+==============================================================
+
+* For sqlite testing, we can implement migration through the docker file via adding another command. `python manage.py makemigrations` and `python manage.py migrate`
+
+Credits: Originally from https://github.com/celery/celery/tree/master/examples/django
+
+Modified the app file just to add a hello-world end point (/api-check/) for validation.
+
+Contents
+========
+
+``proj/``
+---------
+
+This is a project in itself, created using
+``django-admin.py startproject proj``, and then the settings module
+(``proj/settings.py``) was modified to add ``demoapp`` to
+``INSTALLED_APPS``
+
+``proj/celery.py``
+----------
+
+This module contains the Celery application instance for this project,
+we take configuration from Django settings and use ``autodiscover_tasks`` to
+find task modules inside all packages listed in ``INSTALLED_APPS``.
+
+``demoapp/``
+------------
+
+Example generic app.  This is decoupled from the rest of the project by using
+the ``@shared_task`` decorator.  This decorator returns a proxy that always
+points to the currently active Celery instance.
+
+Installing requirements
+=======================
+
+The settings file assumes that ``rabbitmq-server`` is running on ``localhost``
+using the default ports. More information here:
+
+http://docs.celeryproject.org/en/latest/getting-started/brokers/rabbitmq.html
+
+In addition, some Python requirements must also be satisfied:
+
+.. code-block:: console
+
+    $ pip install -r requirements.txt
+
+Starting the worker
+===================
+
+.. code-block:: console
+
+    $ celery -A proj worker -l INFO
+
+Running a task
+===================
+
+.. code-block:: console
+
+    $ python ./manage.py shell
+    >>> from demoapp.tasks import add, mul, xsum
+    >>> res = add.delay(2,3)
+    >>> res.get()
+    5

demoapp/__init__.py

@@ -0,0 +1,21 @@
+# Generated by Django 2.2.1 on 2019-05-24 21:37
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    initial = True
+
+    dependencies = [
+    ]
+
+    operations = [
+        migrations.CreateModel(
+            name='Widget',
+            fields=[
+                ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('name', models.CharField(max_length=140)),
+            ],
+        ),
+    ]

demoapp/migrations/0001_initial.py

@@ -0,0 +1,5 @@
+from django.db import models
+
+
+class Widget(models.Model):
+    name = models.CharField(max_length=140)

demoapp/migrations/__init__.py

@@ -0,0 +1,32 @@
+# Create your tasks here
+
+from demoapp.models import Widget
+
+from celery import shared_task
+
+
+@shared_task
+def add(x, y):
+    return x + y
+
+
+@shared_task
+def mul(x, y):
+    return x * y
+
+
+@shared_task
+def xsum(numbers):
+    return sum(numbers)
+
+
+@shared_task
+def count_widgets():
+    return Widget.objects.count()
+
+
+@shared_task
+def rename_widget(widget_id, name):
+    w = Widget.objects.get(id=widget_id)
+    w.name = name
+    w.save()

demoapp/models.py

@@ -0,0 +1,7 @@
+# Create your views here.
+from rest_framework.views import APIView
+from rest_framework.response import Response
+
+class HomeAPIView(APIView):
+    def get(self, request, format=None):
+        return Response({"desc": "hello world"})