Примеры использования примитивов

Метки: celery

Функция

@celery.task()
def add(a, b):
    return a + b

Вызов функции

add.apply_async( (2, 2) )

Цепочка в примере выполнит последовательно операции сложения 2 + 2 + 4 + 8

>>> from celery import chain
>>> 
>>> res = chain(add.s(2, 2), add.s(4), add.s(8))()
>>> res.get()
16

Группа

>>> from celery import group
>>> res = group(add.s(i, i) for i in range(10))()
>>> res.get(timeout=1)
[0, 2, 4, 6, 8, 10, 12, 14, 16, 18]