python - 如何并行运行多个 celery 任务？

我有两个任务。

@app.task
def run1():
    while True:
        print('run1')
        time.sleep(5)
    return


@app.task
def run2():
    while True:
        print('run2')
        time.sleep(2)
    return

如何从同一个控制台，从一个命令(最好使用不同数量的 workers )同时运行这两个任务。

最佳答案

您需要使用 group :



来自 django shell 的示例:

>>> from celery import group
>>> from myapp.tasks import run1, run2
>>>
>>> run_group = group(run1.s(), run2.s())
>>> run_group()
<GroupResult: 06b3e88b-6c10-4ba5-bb32-5005c82eedfe [cc734fbd-3531-45d1-8575-64f4eff35523,
1075e822-a6e2-4c34-8038-369613ff687d]>

有关更复杂的用法，请参阅 group 上的文档。

关于python - 如何并行运行多个 celery 任务？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/58312820/