2014-09-29 53 views
0

的TASK_ID我怎樣才能從tasks.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在任務是自我

回答

4

得到request對象任務的信息

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

我想你應該通過'綁定= TRUE;對裝飾到能夠訪問'self',它應該是'@ app.task(BIN d =真)'。 – Pierre 2014-09-30 10:31:51

+0

@Peter更新了它! – xecgr 2014-09-30 12:00:53