celery.worker.autoscale

Автомасштабирование пула.

Этот модуль реализует внутренний поток, отвечающий за увеличение и уменьшение пула в соответствии с текущими настройками автомасштабирования.

Поток автомасштабирования включается только при использовании параметра celery worker --autoscale.

classcelery.worker.autoscale.Autoscaler(pool, max_concurrency, min_concurrency=0, worker=None, keepalive=30.0, mutex=None)

Фоновый поток для автомасштабирования рабочих процессов пула.

body()

info()

maybe_scale(req=None)

propertyprocesses

propertyqty

scale_down(n)

scale_up(n)

update(max=None, min=None)

classcelery.worker.autoscale.WorkerComponent(w, **kwargs)

Этап запуска, который запускает поток/таймер автомасштабирования в рабочем процессе.

conditional=True

create(w)

Создать этап.

info(w)

Вернуть сведения об Autoscaler.

label='Autoscaler'

name='celery.worker.autoscale.WorkerComponent'

register_with_event_loop(w, hub)

requires=(step:celery.worker.components.Pool{(step:celery.worker.components.Hub{(step:celery.worker.components.Timer{()},)},)},)