однажды вызов сельдерея

Question

Я использую celery для реализации асинхронной задачи c, но у меня есть тонна асинхронной c задачи, поэтому мне приходится вызывать task_func.delay() несколько раз, мой код выглядит следующим образом:

Зарегистрированная задача:

@app.task()
def task1
    ...

@app.task()
def task2
    ...

@app.task()
def task3
    ...

@app.task()
def task4
    ...

@app.task()
def task5
    ...

@app.task()
def task6
    ...

.....
.....

Я вызываю задачу сельдерея в моем другом коде, например в django представлениях:

task1.delay()
task2.delay()
task3.delay()
task4.delay()
task5.delay()
task6.delay()
......
......

, с указанным выше кодом, каждый раз, когда я создаю новый сельдерей Веселье для задачи c, я должен вызвать его с помощью delay(), есть ли способ, которым я могу назвать все задачи вместе?

Answer 1

Конечно, это так. Холст: проектирование рабочих процессов * В разделе 1002 * документации Celery объясняется, как это сделать. В вашем конкретном случае, если я правильно понял, вам нужно использовать примитив Chain .