我用气流来安排任务,执行者是芹菜。我的问题是:
有些任务会占用大量CPU时间,而有些任务则不会,有没有办法根据服务器的负载动态修改celery worker的并发性? 例如,如果任务现在占用大量CPU,并且服务器负载很重,则celery worker的并发性应该动态收缩,否则并发性应该会增长。
我没用过 Airflow CeleryExecutor ,
Airflow
CeleryExecutor
LocalExecutor )通过添加 task s到 pool s 和 modifying those pools ( slot s count) programmatically .
LocalExecutor
task
pool
slot
(不确定是否有风险/反模式)