Django celery 任务执行

Question

当恶魔只执行一项任务时，我在 tasks.py 文件中有 3 个任务。其余两个显示在调试模式但不执行。

celery worker --concurrency=1

有什么改变需要吗？

编辑：

@celery.decorators.periodic_task(run_every=datetime.timedelta(minutes=1))
def task1():
    try:
        sc = SampleCount.objects.get(pk=1)
    except:
        sc = SampleCount()
    sc.num = sc.num + 1
    sc.save()
    return(sc)

相同的 task2 用于将数据添加到 SampleCount2(minute=2) 和 task3 用于将数据添加到 SampleCount3(minute=3)。 现在我运行

python manage.py celeryd -E -B --loglevel=DEBUG

所以它会显示 3 个任务。但是当我检查状态时，它只显示 1 task1 active 。计划中没有其他两个。如果我运行

python manage.py celeryd -E -B --loglevel=DEBUG

再次命令，然后 task3 处于活动状态，其余两个不工作。如何使用一个工作人员运行三个任务。

我已经等到 10 分钟，但只有一个任务在工作（可能是它的 task1、task2 或 task3）。

Answer 1

这取决于服务器上可用的资源。

没有这样的要求，即任务数必须等于工人数。唯一需要了解的是：

运行的工作人员越多，处理所有任务的速度就越快，但需要更多的服务器资源。

这个命令：

celery worker --concurrency=1

将产生两个进程

1. Control process, that will manage workers
2. worker process, the one, that will actually do the job

还有这个命令：

celery worker --concurrency=2

将产生三个进程

1. Control process, that will manage workers
2. worker process #1, the one, that will actually do the job
2. worker process #2, the one, that will actually do the job

等等。

一个工人可以处理你所有的任务，但两个工人会做得更快。