python - celery工作流的问题

Question

celery中,我做这样的处理:
一个url经过a, b, c三个的函数,分别获得返回值,其中任意函数结果均与任意其他函数结果不相关,然后汇总起来,交给之后的流程.这样,我自然想到并行运行三个函数来加快处理速度.
然而由于一开始的设计问题, a函数式被设计成了一次可以处理多个url的形式,而一个一个的处理会非常慢.

@celery.task
def a(url_list):
    '...do something...'
    for url in url_list:
        b.delay(url)

我尝试这样控制,然而任务似乎并不能嵌套.
那么,如何设计可以比较好的满足我这种比较奇怪的流程和要求呢?

Answer 1

A; b; c hendaklah dipisahkan dan ditulis kepada 3 tugasan Pada masa yang sama, nilai status harus disimpan dalam pangkalan data untuk mewakili status pelaksanaan 3 tugasan itu. nilai status harus diubah suai dan diperiksa sama ada dua tugasan lain telah selesai, jika kedua-duanya selesai, ringkaskan hasil tugasan dan kemudian memprosesnya.

Answer 2

@xiaoboost Penyelenggaraan status secara manual boleh dilaksanakan, tetapi agak memakan masa.

Saderi boleh mereka bentuk proses pelaksanaan, rujuk dokumen: Merekabentuk Aliran Kerja
Keperluan subjek boleh diselesaikan dengan kord, dan nilai boleh dikembalikan dalam tugasan saderi.

BTW: Beri perhatian kepada beberapa pilihan yang berkaitan dengan mengembalikan nilai dalam konfigurasi Saderi, seperti task_ignore_result ini