app.py

# General
import os
import json
import requests
# Flask
from flask import Flask, render_template, flash, request, url_for, jsonify
# Celery
from celery import Celery
# API
import api

# Configure app
app = Flask(__name__)
app.config.update(
    CELERY_BROKER_URL='redis://localhost:6379',
    CELERY_RESULT_BACKEND='redis://localhost:6379'
)

# Configure Celery
celery = Celery(
    app.name,
    broker=app.config['CELERY_BROKER_URL']
)
celery.conf.update(app.config)

@celery.task
def APICall(data={}):
    """ Asynchronous call to ChompChap API """
    # print(data)
    # result = api.Predict(data)
    result = requests.get("https://9c23bd01.ngrok.io/getrec",params={"words":" ".join(data["words"]), "latitude": data["coords"]["lat"], "longitude": data["coords"]["lng"]})

    return { "result": result.json(), "status": "SUCCESS" }

@app.route("/", methods=['GET', 'POST'])
def Index():
    """ Main page """
    return render_template("index.html")

@app.route("/features", methods=['GET'])
def Features():
    """ Feature page """
    return render_template("features.html")

@app.route("/query", methods=['POST'])
def Query():
    """ Handle requests """
    parsed = json.loads(request.data)
    task = APICall.apply_async(kwargs={ "data": parsed })

    return jsonify({}), 202, { "Location": url_for("Status", taskID=task.id) }

@app.route("/status/<taskID>")
def Status(taskID):
    task = APICall.AsyncResult(taskID)
    response = { "state": task.state }
    if task.state != "FAILURE" and task.info and "result" in task.info:
            response["result"] = task.info["result"]

    return jsonify(response)

if __name__ == "__main__":
    # Load model
    # api.Start()
    # Start App
    app.debug = False
    port = int(os.environ.get("PORT", 3000))
    app.run(host="0.0.0.0", port=port, use_reloader=True)