【问题标题】:celery: get function name by task id?芹菜:通过任务ID获取函数名称?
【发布时间】: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查询函数名不好玩,

【问题讨论】:

    标签: python celery


    【解决方案1】:

    快速查看文档显示Task.name

    【讨论】:

    • 谢谢,看来我想多了。
    猜你喜欢
    • 2021-01-02
    • 2019-08-06
    • 1970-01-01
    • 2018-01-28
    • 2015-09-28
    • 1970-01-01
    • 2014-07-14
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多