Django Async Views with ASGI Concurrent Database Operations

Snippet

Django Async Views with ASGI Concurrent Database Operations

This snippet demonstrates Django async views leveraging ASGI for concurrent database operations. By wrapping sync ORM calls with `@sync_to_async` and using `asyncio.gather`, multiple database queries execute simultaneously instead of sequentially, dramatically improving throughput for I/O-bound operations. The pattern is essential for building high-performance Django endpoints that handle multiple external API calls or complex database aggregations.

snippet.py
python
import asyncio
from asgiref.sync import sync_to_async
from django.http import JsonResponse
from django.db import connection
 
class AsyncDjangoView:
    async def get(self, request):
        results = await asyncio.gather(
            self.fetch_users(),
            self.fetch_products(),
            self.fetch_orders(),
            return_exceptions=True
        )
        return JsonResponse({
            'users': results[0],
            'products': results[1],
            'orders': results[2]
        })
 
    
    @sync_to_async
    def fetch_users(self):
        with connection.cursor() as cursor:
            cursor.execute('SELECT id, name FROM auth_user LIMIT 100')
            return cursor.fetchall()
    
    @sync_to_async
    def fetch_products(self):
        from myapp.models import Product
        return list(Product.objects.filter(is_active=True)[:100].values('id', 'name'))
    
    @sync_to_async
    def fetch_orders(self):
        from myapp.models import Order
        return list(Order.objects.select_related('user').only('id', 'total', 'user__name')[:100])

django

Breakdown

import asyncio

Imports the asyncio module for concurrent task management

from asgiref.sync import sync_to_async

Provides decorator to wrap sync functions for async context execution

await asyncio.gather(...)

Executes multiple awaitables concurrently, collecting results or handling exceptions

@sync_to_async

Decorator converts sync ORM methods to async-compatible functions

with connection.cursor()

Direct database cursor for raw SQL execution in async context

Previous snippet Next snippet

More Expert Python exercises →

From your library

Django Async Views with ASGI Concurrent Database Operations

Related