Django搭配Celery时任务报错仍显示成功且返回None 如何获取更多信息

• 任务实际报错却标记成功：通常是你在任务代码中手动捕获了所有异常但未重新抛出，Celery仅能识别未被捕获的异常来判定任务失败，被吞掉的异常不会触发失败标记。
• 日志末尾显示None：Celery默认的成功日志中冒号后展示的是任务的返回值，你的任务没有写return语句，默认返回None就会显示在这里。

• 不要吞异常，确保异常能被Celery感知
  错误的任务写法（会吞异常）：

  @app.task
  def my_task():
      try:
          # 业务逻辑
          1 / 0
      except Exception as e:
          print(f"出错了：{e}") # 仅打印不抛出，Celery认为任务成功
  

  正确写法：

  @app.task(bind=True)
  def my_task(self):
      try:
          # 业务逻辑
          1 / 0
      except Exception as e:
          # 可先记录错误日志
          logger.error(f"任务执行失败：{str(e)}", exc_info=True)
          # 要么重新抛出异常标记任务失败
          raise e
          # 要么需要重试的话调用self.retry
          # raise self.retry(exc=e, countdown=60)
  

• 给任务添加明确返回值，替换默认的None
  你可以根据业务需要返回结构化的执行信息，日志会自动展示返回内容：

  @app.task
  def process_data(data_id):
      # 业务处理逻辑
      data = DataModel.objects.get(id=data_id)
      data.process()
      data.save()
      # 自定义返回内容
      return {"status": "success", "processed_id": data_id, "process_time": data.updated_at}
  

• 自定义日志输出获取更详细信息
  你可以重写Celery Task基类的成功/失败回调方法，自定义日志格式和输出内容：

  import logging
  from celery import Task
  
  logger = logging.getLogger(__name__)
  
  class BaseTask(Task):
      def on_success(self, retval, task_id, args, kwargs):
          # 自定义成功日志
          logger.info(f"任务{self.name}执行成功，任务ID:{task_id}，参数:{args}，返回值:{retval}")
          super().on_success(retval, task_id, args, kwargs)
      
      def on_failure(self, exc, task_id, args, kwargs, einfo):
          # 自定义失败日志，输出完整异常堆栈
          logger.error(f"任务{self.name}执行失败，任务ID:{task_id}，参数:{args}，异常信息:{str(exc)}，堆栈:{einfo.traceback}")
          super().on_failure(exc, task_id, args, kwargs, einfo)
  
  # 任务使用自定义基类
  @app.task(base=BaseTask)
  def my_task():
      # 业务逻辑
  

• 配置Celery参数强化追踪
  在Django的settings.py中添加如下配置，开启更完善的任务追踪：

  # 记录任务的started状态
  CELERY_TRACK_STARTED = True
  # 任务失败时保存异常信息和堆栈
  CELERY_TASK_SERIALIZER = 'json'
  CELERY_RESULT_SERIALIZER = 'json'
  

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