在给定时间点执行的 celery 任务数

Question

我正在尝试动态地异步创建一堆 celery 任务。假设我异步启动了 1000 个任务，而我只有一个 celeryd 进程正在运行来执行任务。 celery 会创建多少个线程来处理这些任务？

如果 celery 自动启动多个线程来处理任务队列，如何限制 celery 在给定时间点仅执行 100 个线程。

谢谢。

Answer 1

它的起始数量与您使用 CELERYD_OPTS concurrency 参数指定的一样多。 这也讨论了here。