2014-09-29 5 views
0

Как я могу получить идентификатор задачи из tasks.py в celeryполучить TASK_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(). Ид, но как может получить тот же идентификатор в задачах это сам

ответ

4

получить информацию Task от request объекта

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

Я думаю, что вы должны передать 'привязывать = true' к декоратора, чтобы иметь возможность получить доступ к' self', он должен быть '@ app.task (бен d = True) '. – Pierre

+0

@Peter обновил его! – xecgr

Смежные вопросы