如何在Celery周期性任务调度器中主动抛出异常并获取完整回溯？

问题根因 #

你当前的异常捕获抛出逻辑写在on_after_configure信号回调函数内，Celery默认会截断信号处理器的异常完整回溯栈，同时你仅将原始异常的字符串内容拼接进新的CeleryError，没有传递原始异常上下文，因此无法输出完整报错信息和回溯栈。另外你代码里还存在一处笔误：winbeat_time_data["hou"]应为winbeat_time_data["hour"]，拼写错误也可能是你触发异常的原因。

修复方案 #

1. 保留原始异常上下文 #

使用Python 3的异常链语法，将原始异常绑定到新抛出的异常上，完整保留回溯栈：

except Exception as e:
    print("ERROR:-->", e)
    # 加 from e 绑定原始异常上下文
    raise CeleryError(f'Celery task init failed with error: {e}') from e

2. 配置Celery开启完整异常输出 #

在Celery实例初始化时添加以下配置，关闭异常截断：

celery = Celery(你的应用名)
# 开启详细日志格式
celery.conf.worker_log_format = '%(asctime)s - %(name)s - %(levelname)s - %(message)s'
# 允许输出完整异常回溯
celery.conf.worker_redirect_stdouts_level = 'ERROR'
celery.conf.task_track_started = True
celery.conf.worker_send_task_events = True

3. 调整启动参数输出完整日志 #

启动Celery worker+beat时，将日志级别调整为ERROR或DEBUG，默认的INFO级别只会打印简短报错：

celery -A 你的应用入口文件名 worker --beat --loglevel=ERROR

4. 运行时异常的额外配置 #

如果你需要捕获的是周期性任务运行时的异常（不是现在的任务注册阶段异常），需要把异常处理逻辑写到对应任务函数内部，或者配置task_failure信号全局捕获运行时异常：

from celery.signals import task_failure

@task_failure.connect
def handle_task_failure(sender, exception, args, kwargs, traceback, einfo, **kw):
    print(f"任务 {sender.name} 执行失败，异常：{exception}，回溯：{einfo.traceback}")

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