celery.app.control

    class celery.app.control.Inspect(destination=None, timeout=1, callback=None, connection=None, app=None, limit=None)

    • active(safe=False)[源代码]

    • active_queues()

    • app = None

    • clock()

    • conf(with_defaults=False)[源代码]

    • hello(from_node, revoked=None)

    • memdump(samples=10)

    • memsample()

    • objgraph(type=’Request’, n=200, max_depth=10)

    • ping()

    • query_task(ids)

    • registered(\taskinfoitems*)[源代码]

    • registered_tasks(\taskinfoitems*)

    • report()

    • reserved(safe=False)[源代码]

    • revoked()

    • scheduled(safe=False)[源代码]

    • stats()

    class celery.app.control.Control(app=None)[源代码]

    • class Mailbox(namespace, type=’direct’, connection=None, clock=None, accept=None)

      • Node(hostname=None, state=None, channel=None, handlers=None)

      • abcast(command, kwargs={})

      • accept = [‘json’]

      • cast(destination, command, kwargs={})

      • connection = None

      • exchange_fmt = ‘%s.pidbox’

      • get_queue(hostname)

      • get_reply_queue()

      • multi_call(command, kwargs={}, timeout=1, limit=None, callback=None, channel=None)

      • namespace = None

      • node_cls

        的别名

      • oid None

      • reply_exchange = None

      • reply_exchange_fmt = ‘reply.%s.pidbox’

      • reply_queue None

      • type = ‘direct’

    • Control.add_consumer(queue, exchange=None, exchange_type=’direct’, routing_key=None, options=None, \*kwargs*)[源代码]

      Tell all (or specific) workers to start consuming from a new queue.

      Only the queue name is required as if only the queue is specified then the exchange/routing key will be set to the same name ( like automatic queues do).

      注解

      This command does not respect the default queue/exchange options in the configuration.

      See for supported keyword arguments.

    • Control.broadcast(command, arguments=None, destination=None, connection=None, reply=False, timeout=1, limit=None, callback=None, channel=None, \*extra_kwargs*)[源代码]

      Broadcast a control command to the celery workers.

      参数:
      • command – Name of command to send.
      • arguments – Keyword arguments for the command.
      • destination – If set, a list of the hosts to send the command to, when empty broadcast to all workers.
      • reply – Wait for and return the reply.
      • timeout – Timeout in seconds to wait for the reply.
      • limit – Limit number of replies.
      • callback – Callback called immediately for each reply received.

    • Control.cancel_consumer(queue, \*kwargs*)

      Tell all (or specific) workers to stop consuming from queue.

      Supports the same keyword arguments as broadcast().

    • Control.disable_events(destination=None, \*kwargs*)

      Tell all (or specific) workers to enable events.

    • Control.discard_all(connection=None)

      Discard all waiting tasks.

    • Control.election(id, topic, action=None, connection=None)

    • Control.enable_events(destination=None, \*kwargs*)[源代码]

      Tell all (or specific) workers to enable events.

    • Control.inspect None

    • Control.ping(destination=None, timeout=1, \*kwargs*)[源代码]

      Ping all (or specific) workers.

      Will return the list of answers.

      See for supported keyword arguments.

    • Control.pool_grow(n=1, destination=None, \*kwargs*)[源代码]

      Tell all (or specific) workers to grow the pool by n.

      Supports the same arguments as .

    • Control.pool_shrink(n=1, destination=None, \*kwargs*)[源代码]

      Tell all (or specific) workers to shrink the pool by n.

      Supports the same arguments as .

    • Control.purge(connection=None)[源代码]

      Discard all waiting tasks.

      This will ignore all tasks waiting for execution, and they will be deleted from the messaging server.

      返回:the number of tasks discarded.

    • Control.rate_limit(task_name, rate_limit, destination=None, \*kwargs*)

      Tell all (or specific) workers to set a new rate limit for task by type.

      See broadcast() for supported keyword arguments.

    • Control.revoke(task_id, destination=None, terminate=False, signal=’SIGTERM’, \*kwargs*)

      Tell all (or specific) workers to revoke a task by id.

      If a task is revoked, the workers will ignore the task and not execute it after all.

      参数:
      • task_id – Id of the task to revoke.
      • terminate – Also terminate the process currently working on the task (if any).
      • signal – Name of signal to send to process if terminate. Default is TERM.

      See broadcast() for supported keyword arguments.

    • Control.time_limit(task_name, soft=None, hard=None, \*kwargs*)

      Tell all (or specific) workers to set time limits for a task by type.

      Any additional keyword arguments are passed on to broadcast().