celery.bin.base

    -A, --app

    app instance to use (e.g. module.attr_name)

    -b, --broker

    url to broker. default is ‘amqp://guest@localhost//’

    --loader

    name of custom loader class to use.

    --config

    Name of the configuration module

    These options are supported by commands that can detach into the background (daemon). They will be present in any command that also has a –detach option.

    -f, --logfile

    Path to log file. If no logfile is specified, stderr is used.

    --pidfile

    Optional file used to store the process pid.

    The program will not start if this file already exists and the pid is still alive.

    --uid

    User id, or user name of the user to run as after detaching.

    --gid

    Group id, or group name of the main group to change to after detaching.

    --umask

    Effective umask of the process after detaching. Default is 0.

    --workdir

    Optional directory to change to after detaching.

    exception celery.bin.base.Error(reason, status=None)

    • status = 1

    exception celery.bin.base.UsageError(reason, status=None)

    • status = 64

    class celery.bin.base.Extensions(namespace, register)

    • add(cls, name)

    • load()

    class celery.bin.base.HelpFormatter(indent_increment=2, max_help_position=24, width=None, short_first=1)[源代码]

    • format_description(description)

    • format_epilog(epilog)[源代码]

    class celery.bin.base.Command(app=None, get_app=None, no_color=False, stdout=None, stderr=None, quiet=False, on_error=None, on_usage_error=None)

    Base class for command-line applications.

    • exception Error(reason, status=None)

      • status = 1

    • Command.Parser

      OptionParser 的别名

    • exception Command.UsageError(reason, status=None)

      • status = 64

    • Command.args = u’’

    • Command.check_args(args)[源代码]

    • Command.description = u’’

    • Command.die(msg, status=1)

    • Command.doc = None

    • Command.early_version(argv)[源代码]

    • Command.enable_config_from_cmdline = False

    • Command.epilog = None

    • Command.error(s)

    • Command.execute_from_commandline(argv=None)

      Execute application from command-line.

    • Command.find_app(app)[源代码]

    • Command.get_cls_by_name(name, imp=<function import_from_cwd at 0xb08d87c>)

    • Command.get_options()

      Get supported command-line options.

    • Command.handle_argv(prog_name, argv, command=None)[源代码]

      Parse command-line arguments from argv and dispatch to .

      Exits with an error message if supports_args is disabled and argv contains positional arguments.

    • Command.leaf = True

    • Command.maybe_patch_concurrency(argv=None)

    • Command.namespace = u’celery’

    • Command.node_format(s, nodename, \*extra*)

    • Command.on_concurrency_setup()[源代码]

    • Command.on_error(exc)

    • Command.on_usage_error(exc)

    • Command.option_list = ()

    • Command.out(s, fh=None)

    • Command.parse_doc(doc)

    • Command.parse_options(prog_name, arguments, command=None)[源代码]

      Parse the available options.

    • Command.parse_preload_options(args)

    • Command.preload_options = (<Option at 0xd0d4eec: -A/—app>, <Option at 0xd0d47cc: -b/—broker>, <Option at 0xd0d4e4c: —loader>, <Option at 0xd0d424c: —config>, <Option at 0xd0d42cc: —workdir>, <Option at 0xd09798c: -C/—no-color>, <Option at 0xd09754c: -q/—quiet>)

    • Command.prepare_args(options, args)[源代码]

    • Command.prepare_parser(parser)

    • Command.preparse_options(args, options)

    • Command.pretty(n)

    • Command.pretty_dict_ok_error(n)

    • Command.pretty_list(n)

    • Command.process_cmdline_config(argv)[源代码]

    • Command.respects_app_option = True

    • Command.run_from_argv(prog_name, argv=None, command=None)

    • Command.say_chat(direction, title, body=u’’)

    • Command.say_remote_command_reply(replies)

    • Command.setup_app_from_commandline(argv)[源代码]

    • Command.show_body = True

    • Command.show_reply = True

    • Command.simple_format(s, \*extra*)

    • Command.supports_args = True

    • Command.symbol_by_name(name, imp=<function import_from_cwd at 0xb08d87c>)

    • Command.usage(command)[源代码]

    • Command.verify_args(given, _index=0)

    • Command.version = ‘3.1.7 (Cipater)’

    • Command.with_pool_option(argv)

      Return tuple of (short_opts, long_opts) if the command supports a pool argument, and used to monkey patch eventlet/gevent environments as early as possible.

      • E.g::

        has_pool_option = ([‘-P’], [‘–pool’])

    class celery.bin.base.Option(\opts, **attrs*)

    • Instance attributes:

      _short_opts : [string] _long_opts : [string]

      action : string type : string dest : string default : any nargs : int const : any choices : [string] callback : function callback_args : (any*) callback_kwargs : { string : any } help : string metavar : string

    • ACTIONS = (‘store’, ‘store_const’, ‘store_true’, ‘store_false’, ‘append’, ‘append_const’, ‘count’, ‘callback’, ‘help’, ‘version’)

    • ALWAYS_TYPED_ACTIONS = (‘store’, ‘append’)

    • ATTRS = [‘action’, ‘type’, ‘dest’, ‘default’, ‘nargs’, ‘const’, ‘choices’, ‘callback’, ‘callback_args’, ‘callback_kwargs’, ‘help’, ‘metavar’]

    • CHECK_METHODS = [<function _check_action at 0x91148ec>, <function _check_type at 0x9114924>, <function _check_choice at 0x911495c>, <function _check_dest at 0x9114994>, <function _check_const at 0x91149cc>, <function _check_nargs at 0x9114a04>, <function _check_callback at 0x9114a3c>]

    • CONST_ACTIONS = (‘store_const’, ‘append_const’)

    • STORE_ACTIONS = (‘store’, ‘store_const’, ‘store_true’, ‘store_false’, ‘append’, ‘append_const’, ‘count’)

    • TYPED_ACTIONS = (‘store’, ‘append’, ‘callback’)

    • TYPES = (‘string’, ‘int’, ‘long’, ‘float’, ‘complex’, ‘choice’)

    • TYPE_CHECKER = {‘int’: <function check_builtin at 0x9114764>, ‘float’: <function check_builtin at 0x9114764>, ‘complex’: <function check_builtin at 0x9114764>, ‘long’: <function check_builtin at 0x9114764>, ‘choice’: <function check_choice at 0x911479c>}

    • check_value(opt, value)

    • convert_value(opt, value)

    • get_opt_string()

    • process(opt, value, values, parser)

    • takes_value()