Make a Python asyncio call from a Flask route

by

You can incorporate some async functionality into Flask apps without having to completely convert them to asyncio.

import asyncio
from flask import Flask

async def abar(a):
    print(a)

loop = asyncio.get_event_loop()
app = Flask(__name__)

@app.route("https://stackoverflow.com/")
def notify():
    loop.run_until_complete(abar("abar"))
    return "OK"

if __name__ == "__main__":
    app.run(debug=False, use_reloader=False)

This will block the Flask response until the async function returns, but it still allows you to do some clever things. I’ve used this pattern to perform many external requests in parallel using aiohttp, and then when they are complete, I’m back into traditional flask for data processing and template rendering.

import aiohttp
import asyncio
import async_timeout
from flask import Flask

loop = asyncio.get_event_loop()
app = Flask(__name__)

async def fetch(url):
    async with aiohttp.ClientSession() as session, async_timeout.timeout(10):
        async with session.get(url) as response:
            return await response.text()

def fight(responses):
    return "Why can't we all just get along?"

@app.route("https://stackoverflow.com/")
def index():
    # perform multiple async requests concurrently
    responses = loop.run_until_complete(asyncio.gather(
        fetch("https://google.com/"),
        fetch("https://bing.com/"),
        fetch("https://duckduckgo.com"),
        fetch("http://www.dogpile.com"),
    ))

    # do something with the results
    return fight(responses)

if __name__ == "__main__":
    app.run(debug=False, use_reloader=False)

More Related Contents:

  1. Are global variables thread-safe in Flask? How do I share data between requests?
  2. Passing HTML to template using Flask/Jinja2
  3. How to debug a Flask app
  4. Create dynamic URLs in Flask with url_for()
  5. TypeError: ObjectId(”) is not JSON serializable
  6. How can I periodically execute a function with asyncio?
  7. Python 3.7 – asyncio.sleep() and time.sleep()
  8. Streaming data with Python and Flask
  9. What is an ‘endpoint’ in Flask?
  10. How can I change the host and port that the flask command uses?
  11. RuntimeError: This event loop is already running in python
  12. Disable console messages in Flask server
  13. Flask hangs when sending a post request to itself
  14. AssertionError: View function mapping is overwriting an existing endpoint function: main
  15. can you add HTTPS functionality to a python flask web server?
  16. Learning asyncio: “coroutine was never awaited” warning error
  17. Get root path of Flask application
  18. Flask url_for generating http URL instead of https
  19. Querying with function on Flask-SQLAlchemy model gives BaseQuery object is not callable error
  20. Flask broken pipe with requests
  21. Getting value from select tag using flask
  22. Unable to “import matplotlib.pyplot as plt” in virtualenv
  23. Keep a datetime.date in ‘yyyy-mm-dd’ format when using Flask’s jsonify
  24. How to use Flask-Script and Gunicorn
  25. “asyncio.run() cannot be called from a running event loop” when using Jupyter Notebook
  26. python flask display image on a html page [duplicate]
  27. Background Worker with Flask
  28. Exception event loop is closed with aiohttp and asyncio in python 3.8
  29. Sharing a lock between gunicorn workers
  30. Increment counter for every access to a Flask view

Leave a Comment