为何Django异步post-save信号会阻塞其他异步ORM调用？

当你在异步ORM操作（如acreate()）中触发post_save信号时，Django会直接await异步信号接收器的执行，导致acreate()必须等待信号处理函数完成才会返回。如果信号处理函数包含长耗时异步任务（如await sleep(30)），虽然await会让出事件循环，但如果ASGI服务器运行在单进程单线程模式下，或信号处理中存在同步阻塞代码，会导致其他WebSocket请求的异步ORM操作（如aget()）被延迟甚至阻塞——尤其是当信号处理任务长时间占据事件循环调度优先级时。

1. 将长耗时任务转为后台异步任务 #

直接在信号接收器中用asyncio.create_task()启动长任务，不等待其完成，让信号接收器立即返回，避免阻塞ORM操作和后续请求：

from asyncio import sleep, create_task
import logging

logger = logging.getLogger(__name__)

async def long_process_task(instance):
    """独立的长耗时任务函数"""
    await sleep(30)
    logger.info("Long Save task completed")

@receiver(dj_models.signals.post_save, sender=MyModel)
async def auto_process_on_change(sender, instance, **kwargs):
    logger.info("Starting Long Save task in background")
    # 启动后台任务，不等待完成
    create_task(long_process_task(instance))

注意：这种方式轻量无额外依赖，但ASGI服务器进程重启时，未完成的后台任务会丢失，若需任务持久化或故障恢复，建议使用专业任务队列。

2. 使用异步任务队列（如Celery） #

如果长任务需要保证执行（即使服务器重启），可以用Celery结合Redis/RabbitMQ作为消息队列，将任务提交到队列中异步执行：

from celery import shared_task

@shared_task
async def long_process_task(instance_id):
    instance = await MyModel.objects.aget(id=instance_id)
    await sleep(30)
    logger.info("Long Save task completed")

@receiver(dj_models.signals.post_save, sender=MyModel)
async def auto_process_on_change(sender, instance, **kwargs):
    logger.info("Submitting Long Save task to Celery")
    # 提交异步任务到队列
    long_process_task.delay(instance.id)

3. 改用同步信号接收器+线程池 #

如果你的长任务是同步IO（无法改为异步），可以用线程池在后台执行，避免阻塞事件循环：

from concurrent.futures import ThreadPoolExecutor
import logging
import time

logger = logging.getLogger(__name__)
executor = ThreadPoolExecutor(max_workers=5)

def long_process_task(instance_id):
    instance = MyModel.objects.get(id=instance_id)
    time.sleep(30)
    logger.info("Long Save task completed")

@receiver(dj_models.signals.post_save, sender=MyModel)
def auto_process_on_change(sender, instance, **kwargs):
    logger.info("Starting Long Save task in thread pool")
    executor.submit(long_process_task, instance.id)

• 禁止在异步信号接收器中使用同步阻塞代码（如time.sleep、同步API调用），这会完全占用事件循环，导致所有请求阻塞。
• 用create_task启动的后台任务需添加try/except捕获异常，避免任务崩溃影响事件循环。
• 使用Celery时，确保异步任务函数线程安全，且正确处理Django数据库连接。

内容的提问来源于stack exchange，提问作者EdoG