【发布时间】:2023-04-11 00:09:01
【问题描述】:
我正在使用 celery on_failure 处理程序来记录所有失败的任务以进行调试和分析。我想知道失败任务的任务名称(函数名称),我怎么能得到呢?
from celery import Task
class DebugTask(Task):
abstract = True
def after_return(self, *args, **kwargs):
print('Task returned: {0!r}'.format(self.request))
def on_failure(self, exc, task_id, args, kwargs, einfo):
func_name = get_func_name_by_task_id(task_id) # how do I do this?
print "{} failed".format(func_name) # expected out: add failed.
@app.task(base=DebugTask)
def add(x, y):
return x + y
PS:我知道有task_id,但是每次用task_id查询函数名不好玩,
【问题讨论】: