python - 你在哪里设置 celery 任务的 task_id？

Question

我找不到任何用我自己的 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

Answer 1

delay不支持options，它是apply_async的快捷方式:

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

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

此外，当前任务的 ID 在 task.request.id 中，而不是像上面那样在 task.id 中。