This document describes the current stable version of Celery (4.0). For development docs, go here.
celery.bin.amqp
¶
The celery amqp command.
-
class
celery.bin.amqp.
AMQShell
(*args, **kwargs)[source]¶ AMQP API Shell.
Parameters: - connect (Callable) – Function used to connect to the server.
Must return
kombu.Connection
object. - silent (bool) – If enabled, the commands won’t have annoying output not relevant when running in non-shell mode.
-
amqp
= {u'queue.declare': <celery.bin.amqp.Spec object>, u'queue.purge': <celery.bin.amqp.Spec object>, u'exchange.delete': <celery.bin.amqp.Spec object>, u'basic.publish': <celery.bin.amqp.Spec object>, u'basic.ack': <celery.bin.amqp.Spec object>, u'exchange.declare': <celery.bin.amqp.Spec object>, u'queue.delete': <celery.bin.amqp.Spec object>, u'queue.bind': <celery.bin.amqp.Spec object>, u'basic.get': <celery.bin.amqp.Spec object>}¶
-
builtins
= {u'exit': u'do_exit', u'EOF': u'do_exit', u'help': u'do_help'}¶
-
chan
= None¶
-
conn
= None¶
-
counter
= 1¶
-
get_amqp_api_command
(cmd, arglist)[source]¶ Get AMQP command wrapper.
With a command name and a list of arguments, convert the arguments to Python values and find the corresponding method on the AMQP channel object.
Returns: of (method, processed_args) pairs. Return type: Tuple
-
identchars
= u'.'¶
-
inc_counter
= count(2)¶
-
needs_reconnect
= False¶
-
parseline
(parts)[source]¶ Parse input line.
Returns: - of three items:
- (command_name, arglist, original_line)
Return type: Tuple
-
prompt
¶
-
prompt_fmt
= u'{self.counter}> '¶
- connect (Callable) – Function used to connect to the server.
Must return
-
class
celery.bin.amqp.
Spec
(*args, **kwargs)[source]¶ AMQP Command specification.
Used to convert arguments to Python values and display various help and tool-tips.
Parameters: -
args
= None¶
-
returns
= None¶
-
-
class
celery.bin.amqp.
amqp
(app=None, get_app=None, no_color=False, stdout=None, stderr=None, quiet=False, on_error=None, on_usage_error=None)[source]¶ AMQP Administration Shell.
Also works for non-AMQP transports (but not ones that store declarations in memory).
Examples
$ # start shell mode $ celery amqp $ # show list of commands $ celery amqp help $ celery amqp exchange.delete name $ celery amqp queue.delete queue $ celery amqp queue.delete queue yes yes