你正在阅读 Celery 3.1 的文档。开发版本文档见： 此处.

celery.worker.autoscale

celery.worker.autoscale

This module implements the internal thread responsible for growing and shrinking the pool according to the current autoscale settings.

The autoscale thread is only enabled if --autoscale has been enabled on the command-line.

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

body()

force_scale_down(n)

force_scale_up(n)

info()

maybe_scale()

processes None

qty None

scale_down(n)

scale_up(n)

update(max=None, min=None)

class celery.worker.autoscale.WorkerComponent(w, **kwargs)

conditional = True

create(w)

label = 'Autoscaler'

name = u'celery.worker.autoscale.WorkerComponent'

register_with_event_loop(w, hub)

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