Making an asynchronous task in Flask

by

I would use Celery to handle the asynchronous task for you. You’ll need to install a broker to serve as your task queue (RabbitMQ and Redis are recommended).

app.py:

from flask import Flask
from celery import Celery

broker_url="amqp://guest@localhost"          # Broker URL for RabbitMQ task queue

app = Flask(__name__)    
celery = Celery(app.name, broker=broker_url)
celery.config_from_object('celeryconfig')      # Your celery configurations in a celeryconfig.py

@celery.task(bind=True)
def some_long_task(self, x, y):
    # Do some long task
    ...

@app.route('/render/<id>', methods=['POST'])
def render_script(id=None):
    ...
    data = json.loads(request.data)
    text_list = data.get('text_list')
    final_file = audio_class.render_audio(data=text_list)
    some_long_task.delay(x, y)                 # Call your async task and pass whatever necessary variables
    return Response(
        mimetype="application/json",
        status=200
    )

Run your Flask app, and start another process to run your celery worker.

$ celery worker -A app.celery --loglevel=debug

I would also refer to Miguel Gringberg’s write up for a more in depth guide to using Celery with Flask.

More Related Contents:

  1. How to schedule a function to run every hour on Flask?
  2. Why is sudo not accepting my sudo password? [closed]
  3. Get a variable from the URL in a Flask route
  4. Add a prefix to all Flask routes
  5. Get IP address of visitors using Flask for Python
  6. How can I run an external command asynchronously from Python?
  7. How to stop flask application without using ctrl-c
  8. How to stop Flask from initialising twice in Debug Mode? [duplicate]
  9. Return JSON response from Flask view
  10. Why not generate the secret key every time Flask starts?
  11. Flask-Login raises TypeError: ‘bool’ object is not callable when trying to override is_active property
  12. Importing flask.ext raises ModuleNotFoundError
  13. Asyncio.gather vs asyncio.wait
  14. How to build a flask application around an already existing database?
  15. Split Python Flask app into multiple files
  16. How to execute a function asynchronously every 60 seconds in Python?
  17. Flask-SQLAlchemy db.create_all() raises RuntimeError working outside of application context
  18. Reload Flask app when template file changes
  19. AttributeError: ‘int’ object has no attribute ‘_sa_instance_state’
  20. How to show a pandas dataframe into a existing flask html table?
  21. Simple approach to launching background task in Django
  22. How to send requests with JSON in unit tests
  23. Flask app “Restarting with stat”
  24. ValueError: Shape of passed values is (1, 6), indices imply (6, 6)
  25. flask-sqlalchemy or sqlalchemy
  26. secret key not set in flask session, using the Flask-Session extension
  27. Slow Requests on Local Flask Server
  28. Nested Blueprints in Flask?
  29. Which SQLAlchemy column type should be used for binary data?
  30. Opening csv file in Python using Flask

Leave a Comment