获取芹菜的task_id

Question

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

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，但是如何在自己的任务中获取相同的ID

Answer 1

从请求对象 获取任务的信息

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