python - 在 celery 中获取 task_id

Question

如何从 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

Answer 1

从request获取任务信息对象

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