signature
signature 包含了位置參數(shù)、關(guān)鍵字參數(shù)和任務(wù)執(zhí)行選項(xiàng) 它就可以被傳遞到函數(shù)里或序列化后在網(wǎng)上傳遞。
創(chuàng)建signature
from celery import signature
signature('tasks.add', args=(2, 2), countdown=10)
add.signature((2, 2), countdown=10)
add.s(2, 2)
add.s(2, 2, debug=True)
同樣的，使用s快捷方式是不能設(shè)置選項(xiàng)的，可用：
add.s(2, 2).set(countdown=1)
如果想把簽名設(shè)置為不可更改的：
add.apply_async((2, 2), link=reset_buffers.signature(immutable=True))
add.apply_async((2, 2), link=reset_buffers.si()) # 快捷方式
回調(diào)
add.apply_async((2, 2), link=other_task.s())
原語(yǔ)
概覽
group 一系列任務(wù)應(yīng)該同時(shí)運(yùn)行的，chain一鏈任務(wù)應(yīng)該一個(gè)接著一個(gè)運(yùn)行的，chord是一個(gè)group的任務(wù)完成后再跟一個(gè)任務(wù)，map和python內(nèi)置map函數(shù)類似，starmap是用于一個(gè)函數(shù)需要多個(gè)參數(shù)的情況，chunks把大參數(shù)列表分塊。
例子：
from celery import chain
res = chain(add.s(2, 2), add.s(4), add.s(8))()
res.get()
或
(add.s(2, 2) | add.s(4) | add.s(8))().get()
from celery import group
res = group(add.s(i, i) for i in xrange(10))()
res.get(timeout=1)
from celery import chord
res = chord((add.s(i, i) for i in xrange(10)), xsum.s())()
res.get()
