在Django中无法捕获Celery OperationalError问题求助

我来帮你拆解问题根源，再给出针对性的修复方案：

问题核心原因 #

你当前的try-except块只包裹了transaction.on_commit()的注册操作，而非回调函数内部的任务入队逻辑。transaction.on_commit()本身只是把回调函数注册到事务提交后执行，并不会立刻运行c_task.delay()——当事务提交触发回调时，save()方法里的try块早就执行完毕了，所以Redis故障抛出的OperationalError根本不会被外层的try捕获到。

另外，你需要明确捕获Redis模块专属的OperationalError，避免泛用Exception导致的捕获不准确问题。

具体修复方案 #

1. 将异常捕获移到回调函数内部

把try-except逻辑放到on_commit的回调里，或者抽成单独的辅助函数，确保任务入队时的异常能被及时捕获：

from redis.exceptions import OperationalError  # 导入Redis的专属异常类
import logging

logger = logging.getLogger(__name__)

def save():
    super().save(*args, **kwargs)
    # 注册回调，将任务入队逻辑抽成独立函数
    transaction.on_commit(lambda: _enqueue_c_task(a, b, self.pk))

def _enqueue_c_task(a, b, pk):
    try:
        c_task.delay(a, b, pk)
    except OperationalError as e:
        # 这里可以做日志记录、告警或任务暂存等处理
        logger.error(f"Redis连接故障，无法入队任务c_task: {str(e)}")
        # 若需要，可在此处实现简单的本地重试逻辑
    except Exception as e:
        logger.error(f"入队任务c_task时发生未知错误: {str(e)}")

2. 区分两个阶段的异常处理

你任务函数里的try-except是处理任务执行阶段的异常（比如查询ModelA、调用entity()时的错误），而Redis故障属于任务入队阶段的异常，这两个阶段的异常是完全独立的，任务内部的捕获逻辑管不到入队失败的问题。

3. 额外优化建议

• 用logging替代print：生产环境中print的输出难以追踪，标准日志模块能更清晰地记录错误上下文。
• 增加降级策略：如果Redis长期不可用，可以将任务信息暂存到数据库或本地文件，后续通过定时任务重试入队，避免任务丢失。

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