main':
print('start task')
result = add.delay(3, 18)
print('end task')
print(result)
broker 指定任务队列的消息中间件...,backend 指定了任务执行结果的存储。...;
apply_async, 对于任务的执行附加额外的参数,对任务进行控制;
app.send_task, 可以执行未在 Celery 中进行注册的任务
重载task
import celery
class...chain
result = chain(add.s(1, 2), add.s(3), add.s(4)) # 1+2+3+4
result().get()
10
group 任务的并发执行...from celery import group
group(add.s(1, 2), add.s(3,4), add.s(5,6))().get()
[3, 7, 11]
chord将执行的结果回调