-
我在 Django 中有一个芹菜应用程序，我在其中定义了所有具有特定间隔的周期性明智任务。
-
我已经用
5 concurrency启动了芹菜工人
celery -A appname worker --loglevel=info -B -c 5
-
现在，定义的每个任务都将定期执行，如果存在超过5个活动任务，则按其间隔执行并排队。
-
现在我想定义一个任务，以便它应该在调用时执行。无论排队还是其他任何事情。
send_task('task_name',[],get_task_kwargs)
- 每当我调用
send_task它都应该立即执行，而不会在芹菜工人的并发时排队。
无法保证任务在调用任务时会运行。 您能做的最好的事情就是将此特定任务分配给其自己的队列。 这样，只要它面前没有另一个相同类型的任务，它就会始终开始执行。