python之在 celery 中获取 task_id

如何从 celery 中的 tasks.py 获取任务 ID

from __future__ import absolute_import 
from pig_engine.celery import app 
import time 
 
@app.task 
def run(code): 
    result = task_id /// How to get the task id 
    return result 

我知道我们可以从 run.delay().id ，但是如何在它自己的任务中获得相同的 id

请您参考如下方法:

从request获取任务信息对象

@app.task(bind=True) 
def run(self,code): 
    result = self.request.id #task id 
    return result