셀러리 작업의 task_id는 어디에 설정합니까? 나는 문제가 내 자신의 TASK_ID 이러한 라인을 따라</p> <p>뭔가를 TASK_ID 설정의 예를 찾는 데

Question

...

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 

Answer 1

지연이 옵션을 지원하지 않습니다, 그것은 apply_async하는 지름길 :

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

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

또한 현재 작업의 ID는 task.request.id이 아니며 위에 언급 한 것처럼 task.id입니다.