Python + Celery：链接工作？

Python + Celery：链接工作？

您可以用芹菜链来做。参见https://celery.readthedocs.org/en/latest/userguide/canvas.html#chains

@task()def add(a, b):    time.sleep(5) # simulate long time processing    return a + b

链接工作：

# import chain from celery import chain# the result of the first add job will be # the first argument of the second add jobret = chain(add.s(1, 2), add.s(3)).apply_async()# another way to express a chain using pipesret2 = (add.s(1, 2) | add.s(3)).apply_async()...# check ret status to get resultif ret.status == u'SUCCESS':    print "result:", ret.get()