Merge pull request #6 from AbhishekPednekar84/celery-redis-int

Celery redis int

celery_app.py

@@ -0,0 +1,9 @@
+from flask import Flask
+from utilities.factory import make_celery
+
+
+def create_celery_app():
+    app = Flask(__name__)
+    celery = make_celery(app)
+
+    return celery

config.py

@@ -9,6 +9,7 @@ class Config:
     SQLALCHEMY_DATABASE_URI = os.getenv("SQLALCHEMY_DATABASE_URI")
     SQLALCHEMY_TRACK_MODIFICATIONS = True
     RESTPLUS_MASK_SWAGGER = False
+    CELERY_BROKER_URL = os.getenv("CELERY_BROKER_URL")
 
 
 class TestConfig(Config):

requirements.txt

@@ -1,10 +1,13 @@
 alembic==1.3.1
+amqp==2.5.2
 aniso8601==8.0.0
 aspy.yaml==1.3.0
 atomicwrites==1.3.0
 attrs==19.1.0
 autopep8==1.4.4
+billiard==3.6.1.0
 blinker==1.4
+celery==4.4.0
 cfgv==2.0.1
 Click==7.0
 colorama==0.4.1
@@ -19,6 +22,7 @@ importlib-metadata==0.19
 itsdangerous==1.1.0
 Jinja2==2.10.1
 jsonschema==3.2.0
+kombu==4.6.7
 Mako==1.1.0
 MarkupSafe==1.1.1
 more-itertools==7.2.0
@@ -40,9 +44,11 @@ python-dotenv==0.10.3
 python-editor==1.0.4
 pytz==2019.3
 PyYAML==5.1.2
+redis==3.3.11
 six==1.12.0
 SQLAlchemy==1.3.10
 toml==0.10.0
+vine==1.3.0
 virtualenv==16.7.7
 wcwidth==0.1.7
 Werkzeug==0.15.5

utilities/factory.py

@@ -0,0 +1,22 @@
+import config
+from celery import Celery
+
+# from app import create_app
+
+
+def make_celery(app):
+    # app = app or create_app()
+    celery = Celery(app.import_name, broker=config.Config.CELERY_BROKER_URL)
+    celery.conf.update(app.config)
+
+    TaskBase = celery.Task
+
+    class ContextTask(TaskBase):
+        abstract = True
+
+        def __call__(self, *args, **kwargs):
+            with app.app_context():
+                return TaskBase.__call__(self, *args, **kwargs)
+
+    celery.Task = ContextTask
+    return celery

utilities/send_email.py → utilities/tasks.py

@@ -2,8 +2,12 @@
 import smtplib
 import ssl
 from email.message import EmailMessage
+from celery_app import create_celery_app
 
+celery = create_celery_app()
 
+
+@celery.task
 def send_email(caller_name, caller_email, caller_subject, caller_message):
     sender_email = os.getenv("EMAIL_USER")
     password = os.environ.get("EMAIL_PASS")

views/contact.py

@@ -1,6 +1,6 @@
 from flask import Blueprint, flash, redirect, url_for, render_template
 from forms.contact import ContactForm
-from utilities.send_email import send_email
+from utilities.tasks import send_email
 
 contact_blueprint = Blueprint("contact", __name__, template_folder="templates")
 
@@ -9,7 +9,7 @@
 def contact():
     form = ContactForm()
     if form.validate_on_submit():
-        send_email(
+        send_email.delay(
             form.username.data,
             form.email.data,
             form.subject.data,