2014-09-29 35 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