Flask end response and continue processing

by

QUICK and EASY method.

We will use pythons Thread Library to acheive this.

Your API consumer has sent something to process and which is processed by my_task() function which takes 10 seconds to execute.
But the consumer of the API wants a response as soon as they hit your API which is return_status() function.

You tie the my_task to a thread and then return the quick response to the API consumer, while in the background the big process gets compelete.

Below is a simple POC.

import os
from flask import Flask,jsonify
import time
from threading import Thread

app = Flask(__name__)

@app.route("/")
def main():
    return "Welcome!"

@app.route('/add_')
def return_status():
    """Return first the response and tie the my_task to a thread"""
    Thread(target = my_task).start()
    return jsonify('Response asynchronosly')

def my_task():
    """Big function doing some job here I just put pandas dataframe to csv conversion"""
    time.sleep(10)
    import pandas as pd
    pd.DataFrame(['sameple data']).to_csv('./success.csv')
    return print('large function completed')

if __name__ == "__main__":
    app.run(host="0.0.0.0", port=8080)

More Related Contents:

  1. How to serve static files in Flask
  2. Are a WSGI server and HTTP server required to serve a Flask app?
  3. Sending data from HTML form to a Python script in Flask
  4. Link to Flask static files with url_for
  5. Store large data or a service connection per Flask session
  6. Flask view return error “View function did not return a response”
  7. How do I get the different parts of a Flask request’s url?
  8. Flask to return image stored in database
  9. Why use Flask’s url_for?
  10. Remove file after Flask serves it
  11. Making an asynchronous task in Flask
  12. Send data from a textbox into Flask?
  13. Serve image stored in SQLAlchemy LargeBinary column
  14. Preserving global state in a flask application [duplicate]
  15. Flask view shows 400 error instead of template with form
  16. Create dynamic arguments for url_for in Flask
  17. How to iterate through a list of dictionaries in Jinja template?
  18. Flask jsonify a list of objects
  19. demystify Flask app.secret_key
  20. ImportError: No module named MySQLdb
  21. flask blueprint template folder
  22. Run Flask CLI command with PyCharm debugger
  23. Flask App: Update progress bar while function runs
  24. Get inserted key before commit session
  25. Where do I define the domain to be used by url_for() in Flask?
  26. How to run Flask with Gunicorn in multithreaded mode
  27. Flask: Get the size of request.files object
  28. How do I get the user agent with Flask?
  29. flask socketio emit to specific user
  30. Static files in Flask – robot.txt, sitemap.xml (mod_wsgi)

Leave a Comment