Skip to main content
 首页 » 编程设计

python之获取 celery AsyncResult 的任务名称

2025年05月04日7itcoder

我正在使用 celery 执行我的异步任务,我想要实现的是在我执行任务后获取工作流中每个任务的名称和 ID。

        exec_workflow = chain( 
            task1.si(), 
            task2.si(), 
            task3.si() 
    ) 
 
    result = exec_workflow.apply_async() 
 
    tasks = [] 
    for t in result._parents(): 
        tasks.append({"id": t.id, "name": t.name}) 

但由于某些奇怪的原因,AsyncResult 似乎没有 name 属性。关于什么是执行此操作的适当方法有什么想法吗?

对此的另一种方法可能是在我执行 apply_async 之前在每个任务上强制使用一个 id,这将解决我的问题,因为我将能够将 id 与任务名称匹配。但我不确定是否可行。

谢谢。

请您参考如下方法:

不是最好的解决方案,但它有效。

result = signature.apply_async() 
result._cache['task_name'] 
#'procedures.tasks.stop'