2012-04-19 21 views
9

我無法找到設置TASK_ID我自己TASK_ID你在哪裏設置芹菜任務的task_id?

東西沿着這些路線的任何例子...

def testview1(request): 
    for i in xrange(0,1000): 
     result = add.delay(i, 4,task_id = i) 
     print result.info 
     #value = result.wait() 
    return HttpResponse("Done") 


@task() 
def add(task_id, x, y): 
    print add.task_id 
    print str(x+y) 
    return x + y 

回答

20

延遲不支持的選項,這是一個快捷方式apply_async:

add.apply_async(args, kwargs, task_id=i) 

add.apply_async((1, 4), task_id=i) 

此外,當前任務的ID在task.request.id而不是task.id像你上面。

+0

謝謝!我還有一個問題可以幫助我。 – michael 2012-04-19 23:55:02

+0

http://stackoverflow.com/questions/10238477/mopping-up-after-celery-results-when-stored-in-db – michael 2012-04-19 23:56:41