索引

符号

--autoreload celery-worker 命令行选项 --autoscale celery-worker 命令行选项 --config 命令行选项 --detach celery-beat 命令行选项 celery-events 命令行选项 --gid 命令行选项 --loader 命令行选项 --maxtasksperchild celery-worker 命令行选项 --no-execv celery-worker 命令行选项 --pidfile celery-worker 命令行选项 命令行选项 --purge celery-worker 命令行选项 --scheduler celery-worker 命令行选项 --soft-time-limit celery-worker 命令行选项 --time-limit celery-worker 命令行选项 --uid 命令行选项 --umask 命令行选项 --without-gossip celery-worker 命令行选项 --without-heartbeat celery-worker 命令行选项 --without-mingle celery-worker 命令行选项 --workdir 命令行选项

-A, --app 命令行选项 -B, --beat celery-worker 命令行选项 -b, --broker 命令行选项 -c, --camera celery-events 命令行选项 -c, --concurrency celery-worker 命令行选项 -d, --dump celery-events 命令行选项 -E, --events celery-worker 命令行选项 -F, --freq, --frequency celery-events 命令行选项 -f, --logfile celery-beat 命令行选项 celery-worker 命令行选项 命令行选项 -I, --include celery-worker 命令行选项 -l, --loglevel celery-beat 命令行选项 celery-events 命令行选项 celery-worker 命令行选项 -n, --hostname celery-worker 命令行选项 -O celery-worker 命令行选项 -P, --pool celery-worker 命令行选项 -Q, --queues celery-worker 命令行选项 -r, --maxrate celery-events 命令行选项 -s, --schedule celery-beat 命令行选项 celery-worker 命令行选项 -S, --scheduler celery-beat 命令行选项 -S, --statedb celery-worker 命令行选项

_

__call__() (celery.signature 方法)

A

abbr() (在 celery.utils.text 模块中) abbrtask() (在 celery.utils.text 模块中) abcast() (celery.app.control.Control.Mailbox 方法) abort() (celery.contrib.abortable.AbortableAsyncResult 方法) AbortableAsyncResult (celery.contrib.abortable 中的类) AbortableTask (celery.contrib.abortable 中的类) abstract (celery.app.task.Task 属性) (Task 属性) accept (celery.app.control.Control.Mailbox 属性) (celery.backends.amqp.AMQPBackend.Consumer 属性) accept_magic_kwargs (celery.app.task.Task 属性) ack acknowledge() (celery.worker.job.Request 方法) acknowledged (celery.worker.job.Request 属性) acks_late (celery.app.task.Task 属性) (Task 属性) acquire() (celery.platforms.Pidfile 方法) ACTIONS (celery.bin.base.Option 属性) active (celery.concurrency.base.BasePool 属性) (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) active() (celery.app.control.Inspect 方法) active_queues control active_queues() (celery.app.control.Inspect 方法) active_requests() (在 celery.worker.state 模块中) add() (celery.app.amqp.Queues 方法) (celery.beat.Scheduler 方法) (celery.bin.base.Extensions 方法) (celery.datastructures.LimitedSet 方法) (celery.result.ResultSet 方法) (hub 方法) add_cert() (celery.security.certificate.CertStore 方法) add_compat() (celery.app.amqp.Queues 方法) add_consumer control add_consumer() (celery.app.control.Control 方法) add_defaults() (celery.Celery 方法) (celery.datastructures.ConfigurationView 方法) add_events() (celery.worker.autoreload.KQueueMonitor 方法) add_queue() (celery.backends.amqp.AMQPBackend.Consumer 方法) add_queue_from_dict() (celery.backends.amqp.AMQPBackend.Consumer 方法) add_reader() (hub 方法) add_task_queue() (celery.worker.consumer.Consumer 方法) add_writer() (hub 方法) adjust_timestamp() (在 celery.utils.timeutils 模块中) ADMINS setting after_return() (celery.app.task.Task 方法) after_setup_logger signal after_setup_task_logger signal after_task_publish signal Agent (celery.worker.consumer 中的类) alert() (celery.events.cursesmon.CursesMonitor 方法) alert_remote_control_reply() (celery.events.cursesmon.CursesMonitor 方法) alias (celery.bootsteps.Blueprint 属性) (celery.bootsteps.Step 属性) alive (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) alive_workers() (celery.events.state.State 方法) ALL_STATES state already_setup (celery.app.log.Logging 属性) AlreadyRegistered alt (celery.app.defaults.Option 属性)

ALWAYS_TYPED_ACTIONS (celery.bin.base.Option 属性) AlwaysEagerIgnored AMQP (celery.app.amqp 中的类) amqp (celery.bin.amqp 中的类) (celery.Celery 属性) (celery.bin.amqp.AMQShell 属性), [1] AMQPAdmin (celery.bin.amqp 中的类) AMQPBackend (celery.backends.amqp 中的类) AMQPBackend.BacklogLimitExceeded AMQPBackend.Consumer (celery.backends.amqp 中的类) AMQPBackend.Consumer.ContentDisallowed AMQPBackend.Exchange (celery.backends.amqp 中的类) AMQPBackend.Producer (celery.backends.amqp 中的类) AMQShell (celery.bin.amqp 中的类) annotate() (celery.app.annotations.MapAnnotation 方法) annotate_any() (celery.app.annotations.MapAnnotation 方法) app, [1] (celery.app.control.Inspect 属性) (celery.apps.beat.Beat 属性) (celery.events.EventDispatcher 属性) (celery.events.EventReceiver 属性) (celery.result.AsyncResult 属性) (celery.result.ResultSet 属性) (celery.schedules.crontab 属性) (celery.schedules.schedule 属性) (celery.worker.WorkController 属性) (celery.worker.job.Request 属性) app_or_default() (在 celery.app 模块中) AppLoader (celery.loaders.app 中的类) apply apply() (celery.app.task.Task 方法) (celery.bootsteps.Blueprint 方法) (celery.signature 方法) apply_async() (celery.app.task.Task 方法) (celery.beat.Scheduler 方法) (celery.concurrency.base.BasePool 方法) (celery.signature 方法) apply_buffer() (celery.contrib.batches.Batches 方法) apply_chord() (celery.backends.base.BaseBackend 方法) apply_eta_task() (celery.worker.consumer.Consumer 方法) apply_target() (在 celery.concurrency.base 模块中) appstr() (在 celery.app.utils 模块中) args (celery.beat.ScheduleEntry 属性) (celery.bin.base.Command 属性) (celery.bin.graph.graph 属性) (celery.concurrency.base.BasePool.Timer.Entry 属性) (celery.contrib.batches.SimpleRequest 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) (celery.utils.timer2.Entry 属性) (celery.utils.timer2.Timer.Entry 属性) (celery.worker.job.Request 属性) arguments (celery.backends.amqp.AMQPBackend.Exchange 属性) as_dict() (celery.datastructures.LimitedSet 方法) (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) as_tuple() (celery.result.AsyncResult 方法) (celery.result.GroupResult 方法) AsyncResult (celery.Celery 属性) (celery.result 中的类) AsyncResult() (celery.app.task.Task 方法) (celery.contrib.abortable.AbortableTask 方法) AsyncResult.TimeoutError asynloop() (在 celery.worker.loops 模块中) AttributeDict (celery.datastructures 中的类) AttributeDictMixin (celery.datastructures 中的类) attrs (celery.backends.amqp.AMQPBackend.Exchange 属性) ATTRS (celery.bin.base.Option 属性) auto_declare (celery.backends.amqp.AMQPBackend.Consumer 属性) (celery.backends.amqp.AMQPBackend.Producer 属性) (celery.backends.rpc.RPCBackend.Consumer 属性) auto_delete (celery.backends.amqp.AMQPBackend.Exchange 属性), [1] autodiscover_tasks() (celery.Celery 方法) (celery.loaders.base.BaseLoader 方法) autoregister (celery.app.task.Task 属性) autoreloader Autoreloader (celery.worker.autoreload 中的类) autoscaler Autoscaler (celery.worker.autoscale 中的类) available (celery.utils.sysinfo.df 属性) AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY

B

backend (celery.app.task.Task 属性) (Task 属性) (celery.Celery 属性) (celery.result.AsyncResult 属性) background (celery.events.cursesmon.CursesMonitor 属性) BacklogLimitExceeded BaseBackend (celery.backends.base 中的类) BaseBackend.TimeoutError BaseLoader (celery.loaders.base 中的类) BaseMonitor (celery.worker.autoreload 中的类) BasePool (celery.concurrency.base 中的类) BasePool.Timer (celery.concurrency.base 中的类) BasePool.Timer.Entry (celery.concurrency.base 中的类) Batches (celery.contrib.batches 中的类) Beat (celery.apps.beat 中的类) beat (celery.bin.beat 中的类) Beat (celery.Celery 属性) (celery.worker.components 中的类) Beat.Service (celery.apps.beat 中的类) beat_embedded_init signal beat_init signal before_task_publish signal bgThread (celery.utils.threads 中的类) billiard bind() (queue 方法) bind_to() (celery.backends.amqp.AMQPBackend.Exchange 方法) binding (celery.backends.rpc.RPCBackend 属性) binding() (celery.backends.amqp.AMQPBackend.Exchange 方法) black() (celery.utils.term.colored 方法) blink() (celery.utils.term.colored 方法) BlockingPool (celery.concurrency.prefork.TaskPool 属性) blue() (celery.utils.term.colored 方法) blueprint, [1] Blueprint (celery.bootsteps 中的类)

blueprint (celery.worker.WorkController 属性) body (celery.utils.mail.ErrorMail 属性) body() (celery.utils.threads.bgThread 方法) (celery.worker.autoreload.Autoreloader 方法) (celery.worker.autoscale.Autoscaler 方法) bold() (celery.utils.term.colored 方法) bootsteps() (celery.bin.graph.graph 方法) bright() (celery.utils.term.colored 方法) broadcast() (celery.app.control.Control 方法) BROKER_BACKEND (celery.app.utils.Settings 属性) BROKER_CONNECTION_MAX_RETRIES setting BROKER_CONNECTION_RETRY setting BROKER_CONNECTION_TIMEOUT setting BROKER_FAILOVER_STRATEGY setting BROKER_HEARTBEAT setting BROKER_HEARTBEAT_CHECKRATE setting BROKER_LOGIN_METHOD setting BROKER_POOL_LIMIT setting BROKER_TRANSPORT setting BROKER_TRANSPORT (celery.app.utils.Settings 属性) BROKER_TRANSPORT_OPTIONS setting BROKER_URL setting BROKER_URL (celery.app.utils.Settings 属性) BROKER_USE_SSL setting bucket (celery.backends.couchbase.CouchBaseBackend 属性) bucket_for_task() (celery.worker.consumer.Consumer 方法) (consumer 方法) bugreport() (celery.Celery 方法) (在 celery.app.utils 模块中) build_graph() (celery.result.AsyncResult 方法) build_tracer() (在 celery.app.trace 模块中) builtin_modules (celery.loaders.base.BaseLoader 属性) builtins (celery.bin.amqp.AMQShell 属性)

C

C_FAKEFORK, [1], [2] C_IMPDEBUG CacheBackend (celery.backends.cache 中的类) cached_property (celery.utils 中的类) call() (celery.app.control.Control.Mailbox 方法) call_after() (celery.concurrency.base.BasePool.Timer 方法) (celery.utils.timer2.Timer 方法) call_at() (celery.concurrency.base.BasePool.Timer 方法) (celery.utils.timer2.Timer 方法) call_repeatedly() (celery.concurrency.base.BasePool.Timer 方法) (celery.utils.timer2.Timer 方法) call_task() (celery.worker.consumer.Gossip 方法) callbacks (celery.backends.amqp.AMQPBackend.Consumer 属性) calling can_cache_declaration (celery.backends.amqp.AMQPBackend.Exchange 属性) cancel() (celery.backends.amqp.AMQPBackend.Consumer 方法) (celery.concurrency.base.BasePool.Timer 方法) (celery.concurrency.base.BasePool.Timer.Entry 方法) (celery.concurrency.eventlet.TaskPool.Timer 方法) (celery.events.snapshot.Polaroid 方法) (celery.utils.timer2.Entry 方法) (celery.utils.timer2.Timer 方法) (celery.utils.timer2.Timer.Entry 方法) cancel_by_queue() (celery.backends.amqp.AMQPBackend.Consumer 方法) cancel_consumer control cancel_consumer() (celery.app.control.Control 方法) cancel_task_queue() (celery.worker.consumer.Consumer 方法) (consumer 方法) cancelled (celery.concurrency.base.BasePool.Timer.Entry 属性) (celery.utils.timer2.Entry 属性) (celery.utils.timer2.Timer.Entry 属性) capacity (celery.utils.sysinfo.df 属性) capture() (celery.events.EventReceiver 方法) (celery.events.snapshot.Polaroid 方法) CASSANDRA_COLUMN_FAMILY setting CASSANDRA_DETAILED_MODE setting CASSANDRA_KEYSPACE setting CASSANDRA_READ_CONSISTENCY setting CASSANDRA_SERVERS setting CASSANDRA_WRITE_CONSISTENCY setting CassandraBackend (celery.backends.cassandra 中的类) cast() (celery.app.control.Control.Mailbox 方法) CDeprecationWarning Celery (celery 中的类) celery (模块) celery-beat 命令行选项 --detach -S, --scheduler -f, --logfile -l, --loglevel -s, --schedule max-interval celery-events 命令行选项 --detach -F, --freq, --frequency -c, --camera -d, --dump -l, --loglevel -r, --maxrate celery-worker 命令行选项 --autoreload --autoscale --maxtasksperchild --no-execv --pidfile --purge --scheduler --soft-time-limit --time-limit --without-gossip --without-heartbeat --without-mingle -B, --beat -E, --events -I, --include -O -P, --pool -Q, --queues -S, --statedb -c, --concurrency -f, --logfile -l, --loglevel -n, --hostname -s, --schedule celery._state (模块) celery.app (模块) celery.app.amqp (模块) celery.app.annotations (模块) celery.app.builtins (模块) celery.app.control (模块) celery.app.defaults (模块) celery.app.log (模块) celery.app.registry (模块) celery.app.routes (模块) celery.app.task (模块) celery.app.trace (模块) celery.app.utils (模块) celery.apps.beat (模块) celery.apps.worker (模块) celery.backends (模块) celery.backends.amqp (模块) celery.backends.base (模块) celery.backends.cache (模块) celery.backends.cassandra (模块) celery.backends.couchbase (模块) celery.backends.database (模块) celery.backends.database.models (模块) celery.backends.database.session (模块) celery.backends.mongodb (模块) celery.backends.redis (模块) celery.backends.rpc (模块) celery.beat (模块) celery.bin.amqp (模块) celery.bin.base (模块) celery.bin.beat (模块) celery.bin.celery (模块) celery.bin.events (模块) celery.bin.graph (模块) celery.bin.multi (模块) celery.bin.worker (模块) celery.bootsteps (模块) celery.concurrency (模块) celery.concurrency.base (模块) celery.concurrency.eventlet (模块) celery.concurrency.gevent (模块) celery.concurrency.prefork (模块) celery.concurrency.solo (模块) celery.concurrency.threads (模块) celery.contrib.abortable (模块) celery.contrib.batches (模块) celery.contrib.methods (模块) celery.contrib.migrate (模块) celery.contrib.rdb (模块) celery.datastructures (模块) celery.events (模块) celery.events.cursesmon (模块) celery.events.dumper (模块) celery.events.snapshot (模块) celery.events.state (模块) celery.exceptions (模块) celery.loaders (模块) celery.loaders.app (模块) celery.loaders.base (模块) celery.loaders.default (模块) celery.platforms (模块) celery.result (模块) celery.schedules (模块) celery.security (模块) celery.security.certificate (模块) celery.security.key (模块) celery.security.serialization (模块) celery.security.utils (模块) celery.signals (模块) celery.states (模块) celery.task.base (模块) celery.task.http (模块), [1] celery.utils (模块) celery.utils.compat (模块) celery.utils.debug (模块) celery.utils.dispatch (模块) celery.utils.dispatch.saferef (模块) celery.utils.dispatch.signal (模块) celery.utils.functional (模块) celery.utils.imports (模块) celery.utils.iso8601 (模块) celery.utils.log (模块) celery.utils.mail (模块) celery.utils.objects (模块) celery.utils.serialization (模块) celery.utils.sysinfo (模块) celery.utils.term (模块) celery.utils.text (模块) celery.utils.threads (模块) celery.utils.timer2 (模块) celery.utils.timeutils (模块) celery.worker (模块) celery.worker.autoreload (模块) celery.worker.autoscale (模块) celery.worker.components (模块) celery.worker.consumer (模块) celery.worker.control (模块) celery.worker.heartbeat (模块) celery.worker.job (模块) celery.worker.loops (模块) celery.worker.pidbox (模块) celery.worker.state (模块) celery.worker.strategy (模块) CELERY_ACCEPT_CONTENT setting CELERY_ACKS_LATE setting CELERY_ALWAYS_EAGER setting CELERY_ANNOTATIONS setting CELERY_BENCH CELERY_BROADCAST_EXCHANGE setting CELERY_BROADCAST_EXCHANGE_TYPE setting CELERY_BROADCAST_QUEUE setting CELERY_BROKER_URL CELERY_CACHE_BACKEND setting CELERY_CACHE_BACKEND_OPTIONS setting CELERY_CHORD_PROPAGATES setting CELERY_CONFIG_MODULE, [1], [2] CELERY_COUCHBASE_BACKEND_SETTINGS setting CELERY_CREATE_DIRS CELERY_CREATE_MISSING_QUEUES setting CELERY_DEFAULT_DELIVERY_MODE setting CELERY_DEFAULT_EXCHANGE setting CELERY_DEFAULT_EXCHANGE_TYPE setting CELERY_DEFAULT_QUEUE setting CELERY_DEFAULT_RATE_LIMIT setting CELERY_DEFAULT_ROUTING_KEY setting CELERY_DISABLE_RATE_LIMITS setting CELERY_EAGER_PROPAGATES_EXCEPTIONS setting CELERY_ENABLE_REMOTE_CONTROL setting CELERY_ENABLE_UTC setting CELERY_EVENT_QUEUE_EXPIRES setting CELERY_EVENT_QUEUE_TTL setting CELERY_EVENT_SERIALIZER setting CELERY_IGNORE_RESULT setting CELERY_IMPORTS setting CELERY_INCLUDE setting CELERY_LOADER, [1], [2], [3], [4], [5] CELERY_MAX_CACHED_RESULTS setting

CELERY_MESSAGE_COMPRESSION setting CELERY_MONGODB_BACKEND_SETTINGS setting CELERY_QUEUE_HA_POLICY setting CELERY_QUEUES setting CELERY_RDB_HOST CELERY_RDB_PORT CELERY_RDBSIG CELERY_REDIRECT_STDOUTS setting CELERY_REDIRECT_STDOUTS_LEVEL setting CELERY_REDIS_MAX_CONNECTIONS setting CELERY_RESULT_BACKEND setting CELERY_RESULT_BACKEND (celery.app.utils.Settings 属性) CELERY_RESULT_DB_SHORT_LIVED_SESSIONS CELERY_RESULT_DB_SHORT_LIVED_SESSIONS = True setting CELERY_RESULT_DB_TABLENAMES setting CELERY_RESULT_DBURI setting CELERY_RESULT_ENGINE_OPTIONS setting CELERY_RESULT_EXCHANGE setting CELERY_RESULT_EXCHANGE_TYPE setting CELERY_RESULT_PERSISTENT setting CELERY_RESULT_SERIALIZER setting CELERY_ROUTES setting CELERY_SECURITY_CERT_STORE setting CELERY_SECURITY_CERTIFICATE setting CELERY_SECURITY_KEY setting CELERY_SEND_EVENTS setting CELERY_SEND_TASK_ERROR_EMAILS setting CELERY_SEND_TASK_SENT_EVENT setting CELERY_STORE_ERRORS_EVEN_IF_IGNORED setting CELERY_TASK_PUBLISH_RETRY setting CELERY_TASK_PUBLISH_RETRY_POLICY setting CELERY_TASK_RESULT_EXPIRES setting CELERY_TASK_SERIALIZER setting CELERY_TIMEZONE setting CELERY_TIMEZONE (celery.app.utils.Settings 属性) CELERY_TRACE_APP, [1], [2] CELERY_TRACK_STARTED setting CELERY_WORKER_DIRECT setting CELERYBEAT_MAX_LOOP_INTERVAL setting CELERYBEAT_SCHEDULE setting CELERYBEAT_SCHEDULE_FILENAME setting CELERYBEAT_SCHEDULER setting CeleryCommand (celery.bin.celery 中的类) celeryd_after_setup signal CELERYD_AUTORELOADER setting CELERYD_AUTOSCALER setting CELERYD_CONCURRENCY setting CELERYD_CONSUMER setting CELERYD_FORCE_EXECV setting CELERYD_FSNOTIFY, [1] CELERYD_HIJACK_ROOT_LOGGER setting celeryd_init signal CELERYD_LOG_COLOR setting CELERYD_LOG_FORMAT setting CELERYD_MAX_TASKS_PER_CHILD setting CELERYD_POOL setting CELERYD_POOL_RESTARTS setting CELERYD_PREFETCH_MULTIPLIER setting CELERYD_STATE_DB setting CELERYD_TASK_LOG_FORMAT setting CELERYD_TASK_SOFT_TIME_LIMIT setting CELERYD_TASK_TIME_LIMIT setting CELERYD_TIMER setting CELERYD_TIMER_PRECISION setting CELERYD_WORKER_LOST_WAIT setting CELERYMON_LOG_FORMAT setting Certificate (celery.security.certificate 中的类) CertStore (celery.security.certificate 中的类) chain (celery 中的类) chan (celery.bin.amqp.AMQShell 属性) changes (celery.datastructures.ConfigurationView 属性) channel (celery.backends.amqp.AMQPBackend.Consumer 属性) (celery.backends.amqp.AMQPBackend.Exchange 属性) (celery.backends.amqp.AMQPBackend.Producer 属性) check_args() (celery.bin.base.Command 方法) CHECK_METHODS (celery.bin.base.Option 属性) check_value() (celery.bin.base.Option 方法) children (celery.result.AsyncResult 属性) (celery.result.GroupResult 属性) chord (celery 中的类) chord_keyprefix (celery.backends.base.KeyValueStoreBackend 属性) ChordError chunks() (celery.app.task.Task 方法) (在 celery.utils.functional 模块中) cipater claim_steps() (celery.bootsteps.Blueprint 方法) cleanup() (celery.backends.base.BaseBackend 方法) (celery.backends.database.DatabaseBackend 方法) (celery.backends.mongodb.MongoBackend 方法) (celery.events.snapshot.Polaroid 方法) (celery.utils.threads.LocalManager 方法) cleanup_signal (celery.events.snapshot.Polaroid 属性) clear() (celery.concurrency.base.BasePool.Timer 方法) (celery.concurrency.eventlet.TaskPool.Timer.Schedule 方法) (celery.concurrency.gevent.TaskPool.Timer.Schedule 方法) (celery.datastructures.ConfigurationView 方法) (celery.datastructures.LimitedSet 方法) (celery.events.state.State 方法) (celery.result.ResultSet 方法) (celery.utils.timer2.Timer 方法) clear_after (celery.events.snapshot.Polaroid 属性) clear_tasks() (celery.events.state.State 方法) client (celery.backends.cache.CacheBackend 属性) (celery.backends.redis.RedisBackend 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) clock (celery.events.state.State.Task 属性) (celery.events.state.State.Worker 属性) (celery.events.state.Task 属性) (celery.events.state.Worker 属性) clock() (celery.app.control.Inspect 方法) clone() (celery.signature 方法) CLOSE (celery.concurrency.base.BasePool 属性) close() (celery.backends.amqp.AMQPBackend.Consumer 方法) (celery.Celery 方法) (celery.backends.amqp.AMQPBackend.Producer 方法) (celery.beat.PersistentScheduler 方法) (celery.beat.Scheduler 方法) (celery.bootsteps.Blueprint 方法) (celery.bootsteps.StartStopStep 方法) (celery.concurrency.base.BasePool 方法) (celery.events.EventDispatcher 方法) (celery.platforms.DaemonContext 方法) (celery.utils.log.LoggingProxy 方法) (celery.worker.autoreload.KQueueMonitor 方法) (celery.worker.components.Pool 方法) (celery.worker.state.Persistent 方法) close_open_fds() (在 celery.platforms 模块中) closed (celery.utils.log.LoggingProxy 属性) cmdline_config_parser() (celery.loaders.base.BaseLoader 方法) coerce() (celery.bin.amqp.Spec 方法) collect() (celery.result.AsyncResult 方法) collection (celery.backends.mongodb.MongoBackend 属性) colored (celery.bin.multi.MultiTool 属性) (celery.utils.term 中的类) colored() (celery.app.log.Logging 方法) ColorFormatter (celery.utils.log 中的类) COLORS (celery.utils.log.ColorFormatter 属性) colors (celery.utils.log.ColorFormatter 属性) column_family (celery.backends.cassandra.CassandraBackend 属性) Command (celery.bin.base 中的类) Command.Error Command.UsageError commands (celery.bin.celery.CeleryCommand 属性) compatible_transport() (celery.worker.consumer.Gossip 方法) (celery.worker.consumer.Mingle 方法) compatible_transports (celery.worker.consumer.Gossip 属性) (celery.worker.consumer.Mingle 属性) completed_count() (celery.result.ResultSet 方法) completenames() (celery.bin.amqp.AMQShell 方法) compress() (celery.worker.state.Persistent 方法) compression (celery.backends.amqp.AMQPBackend.Producer 属性) (Task 属性) conditional (celery.bootsteps.Step 属性) (celery.worker.autoreload.WorkerComponent 属性) (celery.worker.autoscale.WorkerComponent 属性) (celery.worker.components.Beat 属性) (celery.worker.consumer.Agent 属性) conf (celery.Celery 属性) (celery.loaders.base.BaseLoader 属性) conf() (celery.app.control.Inspect 方法) config_from_object() (celery.Celery 方法) (celery.loaders.base.BaseLoader 方法) ConfigurationView (celery.datastructures 中的类) configured (celery.loaders.base.BaseLoader 属性) conn (celery.bin.amqp.AMQShell 属性) conncache (celery.backends.couchbase.CouchBaseBackend 属性) connect() (celery.bin.amqp.AMQPAdmin 方法) (celery.utils.dispatch.Signal 方法) (celery.utils.dispatch.signal.Signal 方法) (celery.worker.consumer.Consumer 方法) connect_with() (celery.bootsteps.Blueprint 方法) connection Connection (celery.app.amqp.AMQP 属性) connection (celery.app.control.Control.Mailbox 属性) (celery.backends.amqp.AMQPBackend.Consumer 属性) (celery.backends.amqp.AMQPBackend.Producer 属性) (celery.backends.couchbase.CouchBaseBackend 属性) (celery.beat.Scheduler 属性) (celery.events.EventReceiver 属性) Connection (celery.worker.consumer 中的类) connection() (celery.Celery 方法) connection_errors (celery.worker.job.Request 属性) connection_or_acquire() (celery.Celery 方法) CONST_ACTIONS (celery.bin.base.Option 属性) consume() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.amqp.AMQPBackend.Consumer 方法) consume_from (celery.app.amqp.Queues 属性) Consumer (celery.app.amqp.AMQP 属性) (celery.worker.components 中的类) (celery.worker.consumer 中的类) consumer (celery.worker.pidbox.Pidbox 属性) Consumer.Blueprint (celery.worker.consumer 中的类) consumers (celery.bootsteps.ConsumerStep 属性) ConsumerStep (celery.bootsteps 中的类) consuming_from() (celery.backends.amqp.AMQPBackend.Consumer 方法) context control active_queues add_consumer cancel_consumer disable_events enable_events ping pool_restart rate_limit revoke shutdown Control (celery.app.control 中的类) control (celery.Celery 属性) Control (celery.worker.consumer 中的类) Control.Mailbox (celery.app.control 中的类) controller convert_value() (celery.bin.base.Option 方法) correlation_id (celery.worker.job.Request 属性) CouchBaseBackend (celery.backends.couchbase 中的类) count (celery.contrib.migrate.State 属性) counter (celery.bin.amqp.AMQShell 属性) CPendingDeprecationWarning create() (celery.bootsteps.Step 方法) (celery.worker.autoreload.WorkerComponent 方法) (celery.worker.autoscale.WorkerComponent 方法) (celery.worker.components.Beat 方法) (celery.worker.components.Consumer 方法) (celery.worker.components.Hub 方法) (celery.worker.components.Pool 方法) (celery.worker.components.Queues 方法) (celery.worker.components.StateDB 方法) (celery.worker.components.Timer 方法) (celery.worker.consumer.Agent 方法) create_exception_cls() (在 celery.utils.serialization 模块中) create_notifier() (celery.worker.autoreload.InotifyMonitor 方法) create_parser() (celery.bin.base.Command 方法) create_pidlock() (在 celery.platforms 模块中) create_session() (在 celery.backends.database.session 模块中) create_task_handler() (celery.worker.consumer.Consumer 方法) crontab (celery.schedules 中的类) crontab_parser (celery.schedules 中的类) crontab_parser.ParseException cry() (在 celery.utils 模块中) current_app() (在 celery 模块中) current_task (celery.Celery 属性) current_task() (在 celery 模块中) current_task_children() (celery.backends.base.BaseBackend 方法) CursesMonitor (celery.events.cursesmon 中的类) cwd_in_path() (在 celery.utils.imports 模块中) cyan() (celery.utils.term.colored 方法)

D

daemon_options() (在 celery.bin.base 模块中) DaemonContext (celery.platforms 中的类) data (celery.worker.control.Panel 属性) database (celery.backends.mongodb.MongoBackend 属性) database_name (celery.backends.mongodb.MongoBackend 属性) DatabaseBackend (celery.backends.database 中的类) date_done (celery.backends.database.models.Task 属性) (celery.backends.database.models.TaskSet 属性) day_of_month (celery.schedules.crontab 属性) day_of_week (celery.schedules.crontab 属性) db (celery.backends.redis.RedisBackend 属性) (celery.worker.state.Persistent 属性) debugger() (在 celery.contrib.rdb 模块中) declare() (celery.backends.amqp.AMQPBackend.Consumer 方法) (celery.backends.amqp.AMQPBackend.Exchange 方法) (celery.backends.amqp.AMQPBackend.Producer 方法) (queue 方法) decode() (celery.backends.base.BaseBackend 方法) decompress() (celery.worker.state.Persistent 方法) dedent() (在 celery.utils.text 模块中) dedent_initial() (在 celery.utils.text 模块中) default() (celery.bin.amqp.AMQShell 方法) (在 celery.worker.strategy 模块中) default_app() (在 celery.app 模块中) default_dispatcher() (celery.events.Events 方法) default_exchange (celery.app.amqp.AMQP 属性) default_loader() (在 celery.app 模块中) default_nodename() (在 celery.worker 模块中) default_queue (celery.app.amqp.AMQP 属性) default_retry_delay (celery.app.task.Task 属性) (Task 属性) default_socket_timeout() (在 celery.utils.threads 模块中) default_steps (celery.bootsteps.Blueprint 属性) (celery.worker.WorkController.Blueprint 属性) (celery.worker.consumer.Consumer.Blueprint 属性) defaults (celery.datastructures.ConfigurationView 属性) delay() (celery.app.task.Task 方法) (celery.signature 方法) delete() (celery.backends.amqp.AMQPBackend.Exchange 方法) (celery.backends.base.KeyValueStoreBackend 方法) (celery.backends.cache.CacheBackend 方法) (celery.backends.couchbase.CouchBaseBackend 方法) (celery.backends.redis.RedisBackend 方法) (celery.result.GroupResult 方法) (exchange 方法) (queue 方法) delete_group() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.base.BaseBackend 方法) deleter() (celery.utils.cached_property 方法) delivery_info (celery.contrib.batches.SimpleRequest 属性) (celery.worker.job.Request 属性) delivery_mode (celery.backends.amqp.AMQPBackend.Exchange 属性), [1] delta_resolution() (在 celery.utils.timeutils 模块中) deprecate_by (celery.app.defaults.Option 属性) deprecated() (在 celery.utils 模块中) description (celery.bin.base.Command 属性) deselect() (celery.app.amqp.Queues 方法)

deserialize() (celery.security.serialization.SecureSerializer 方法) destination_for() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.rpc.RPCBackend 方法) detached() (在 celery.platforms 模块中) detailed_mode (celery.backends.cassandra.CassandraBackend 属性) df (celery.utils.sysinfo 中的类) DictAttribute (celery.datastructures 中的类) dictfilter() (在 celery.utils.functional 模块中) did_start_ok() (celery.concurrency.base.BasePool 方法) (celery.concurrency.prefork.TaskPool 方法) die() (celery.bin.base.Command 方法) disable() (celery.events.EventDispatcher 方法) disable_events control disable_events() (celery.app.control.Control 方法) disable_trace() (在 celery.app 模块中) DISABLED_TRANSPORTS (celery.events.EventDispatcher 属性) DisabledBackend (celery.backends.base 中的类) discard() (celery.datastructures.LimitedSet 方法) (celery.result.ResultSet 方法) discard_all() (celery.app.control.Control 方法) disconnect() (celery.utils.dispatch.Signal 方法) (celery.utils.dispatch.signal.Signal 方法) dispatch() (celery.bin.amqp.AMQShell 方法) (celery.task.http.HttpDispatch 方法) Dispatcher (celery.events.Events 属性) dispatcher (celery.task.http.URL 属性) display_command_help() (celery.bin.amqp.AMQShell 方法) display_height (celery.events.cursesmon.CursesMonitor 属性) display_task_row() (celery.events.cursesmon.CursesMonitor 方法) display_width (celery.events.cursesmon.CursesMonitor 属性) DJANGO_SETTINGS_MODULE, [1], [2], [3], [4] do_exit() (celery.bin.amqp.AMQShell 方法) do_help() (celery.bin.amqp.AMQShell 方法) doc (celery.bin.base.Command 属性) (celery.bin.beat.beat 属性) (celery.bin.events.events 属性) (celery.bin.worker.worker 属性) DOWN (celery.bin.multi.MultiTool 属性) drain_events() (celery.backends.amqp.AMQPBackend 方法) draw() (celery.events.cursesmon.CursesMonitor 方法) dst() (celery.utils.timeutils.LocalTimezone 方法) dump_body() (在 celery.worker.consumer 模块中) Dumper (celery.events.dumper 中的类) DuplicateNodenameWarning durable (celery.backends.amqp.AMQPBackend.Exchange 属性), [1]

E

eager_trace_task() (在 celery.app.trace 模块中) EagerResult (celery.result 中的类) early_version() (celery.bin.base.Command 方法) election() (celery.app.control.Control 方法) (celery.worker.consumer.Gossip 方法) EMAIL_HOST setting EMAIL_HOST_PASSWORD setting EMAIL_HOST_USER setting EMAIL_PORT setting EMAIL_SIGNATURE_SEP (celery.utils.mail.ErrorMail 属性) EMAIL_TIMEOUT setting EMAIL_USE_SSL setting EMAIL_USE_TLS setting embed() (celery.utils.term.colored 方法) EmbeddedService() (在 celery.beat 模块中) empty() (celery.concurrency.base.BasePool.Timer 方法) (celery.utils.timer2.Timer 方法) enable() (celery.events.EventDispatcher 方法) enable_config_from_cmdline (celery.bin.base.Command 属性) (celery.bin.beat.beat 属性) (celery.bin.celery.CeleryCommand 属性) (celery.bin.worker.worker 属性) enable_events control enable_events() (celery.app.control.Control 方法) enable_trace() (在 celery.app 模块中) enabled (celery.bootsteps.Step 属性) encode() (celery.backends.base.BaseBackend 方法) encode_result() (celery.backends.base.BaseBackend 方法) ensure_2lines() (在 celery.utils.text 模块中) ensure_process_aware_logger() (在 celery.utils.log 模块中) ensure_started() (celery.concurrency.base.BasePool.Timer 方法) (celery.concurrency.eventlet.TaskPool.Timer 方法) (celery.concurrency.gevent.TaskPool.Timer 方法) (celery.utils.timer2.Timer 方法) enter() (celery.concurrency.base.BasePool.Timer 方法) (celery.utils.timer2.Timer 方法) enter_after() (celery.concurrency.base.BasePool.Timer 方法) (celery.utils.timer2.Timer 方法) Entry (celery.beat.Scheduler 属性) (celery.utils.timer2 中的类) epilog (celery.bin.base.Command 属性) Error error() (celery.bin.base.Command 方法) (celery.bin.multi.MultiTool 方法) error_msg (celery.worker.job.Request 属性) ErrorMail (celery.utils.mail 中的类) (Task 属性) eta (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) (celery.worker.job.Request 属性) evaluate() (celery.utils.functional.lazy 方法) (celery.utils.functional.mlazy 方法) evaluated (celery.utils.functional.mlazy 属性), [1] evcam() (在 celery.events.snapshot 模块中) evdump() (在 celery.events.dumper 模块中) event task-failed task-received task-retried task-revoked task-sent task-started task-succeeded worker-heartbeat worker-offline worker-online event (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) event() (celery.events.state.State 方法) (celery.events.state.State.Task 方法) (celery.events.state.Task 方法)

Event() (在 celery.events 模块中) event_count (celery.events.state.State 属性) event_dispatcher event_from_message() (celery.events.EventReceiver 方法) EventDispatcher (celery.events 中的类) eventer (celery.worker.job.Request 属性) eventlet_pool_apply signal eventlet_pool_postshutdown signal eventlet_pool_preshutdown signal eventlet_pool_started signal EventReceiver (celery.events 中的类) events (celery.bin.events 中的类) (celery.Celery 属性) Events (celery.events 中的类) (celery.worker.consumer 中的类) Evloop (celery.worker.consumer 中的类) evtop() (在 celery.events.cursesmon 模块中) exc (celery.exceptions.Retry 属性) exc_args (celery.utils.serialization.UnpickleableExceptionWrapper 属性) exc_cls_name (celery.utils.serialization.UnpickleableExceptionWrapper 属性) exc_module (celery.utils.serialization.UnpickleableExceptionWrapper 属性) exception (celery.datastructures.ExceptionInfo 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) EXCEPTION_STATES state EXCEPTION_STATES (celery.backends.base.BaseBackend 属性) exception_to_python() (celery.backends.base.BaseBackend 方法) ExceptionInfo (celery.datastructures 中的类) exchange (celery.app.control.Control.Mailbox 属性) (celery.backends.amqp.AMQPBackend.Producer 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) exchange_fmt (celery.app.control.Control.Mailbox 属性) execute() (celery.bin.celery.CeleryCommand 方法) (celery.worker.job.Request 方法) execute_from_commandline() (celery.bin.base.Command 方法) (celery.bin.celery.CeleryCommand 方法) (celery.bin.multi.MultiTool 方法) execute_using_pool() (celery.worker.job.Request 方法) executing exit_after() (celery.concurrency.base.BasePool.Timer 方法) (celery.utils.timer2.Timer 方法) expand() (celery.bin.multi.MultiTool 方法) expand_destination() (celery.app.routes.Router 方法) expanduser() (celery.bin.base.Command 方法) expire() (celery.backends.base.KeyValueStoreBackend 方法) (celery.backends.redis.RedisBackend 方法) expire_window (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) expires (celery.app.task.Task 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) (celery.worker.job.Request 属性) ext_fmt (celery.bin.celery.CeleryCommand 属性) extend_buffer() (celery.events.EventDispatcher 方法) extend_with_default_kwargs() (celery.worker.job.Request 方法) Extensions (celery.bin.base 中的类) extra_info() (celery.apps.worker.Worker 方法)

F

fail_from_current_stack() (celery.backends.base.BaseBackend 方法) FAILED (celery.bin.multi.MultiTool 属性) failed (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) failed() (celery.result.AsyncResult 方法) (celery.result.ResultSet 方法) FAILURE state FAILURE() (在 celery.states 模块中) fallback_chord_unlock() (celery.backends.base.BaseBackend 方法) ffwd (celery.utils.timeutils 中的类) file_hash() (在 celery.worker.autoreload 模块中) fill_paragraphs() (在 celery.utils.text 模块中) filter_hidden_settings() (在 celery.app.utils 模块中) filter_types() (celery.app.registry.TaskRegistry 方法) filtered (celery.contrib.migrate.State 属性) finalize() (celery.Celery 方法) find() (在 celery.app.defaults 模块中) find_app() (celery.bin.base.Command 方法) (在 celery.app.utils 模块中) find_changes() (celery.worker.autoreload.StatMonitor 方法) find_module() (celery.loaders.base.BaseLoader 方法) (在 celery.utils.imports 模块中) find_option() (celery.app.utils.Settings 方法) find_pickleable_exception() (在 celery.utils.serialization 模块中) find_position() (celery.events.cursesmon.CursesMonitor 方法) find_value_for_key() (celery.app.utils.Settings 方法) first() (celery.datastructures.ConfigurationView 方法) (在 celery.utils.functional 模块中) firstmethod() (在 celery.utils.functional 模块中) FixupWarning flatten() (在 celery.app.defaults 模块中) flatten_links() (celery.signature 方法) flatten_reply() (在 celery.app.control 模块中)

flow() (celery.backends.amqp.AMQPBackend.Consumer 方法) flush() (celery.concurrency.base.BasePool 方法) (celery.contrib.batches.Batches 方法) (celery.events.EventDispatcher 方法) (celery.utils.log.LoggingProxy 方法) flush_every (celery.contrib.batches.Batches 属性) flush_interval (celery.contrib.batches.Batches 属性) flush_routes() (celery.app.amqp.AMQP 方法) force_scale_down() (celery.worker.autoscale.Autoscaler 方法) force_scale_up() (celery.worker.autoscale.Autoscaler 方法) foreground (celery.events.cursesmon.CursesMonitor 属性) forget() (celery.backends.base.BaseBackend 方法) (celery.result.AsyncResult 方法) (celery.result.EagerResult 方法) (celery.result.ResultSet 方法) format() (celery.app.amqp.Queues 方法) (celery.app.log.TaskFormatter 方法) (celery.utils.log.ColorFormatter 方法) format_arg() (celery.bin.amqp.Spec 方法) format_body() (celery.utils.mail.ErrorMail 方法) format_description() (celery.bin.base.HelpFormatter 方法) format_epilog() (celery.bin.base.HelpFormatter 方法) format_response() (celery.bin.amqp.Spec 方法) format_row() (celery.events.cursesmon.CursesMonitor 方法) format_signature() (celery.bin.amqp.Spec 方法) format_subject() (celery.utils.mail.ErrorMail 方法) format_task_event() (celery.events.dumper.Dumper 方法) formatException() (celery.utils.log.ColorFormatter 方法) freeze() (celery.signature 方法) (State 方法) freeze_while() (celery.events.state.State 方法) (State 方法) freq (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) from_exception() (celery.utils.serialization.UnpickleableExceptionWrapper 类方法) from_request() (celery.contrib.batches.SimpleRequest 类方法) FSCertStore (celery.security.certificate 中的类) fun (celery.concurrency.base.BasePool.Timer.Entry 属性) (celery.utils.timer2.Entry 属性) (celery.utils.timer2.Timer.Entry 属性)

G

gen_task_name() (在 celery.utils 模块中) get() (celery.backends.base.KeyValueStoreBackend 方法) (celery.backends.cache.CacheBackend 方法) (celery.backends.couchbase.CouchBaseBackend 方法) (celery.backends.redis.RedisBackend 方法) (celery.bin.multi.MultiTool 方法) (celery.datastructures.ConfigurationView 方法) (celery.datastructures.DictAttribute 方法) (celery.result.AsyncResult 方法) (celery.result.EagerResult 方法) (celery.result.ResultSet 方法) get_amqp_api_command() (celery.bin.amqp.AMQShell 方法) get_async() (celery.task.http.URL 方法) get_backend_by_url() (在 celery.backends 模块中) get_backend_cls() (在 celery.backends 模块中) get_by_parts() (celery.app.utils.Settings 方法) get_children() (celery.backends.base.BaseBackend 方法) get_cls_by_name() (celery.bin.base.Command 方法) get_command_info() (celery.bin.celery.CeleryCommand 类方法) get_consumers() (celery.bootsteps.ConsumerStep 方法) (celery.events.EventReceiver 方法) (celery.worker.consumer.Gossip 方法) get_current_app() (在 celery._state 模块中) get_current_task() (在 celery._state 模块中) get_current_worker_task() (在 celery._state 模块中) get_default_logger() (celery.app.log.Logging 方法) get_engine() (在 celery.backends.database.session 模块中) get_errno_name() (在 celery.platforms 模块中) get_fdmax() (在 celery.platforms 模块中) get_group_meta() (celery.backends.base.BaseBackend 方法) get_id() (celery.security.certificate.Certificate 方法) get_ident() (celery.utils.threads.LocalManager 方法) (在 celery.utils.threads 模块中) get_implementation() (在 celery.concurrency 模块中) get_issuer() (celery.security.certificate.Certificate 方法) get_key_for_chord() (celery.backends.base.KeyValueStoreBackend 方法) get_key_for_group() (celery.backends.base.KeyValueStoreBackend 方法) get_key_for_task() (celery.backends.base.KeyValueStoreBackend 方法) get_leaf() (celery.result.AsyncResult 方法) get_loader_cls() (在 celery.loaders 模块中) get_logger() (在 celery.utils.log 模块中) get_many() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.base.KeyValueStoreBackend 方法) get_multiprocessing_logger() (在 celery.utils.log 模块中)

get_names() (celery.bin.amqp.AMQShell 方法) get_opt_string() (celery.bin.base.Option 方法) get_options() (celery.bin.base.Command 方法) (celery.bin.beat.beat 方法) (celery.bin.events.events 方法) (celery.bin.worker.worker 方法) get_or_create_task() (celery.events.state.State 方法) get_or_create_worker() (celery.events.state.State 方法) get_pickleable_etype() (在 celery.utils.serialization 模块中) get_pickleable_exception() (在 celery.utils.serialization 模块中) get_pickled_exception() (在 celery.utils.serialization 模块中) get_queue() (celery.app.control.Control.Mailbox 方法) get_reply_queue() (celery.app.control.Control.Mailbox 方法) get_result() (celery.backends.base.BaseBackend 方法) (celery.backends.base.DisabledBackend 方法) get_schedule() (celery.beat.PersistentScheduler 方法) (celery.beat.Scheduler 方法) get_scheduler() (celery.apps.beat.Beat.Service 方法) (celery.beat.Service 方法) get_serial_number() (celery.security.certificate.Certificate 方法) get_status() (celery.backends.base.BaseBackend 方法) (celery.backends.base.DisabledBackend 方法) get_task_logger() (在 celery.utils.log 模块中) get_task_meta() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.base.BaseBackend 方法) get_traceback() (celery.backends.base.BaseBackend 方法) (celery.backends.base.DisabledBackend 方法) getpids() (celery.bin.multi.MultiTool 方法) gossip Gossip (celery.worker.consumer 中的类) gPidbox (celery.worker.pidbox 中的类) graph (celery.bin.graph 中的类) (celery.result.AsyncResult 属性) GraphFormatter (celery.bootsteps.Blueprint 属性) green() (celery.utils.term.colored 方法) greet (celery.events.cursesmon.CursesMonitor 属性) group (celery 中的类) group_keyprefix (celery.backends.base.KeyValueStoreBackend 属性) GroupResult (celery.Celery 属性) (celery.result 中的类) grow() (celery.concurrency.gevent.TaskPool 方法)

H

handle_argv() (celery.bin.base.Command 方法) (celery.bin.celery.CeleryCommand 方法) handle_error_state() (celery.app.trace.TraceInfo 方法) handle_event() (celery.worker.autoreload.KQueueMonitor 方法) handle_failure() (celery.app.trace.TraceInfo 方法) handle_keypress() (celery.events.cursesmon.CursesMonitor 方法) handle_retry() (celery.app.trace.TraceInfo 方法) has_expired() (celery.security.certificate.Certificate 方法) heap_multiplier (celery.events.state.State 属性) heart Heart (celery.worker.consumer 中的类) (celery.worker.heartbeat 中的类) heartbeat_expires (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) heartbeat_expires() (在 celery.events.state 模块中) heartbeat_max (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) heartbeats (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) hello() (celery.app.control.Inspect 方法)

help (celery.events.cursesmon.CursesMonitor 属性) help() (celery.bin.multi.MultiTool 方法) help_title (celery.events.cursesmon.CursesMonitor 属性) HelpFormatter (celery.bin.base 中的类) host (celery.backends.couchbase.CouchBaseBackend 属性) (celery.backends.mongodb.MongoBackend 属性) (celery.backends.redis.RedisBackend 属性) hostname, [1] (celery.contrib.batches.SimpleRequest 属性) (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) (celery.worker.job.Request 属性) hour (celery.schedules.crontab 属性) http_headers (celery.task.http.HttpDispatch 属性) HttpDispatch (celery.task.http 中的类) hub, [1] Hub (celery.worker.components 中的类) human_seconds (celery.schedules.schedule 属性) human_state() (celery.bootsteps.Blueprint 方法) humanize() (celery.app.utils.Settings 方法) (celery.exceptions.Retry 方法) humanize_seconds() (在 celery.utils.timeutils 模块中)

I

iblue() (celery.utils.term.colored 方法) icyan() (celery.utils.term.colored 方法) id (celery.backends.database.models.Task 属性) (celery.backends.database.models.TaskSet 属性) (celery.contrib.batches.SimpleRequest 属性) (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) (celery.result.AsyncResult 属性) (celery.result.GroupResult 属性) (celery.worker.job.Request 属性) idempotent identchars (celery.bin.amqp.AMQShell 属性) Ignore ignore_errno() (在 celery.platforms 模块中) ignore_result (celery.app.task.Task 属性) (Task 属性) ignored_msg (celery.worker.job.Request 属性) igreen() (celery.utils.term.colored 方法) imagenta() (celery.utils.term.colored 方法) implements_incr (celery.backends.base.KeyValueStoreBackend 属性) (celery.backends.cache.CacheBackend 属性) (celery.backends.redis.RedisBackend 属性) import_default_modules() (celery.loaders.base.BaseLoader 方法) import_from_cwd() (celery.loaders.base.BaseLoader 方法) (在 celery.utils.imports 模块中) import_module() (celery.loaders.base.BaseLoader 方法) import_modules signal import_task_module() (celery.loaders.base.BaseLoader 方法) ImproperlyConfigured in_shutdown (celery.worker.consumer.Consumer 属性) in_sighandler() (在 celery.utils.log 模块中) inc_counter (celery.bin.amqp.AMQShell 属性) include() (celery.bootsteps.StartStopStep 方法) (celery.bootsteps.Step 方法) include_if() (celery.bootsteps.Step 方法) (celery.worker.components.Hub 方法) (celery.worker.consumer.Control 方法) incr() (celery.backends.base.KeyValueStoreBackend 方法) (celery.backends.cache.CacheBackend 方法) (celery.backends.redis.RedisBackend 方法) (celery.datastructures.LRUCache 方法) (celery.utils.functional.LRUCache 方法) indent() (在 celery.utils.text 模块中) info (celery.beat.PersistentScheduler 属性) (celery.beat.Scheduler 属性) (celery.concurrency.base.BasePool 属性) (celery.result.AsyncResult 属性) info() (celery.bin.multi.MultiTool 方法) (celery.bootsteps.Blueprint 方法) (celery.bootsteps.Step 方法) (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) (celery.worker.WorkController 方法) (celery.worker.autoscale.Autoscaler 方法) (celery.worker.components.Pool 方法) (celery.worker.consumer.Connection 方法) (celery.worker.consumer.Tasks 方法) (celery.worker.job.Request 方法) info_str (celery.events.cursesmon.CursesMonitor 属性) init_callback (celery.worker.consumer.Consumer 属性) init_loader() (celery.apps.beat.Beat 方法) init_screen() (celery.events.cursesmon.CursesMonitor 方法) init_worker() (celery.loaders.base.BaseLoader 方法) init_worker_process() (celery.loaders.base.BaseLoader 方法) initgroups() (在 celery.platforms 模块中) InotifyMonitor (celery.worker.autoreload 中的类)

Inspect (celery.app.control 中的类) inspect (celery.app.control.Control 属性) install() (celery.events.snapshot.Polaroid 方法) install_default_entries() (celery.beat.Scheduler 方法) install_platform_tweaks() (celery.apps.worker.Worker 方法) install_sync_handler() (celery.apps.beat.Beat 方法) instantiate() (celery.bootsteps.Step 方法) (在 celery.utils.imports 模块中) internal (celery.datastructures.ExceptionInfo 属性) internal_error_msg (celery.worker.job.Request 属性) InvalidResponseError InvalidTaskError ired() (celery.utils.term.colored 方法) IRON_PROJECT_ID IRON_TOKEN is_aborted() (celery.contrib.abortable.AbortableAsyncResult 方法) (celery.contrib.abortable.AbortableTask 方法) is_cached() (celery.backends.base.BaseBackend 方法) is_due() (celery.beat.ScheduleEntry 方法) (celery.schedules.crontab 方法) (celery.schedules.schedule 方法) is_green (celery.concurrency.base.BasePool 属性) (celery.concurrency.eventlet.TaskPool 属性) (celery.concurrency.gevent.TaskPool 属性) is_iterable() (在 celery.utils 模块中) is_list() (在 celery.utils.functional 模块中) is_locked() (celery.platforms.Pidfile 方法) is_naive() (在 celery.utils.timeutils 模块中) isatty() (celery.utils.log.LoggingProxy 方法) (在 celery.utils 模块中) items() (celery.datastructures.ConfigurationView 方法) (celery.datastructures.DictAttribute 方法) (celery.datastructures.LRUCache 方法) (celery.utils.functional.LRUCache 方法) iter_native() (celery.result.ResultSet 方法) iterate() (celery.result.ResultSet 方法) itercapture() (celery.events.EventReceiver 方法) itercerts() (celery.security.certificate.CertStore 方法) iterdeps() (celery.result.AsyncResult 方法) iteritems() (celery.datastructures.ConfigurationView 方法) (celery.datastructures.DictAttribute 方法) (celery.datastructures.LRUCache 方法) (celery.utils.functional.LRUCache 方法) iterkeys() (celery.datastructures.ConfigurationView 方法) (celery.datastructures.DictAttribute 方法) (celery.datastructures.LRUCache 方法) (celery.utils.functional.LRUCache 方法) itertasks() (celery.events.state.State 方法) itervalues() (celery.datastructures.ConfigurationView 方法) (celery.datastructures.DictAttribute 方法) (celery.datastructures.LRUCache 方法) (celery.utils.functional.LRUCache 方法) iwhite() (celery.utils.term.colored 方法) iyellow() (celery.utils.term.colored 方法)

J

join() (celery.bootsteps.Blueprint 方法) (celery.result.ResultSet 方法) (在 celery.utils.text 模块中) join_native() (celery.result.ResultSet 方法)

jsonify() (在 celery.utils 模块中)

K

key_t() (celery.backends.base.KeyValueStoreBackend 方法) keyalias (celery.events.cursesmon.CursesMonitor 属性) keymap (celery.events.cursesmon.CursesMonitor 属性) keys() (celery.datastructures.ConfigurationView 方法) (celery.datastructures.DictAttribute 方法) (celery.datastructures.LRUCache 方法) (celery.utils.functional.LRUCache 方法) keyspace (celery.backends.cassandra.CassandraBackend 属性) KeyValueStoreBackend (celery.backends.base 中的类)

kill() (celery.bin.multi.MultiTool 方法) known_suffixes (celery.beat.PersistentScheduler 属性) kombu KQueueMonitor (celery.worker.autoreload 中的类) kwargs (celery.beat.ScheduleEntry 属性) (celery.concurrency.base.BasePool.Timer.Entry 属性) (celery.contrib.batches.SimpleRequest 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) (celery.utils.timer2.Entry 属性) (celery.utils.timer2.Timer.Entry 属性) (celery.worker.job.Request 属性)

L

label (celery.bootsteps.Step 属性) (celery.worker.autoreload.WorkerComponent 属性) (celery.worker.autoscale.WorkerComponent 属性) (celery.worker.components.Beat 属性) (celery.worker.components.Queues 属性) (celery.worker.consumer.Evloop 属性) (celery.worker.consumer.Gossip 属性) (celery.worker.consumer.Mingle 属性) last (celery.bootsteps.Step 属性) (celery.worker.components.Consumer 属性) (celery.worker.consumer.Evloop 属性) last_run_at (celery.beat.ScheduleEntry 属性) lazy (celery.utils.functional 中的类) leaf (celery.bin.base.Command 属性) limit (celery.events.cursesmon.CursesMonitor 属性) LimitedSet (celery.datastructures 中的类) link() (celery.signature 方法) link_error() (celery.signature 方法) list_commands() (celery.bin.celery.CeleryCommand 类方法) load() (celery.bin.base.Extensions 方法) load_average() (在 celery.utils.sysinfo 模块中) load_extension_commands() (celery.bin.celery.CeleryCommand 方法) load_shared_tasks() (在 celery.app.builtins 模块中) load_step() (celery.bootsteps.Blueprint 方法) loadavg (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) loader (celery.Celery 属性)

Loader (celery.loaders.default 中的类) Local (celery.utils.threads 中的类) localize() (在 celery.utils.timeutils 模块中) LocalManager (celery.utils.threads 中的类) LocalStack() (在 celery.utils.threads 模块中) LocalTimezone (celery.utils.timeutils 中的类) LockFailed log (celery.Celery 属性) logger (celery.beat.Scheduler 属性) Logging (celery.app.log 中的类) LoggingProxy (celery.utils.log 中的类) loglevel (celery.utils.log.LoggingProxy 属性) lookup_route() (celery.app.routes.Router 方法) loop() (celery.worker.pidbox.gPidbox 方法) loop_args() (celery.worker.consumer.Consumer 方法) lpmerge() (在 celery.utils 模块中) LRUCache (celery.datastructures 中的类) (celery.utils.functional 中的类)

M

magenta() (celery.utils.term.colored 方法) mail (celery.loaders.base.BaseLoader 属性) mail_admins() (celery.Celery 方法) (celery.loaders.base.BaseLoader 方法) Mailer (celery.utils.mail 中的类) main (celery.Celery 属性) main() (在 celery.bin.celery 模块中) (在 celery.bin.worker 模块中) maintain_pool() (celery.concurrency.base.BasePool 方法) make_aware() (在 celery.utils.timeutils 模块中) make_request() (celery.task.http.HttpDispatch 方法) map() (celery.app.task.Task 方法) MapAnnotation (celery.app.annotations 中的类) MapRoute (celery.app.routes 中的类) mark_as_done() (celery.backends.base.BaseBackend 方法) mark_as_failure() (celery.backends.base.BaseBackend 方法) mark_as_retry() (celery.backends.base.BaseBackend 方法) mark_as_revoked() (celery.backends.base.BaseBackend 方法) mark_as_started() (celery.backends.base.BaseBackend 方法) mattrgetter() (在 celery.utils.functional 模块中) max-interval celery-beat 命令行选项 max_connections (celery.backends.redis.RedisBackend 属性) max_interval (celery.beat.Scheduler 属性) max_pool_size (celery.backends.mongodb.MongoBackend 属性) max_retries (celery.app.task.Task 属性) (Task 属性) MaxRetriesExceededError maybe_declare() (celery.backends.amqp.AMQPBackend.Producer 方法) maybe_detach() (celery.bin.worker.worker 方法) maybe_drop_privileges() (在 celery.platforms 模块中) maybe_due() (celery.beat.Scheduler 方法) maybe_evaluate() (在 celery.utils.functional 模块中) maybe_expire() (celery.worker.job.Request 方法) maybe_iso8601() (在 celery.utils.timeutils 模块中) maybe_list() (在 celery.utils.functional 模块中) maybe_make_aware() (celery.schedules.schedule 方法) (在 celery.utils.timeutils 模块中) maybe_patch_concurrency() (celery.bin.base.Command 方法) maybe_reraise() (在 celery.utils 模块中) maybe_s_to_ms() (在 celery.utils.timeutils 模块中) maybe_scale() (celery.worker.autoscale.Autoscaler 方法)

maybe_schedule() (在 celery.schedules 模块中) maybe_shutdown() (在 celery.worker.state 模块中) maybe_timedelta() (在 celery.utils.timeutils 模块中) mem_rss() (在 celery.utils.debug 模块中) memdump() (celery.app.control.Inspect 方法) (在 celery.utils.debug 模块中) memoize() (在 celery.utils.functional 模块中) memsample() (celery.app.control.Inspect 方法) merge() (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) (celery.worker.state.Persistent 方法) merge_inplace() (celery.beat.Scheduler 方法) merge_rules (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) message (celery.exceptions.Retry 属性) Message (celery.utils.mail 中的类) Message() (celery.backends.amqp.AMQPBackend.Exchange 方法) mget() (celery.backends.base.KeyValueStoreBackend 方法) (celery.backends.cache.CacheBackend 方法) (celery.backends.couchbase.CouchBaseBackend 方法) (celery.backends.redis.RedisBackend 方法) migrate_task() (在 celery.contrib.migrate 模块中) migrate_tasks() (在 celery.contrib.migrate 模块中) Mingle (celery.worker.consumer 中的类) minute (celery.schedules.crontab 属性) mlazy (celery.utils.functional 中的类) mlevel() (在 celery.utils.log 模块中) mode (celery.utils.log.LoggingProxy 属性) module_file() (在 celery.utils.imports 模块中) MongoBackend (celery.backends.mongodb 中的类) Monitor (celery.worker.autoreload.Autoreloader 属性) Monitor() (在 celery.worker.autoreload 模块中) month_of_year (celery.schedules.crontab 属性) move() (在 celery.contrib.migrate 模块中) move_by_idmap() (在 celery.contrib.migrate 模块中) move_by_taskmap() (在 celery.contrib.migrate 模块中) move_selection() (celery.events.cursesmon.CursesMonitor 方法) move_selection_down() (celery.events.cursesmon.CursesMonitor 方法) move_selection_up() (celery.events.cursesmon.CursesMonitor 方法) move_task_by_id() (在 celery.contrib.migrate 模块中) MP_LOG, [1] mro_lookup() (在 celery.utils.objects 模块中) multi_call() (celery.app.control.Control.Mailbox 方法) MultiTool (celery.bin.multi 中的类)

N

name (celery.app.task.Task 属性) (Task 属性) (celery.backends.amqp.AMQPBackend.Exchange 属性), [1] (celery.beat.ScheduleEntry 属性) (celery.bootsteps.Blueprint 属性) (celery.bootsteps.ConsumerStep 属性) (celery.bootsteps.StartStopStep 属性) (celery.bootsteps.Step 属性) (celery.contrib.batches.SimpleRequest 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) (celery.utils.log.LoggingProxy 属性) (celery.worker.WorkController.Blueprint 属性) (celery.worker.autoreload.WorkerComponent 属性) (celery.worker.autoscale.WorkerComponent 属性) (celery.worker.components.Beat 属性) (celery.worker.components.Consumer 属性) (celery.worker.components.Hub 属性) (celery.worker.components.Pool 属性) (celery.worker.components.Queues 属性) (celery.worker.components.StateDB 属性) (celery.worker.components.Timer 属性) (celery.worker.consumer.Agent 属性) (celery.worker.consumer.Connection 属性) (celery.worker.consumer.Consumer.Blueprint 属性) (celery.worker.consumer.Control 属性) (celery.worker.consumer.Events 属性) (celery.worker.consumer.Evloop 属性) (celery.worker.consumer.Gossip 属性) (celery.worker.consumer.Heart 属性) (celery.worker.consumer.Mingle 属性) (celery.worker.consumer.Tasks 属性) (celery.worker.job.Request 属性) names() (celery.bin.multi.MultiTool 方法) namespace (celery.app.control.Control.Mailbox 属性) (celery.bin.base.Command 属性) (celery.bin.celery.CeleryCommand 属性) (celery.bin.worker.worker 属性) nap() (celery.events.cursesmon.CursesMonitor 方法) needs_reconnect (celery.bin.amqp.AMQShell 属性) new_missing() (celery.app.amqp.Queues 方法) next() (celery.beat.ScheduleEntry 方法) (celery.concurrency.base.BasePool.Timer 方法) (celery.utils.timer2.Timer 方法) no_ack (celery.backends.amqp.AMQPBackend.Consumer 属性) no_color() (celery.utils.term.colored 方法) Node() (celery.app.control.Control.Mailbox 方法) node() (celery.utils.term.colored 方法) node_alive() (celery.bin.multi.MultiTool 方法) node_cls (celery.app.control.Control.Mailbox 属性)

node_format() (celery.bin.base.Command 方法) nodename() (在 celery.utils 模块中) nodesplit() (在 celery.utils 模块中) noop() (在 celery.utils.functional 模块中) NOSE_VERBOSE NotAPackage NotConfigured note() (celery.bin.amqp.AMQPAdmin 方法) (celery.bin.amqp.AMQShell 方法) (celery.bin.multi.MultiTool 方法) NotRegistered now() (celery.Celery 方法) (celery.loaders.base.BaseLoader 方法) (celery.schedules.crontab 方法) (celery.schedules.schedule 方法) nowfun (celery.schedules.crontab 属性) nullipotent num_processes (celery.concurrency.base.BasePool 属性) (celery.concurrency.gevent.TaskPool 属性) (celery.concurrency.prefork.TaskPool 属性)

O

obj (celery.bootsteps.StartStopStep 属性) (celery.datastructures.DictAttribute 属性) objgraph() (celery.app.control.Inspect 方法) oid (celery.app.control.Control.Mailbox 属性) (celery.backends.rpc.RPCBackend 属性) OK (celery.bin.multi.MultiTool 属性) on_accepted() (celery.worker.job.Request 方法) on_ack (celery.worker.job.Request 属性) on_after_init() (celery.apps.worker.Worker 方法) (celery.worker.WorkController 方法) on_apply() (celery.concurrency.base.BasePool 方法) (celery.concurrency.eventlet.TaskPool 方法) (celery.concurrency.gevent.TaskPool 方法) (celery.concurrency.threads.TaskPool 方法) on_before_init() (celery.apps.worker.Worker 方法) (celery.worker.WorkController 方法) on_bound() (celery.app.task.Task 类方法) on_change() (celery.worker.autoreload.Autoreloader 方法) (celery.worker.autoreload.BaseMonitor 方法) (celery.worker.autoreload.InotifyMonitor 方法) on_chord_part_return() (celery.backends.base.BaseBackend 方法) (celery.backends.base.KeyValueStoreBackend 方法) on_cleanup() (celery.events.snapshot.Polaroid 方法) on_close() (celery.concurrency.base.BasePool 方法) (celery.concurrency.prefork.TaskPool 方法) (celery.worker.WorkController 方法) (celery.worker.consumer.Consumer 方法) on_concurrency_setup() (celery.bin.base.Command 方法) (celery.bin.celery.CeleryCommand 方法) on_consume_ready() (celery.events.EventReceiver 方法) on_consumer_ready() (celery.apps.worker.Worker 方法) (celery.worker.WorkController 方法) on_crash() (celery.utils.threads.bgThread 方法) on_decode_error (celery.backends.amqp.AMQPBackend.Consumer 属性) on_decode_error() (celery.worker.consumer.Consumer 方法) on_disabled (celery.events.EventDispatcher 属性) on_elect() (celery.worker.consumer.Gossip 方法) on_elect_ack() (celery.worker.consumer.Gossip 方法) on_enabled (celery.events.EventDispatcher 属性) on_error() (celery.bin.base.Command 方法) on_event() (celery.events.dumper.Dumper 方法) on_event_loop_close() (celery.worker.autoreload.Autoreloader 方法) (celery.worker.autoreload.BaseMonitor 方法) (celery.worker.autoreload.InotifyMonitor 方法) (celery.worker.autoreload.KQueueMonitor 方法) on_failed() (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) on_failure() (celery.app.task.Task 方法) (celery.worker.job.Request 方法) on_hard_timeout() (celery.concurrency.base.BasePool 方法) on_heartbeat() (celery.events.state.State.Worker 方法) (celery.events.state.Worker 方法) on_init() (celery.worker.autoreload.Autoreloader 方法) on_init_blueprint() (celery.apps.worker.Worker 方法) (celery.worker.WorkController 方法) on_invalid_task() (celery.worker.consumer.Consumer 方法) on_message (celery.backends.amqp.AMQPBackend.Consumer 属性) on_message() (celery.worker.consumer.Gossip 方法) (celery.worker.pidbox.Pidbox 方法) on_node_join() (celery.worker.consumer.Gossip 方法) on_node_leave() (celery.worker.consumer.Gossip 方法) on_node_lost() (celery.worker.consumer.Gossip 方法) on_offline() (celery.events.state.State.Worker 方法) (celery.events.state.Worker 方法) on_online() (celery.events.state.State.Worker 方法) (celery.events.state.Worker 方法) on_process_cleanup() (celery.loaders.base.BaseLoader 方法)

on_readable() (celery.worker.autoreload.InotifyMonitor 方法) on_ready() (celery.worker.consumer.Consumer 方法) on_received() (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) on_reject (celery.worker.job.Request 属性) on_reply_declare() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.rpc.RPCBackend 方法) on_retried() (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) on_retry() (celery.app.task.Task 方法) (celery.worker.job.Request 方法) on_return (celery.backends.amqp.AMQPBackend.Producer 属性) on_revoked() (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) on_sent() (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) on_shutter() (celery.events.snapshot.Polaroid 方法) on_soft_timeout() (celery.concurrency.base.BasePool 方法) on_start() (celery.apps.worker.Worker 方法) (celery.concurrency.base.BasePool 方法) (celery.concurrency.eventlet.TaskPool 方法) (celery.concurrency.gevent.TaskPool 方法) (celery.concurrency.prefork.TaskPool 方法) (celery.concurrency.threads.TaskPool 方法) (celery.worker.WorkController 方法) on_started() (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) on_stop() (celery.concurrency.base.BasePool 方法) (celery.concurrency.eventlet.TaskPool 方法) (celery.concurrency.gevent.TaskPool 方法) (celery.concurrency.prefork.TaskPool 方法) (celery.concurrency.threads.TaskPool 方法) (celery.worker.pidbox.Pidbox 方法) (celery.worker.pidbox.gPidbox 方法) on_stopped() (celery.worker.WorkController 方法) on_succeeded() (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) on_success() (celery.app.task.Task 方法) (celery.worker.job.Request 方法) on_task_call() (celery.backends.base.BaseBackend 方法) (celery.backends.rpc.RPCBackend 方法) on_task_init() (celery.loaders.base.BaseLoader 方法) on_terminate() (celery.concurrency.base.BasePool 方法) (celery.concurrency.prefork.TaskPool 方法) on_tick (celery.concurrency.base.BasePool.Timer 属性) (celery.utils.timer2.Timer 属性) on_timeout() (celery.worker.job.Request 方法) on_timer_error() (celery.worker.components.Timer 方法) on_timer_tick() (celery.worker.components.Timer 方法) on_unknown_event() (celery.events.state.State.Task 方法) (celery.events.state.Task 方法) on_unknown_message() (celery.worker.consumer.Consumer 方法) on_unknown_task() (celery.worker.consumer.Consumer 方法) on_usage_error() (celery.bin.base.Command 方法) (celery.bin.celery.CeleryCommand 方法) on_worker_init() (celery.loaders.base.BaseLoader 方法) on_worker_process_init() (celery.loaders.base.BaseLoader 方法) on_worker_shutdown() (celery.loaders.base.BaseLoader 方法) onecmd() (celery.bin.amqp.AMQShell 方法) online_str (celery.events.cursesmon.CursesMonitor 属性) open() (celery.platforms.DaemonContext 方法) (celery.worker.state.Persistent 方法) Option (celery.app.defaults 中的类) (celery.bin.base 中的类) option_list (celery.bin.base.Command 属性) options (celery.backends.mongodb.MongoBackend 属性) (celery.beat.ScheduleEntry 属性) origin (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) osx_proxy_detection_workaround() (celery.apps.worker.Worker 方法) out() (celery.bin.base.Command 方法) override_backends (celery.loaders.base.BaseLoader 属性)

P

padlist() (在 celery.utils.functional 模块中) Panel (celery.worker.control 中的类) parent (celery.result.ResultBase 属性) parse() (celery.schedules.crontab_parser 方法) parse_doc() (celery.bin.base.Command 方法) parse_gid() (在 celery.platforms 模块中) parse_iso8601() (在 celery.utils.iso8601 模块中) parse_options() (celery.bin.base.Command 方法) parse_preload_options() (celery.bin.base.Command 方法) parse_uid() (在 celery.platforms 模块中) ParseException parseline() (celery.bin.amqp.AMQShell 方法) Parser (celery.bin.base.Command 属性) passive (celery.backends.amqp.AMQPBackend.Exchange 属性) password (celery.backends.couchbase.CouchBaseBackend 属性) (celery.backends.mongodb.MongoBackend 属性) (celery.backends.redis.RedisBackend 属性) patch_all() (celery.worker.consumer.Evloop 方法) PATH path (celery.platforms.Pidfile 属性) PENDING state PENDING() (在 celery.states 模块中) periodic() (celery.app.registry.TaskRegistry 方法) (celery.worker.consumer.Gossip 方法) persistence (celery.beat.PersistentScheduler 属性) persistent (celery.backends.amqp.AMQPBackend 属性) (celery.backends.base.BaseBackend 属性) (celery.backends.rpc.RPCBackend 属性) Persistent (celery.worker.state 中的类) PERSISTENT_DELIVERY_MODE (celery.backends.amqp.AMQPBackend.Exchange 属性) PersistentScheduler (celery.beat 中的类) Pickler (celery.Celery 属性) pid (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) Pidbox (celery.worker.pidbox 中的类) Pidfile (celery.platforms 中的类) pidlock (celery.worker.WorkController 属性) ping control ping() (celery.app.control.Control 方法) (celery.app.control.Inspect 方法) pluralize() (在 celery.utils.text 模块中) Polaroid (celery.events.snapshot 中的类) poll() (celery.backends.amqp.AMQPBackend 方法) pool, [1] (celery.Celery 属性) Pool (celery.concurrency.prefork.TaskPool 属性) (celery.worker.components 中的类) pool (celery.worker.consumer.Consumer 属性) (celery.worker.WorkController 属性) pool_grow() (celery.app.control.Control 方法) pool_restart control pool_shrink() (celery.app.control.Control 方法) pop_value() (celery.datastructures.LimitedSet 方法)

port (celery.backends.couchbase.CouchBaseBackend 属性) (celery.backends.mongodb.MongoBackend 属性) (celery.backends.redis.RedisBackend 属性) post_async() (celery.task.http.URL 方法) precedence() (在 celery.states 模块中) prefetch count prefetch multiplier preload_options (celery.bin.base.Command 属性) prepare() (在 celery.app.annotations 模块中) (在 celery.app.routes 模块中) prepare_args() (celery.bin.base.Command 方法) (celery.worker.WorkController 方法) prepare_exception() (celery.backends.base.BaseBackend 方法) prepare_expires() (celery.backends.base.BaseBackend 方法) prepare_parser() (celery.bin.base.Command 方法) prepare_persistent() (celery.backends.base.BaseBackend 方法) prepare_prog_name() (celery.bin.celery.CeleryCommand 方法) prepare_value() (celery.backends.base.BaseBackend 方法) preparse_options() (celery.bin.base.Command 方法) pretty() (celery.bin.base.Command 方法) (在 celery.utils.text 模块中) pretty_dict_ok_error() (celery.bin.base.Command 方法) pretty_list() (celery.bin.base.Command 方法) PrivateKey (celery.security.key 中的类) process() (celery.bin.base.Option 方法) (celery.events.EventReceiver 方法) process_() (celery.worker.autoreload.InotifyMonitor 方法) process_cleanup() (celery.backends.base.BaseBackend 方法) (celery.backends.cassandra.CassandraBackend 方法) (celery.backends.mongodb.MongoBackend 方法) process_cmdline_config() (celery.bin.base.Command 方法) process_destructor() (在 celery.concurrency.prefork 模块中) process_IN_ATTRIB() (celery.worker.autoreload.InotifyMonitor 方法) process_IN_MODIFY() (celery.worker.autoreload.InotifyMonitor 方法) process_initializer() (在 celery.concurrency.prefork 模块中) processed (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) processes (celery.worker.autoscale.Autoscaler 属性) producer_or_acquire() (celery.Celery 方法) prog_name (celery.bin.base.Command 属性) (celery.bin.celery.CeleryCommand 属性) prompt (celery.bin.amqp.AMQShell 属性) prompt_fmt (celery.bin.amqp.AMQShell 属性) PROPAGATE_STATES state protocol (celery.worker.state.Persistent 属性) ps() (在 celery.utils.debug 模块中) publish() (celery.backends.amqp.AMQPBackend.Exchange 方法) (celery.backends.amqp.AMQPBackend.Producer 方法) (celery.events.EventDispatcher 方法) publisher (celery.beat.Scheduler 属性) (celery.events.EventDispatcher 属性) publisher_pool (celery.app.amqp.AMQP 属性) purge() (celery.app.control.Control 方法) (celery.backends.amqp.AMQPBackend.Consumer 方法) (celery.datastructures.LimitedSet 方法) purge_messages() (celery.apps.worker.Worker 方法) pyimplementation() (在 celery.platforms 模块中) Python 提高建议 PEP 8

Q

qos qos() (celery.backends.amqp.AMQPBackend.Consumer 方法) qty (celery.worker.autoscale.Autoscaler 属性) qualname() (在 celery.utils.imports 模块中) query_task() (celery.app.control.Inspect 方法) Queue (celery.backends.amqp.AMQPBackend 属性) queue (celery.concurrency.base.BasePool.Timer 属性) (celery.concurrency.eventlet.TaskPool.Timer.Schedule 属性) (celery.concurrency.gevent.TaskPool.Timer.Schedule 属性) (celery.utils.timer2.Timer 属性)

QueueNotFound Queues (celery.app.amqp 中的类) queues (celery.app.amqp.AMQP 属性) (celery.backends.amqp.AMQPBackend.Consumer 属性) Queues (celery.worker.components 中的类) Queues() (celery.app.amqp.AMQP 方法) quiet (celery.backends.couchbase.CouchBaseBackend 属性)

R

rate() (在 celery.utils.timeutils 模块中) rate_limit control rate_limit (celery.app.task.Task 属性) (Task 属性) rate_limit() (celery.app.control.Control 方法) Rdb (celery.contrib.rdb 中的类) read_configuration() (celery.loaders.base.BaseLoader 方法) (celery.loaders.default.Loader 方法) read_pid() (celery.platforms.Pidfile 方法) readline() (celery.events.cursesmon.CursesMonitor 方法) ready (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) ready() (celery.result.AsyncResult 方法) (celery.result.EagerResult 方法) (celery.result.ResultSet 方法) READY_STATES state READY_STATES (celery.backends.base.BaseBackend 属性) rebuild_taskheap() (celery.events.state.State 方法) receive() (celery.backends.amqp.AMQPBackend.Consumer 方法) received (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) RECEIVED() (在 celery.states 模块中) Receiver (celery.events.Events 属性) receivers (celery.utils.dispatch.Signal 属性) (celery.utils.dispatch.signal.Signal 属性) recover() (celery.backends.amqp.AMQPBackend.Consumer 方法) red() (celery.utils.term.colored 方法) redirect_stdouts() (celery.app.log.Logging 方法) redirect_stdouts_to_logger() (celery.app.log.Logging 方法) redirect_to_null() (celery.platforms.DaemonContext 方法) redis (celery.backends.redis.RedisBackend 属性) RedisBackend (celery.backends.redis 中的类) reentrant regen() (在 celery.utils.functional 模块中) register() (celery.app.registry.TaskRegistry 方法) (celery.worker.control.Panel 类方法) register_auth() (在 celery.security.serialization 模块中) register_callback() (celery.backends.amqp.AMQPBackend.Consumer 方法) register_command() (celery.bin.celery.CeleryCommand 类方法) register_timer() (celery.worker.consumer.Gossip 方法) register_with_event_loop() (celery.concurrency.base.BasePool 方法) (celery.concurrency.prefork.TaskPool 方法) (celery.worker.WorkController 方法) (celery.worker.autoreload.Autoreloader 方法) (celery.worker.autoreload.InotifyMonitor 方法) (celery.worker.autoreload.KQueueMonitor 方法) (celery.worker.autoreload.StatMonitor 方法) (celery.worker.autoreload.WorkerComponent 方法) (celery.worker.autoscale.WorkerComponent 方法) (celery.worker.components.Pool 方法) (celery.worker.consumer.Consumer 方法) registered() (celery.app.control.Inspect 方法) registered_tasks() (celery.app.control.Inspect 方法) regular() (celery.app.registry.TaskRegistry 方法) reject() (celery.worker.job.Request 方法) rejected_msg (celery.worker.job.Request 属性) relative (celery.schedules.schedule 属性) release() (celery.backends.amqp.AMQPBackend.Producer 方法) (celery.platforms.Pidfile 方法) reload() (celery.worker.WorkController 方法) reload_from_cwd() (在 celery.utils.imports 模块中) reload_group_result() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.base.BaseBackend 方法) reload_task_result() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.base.BaseBackend 方法) remaining() (在 celery.utils.timeutils 模块中) remaining_delta() (celery.schedules.crontab 方法) remaining_estimate() (celery.schedules.crontab 方法) (celery.schedules.schedule 方法) RemoteExecuteError remove() (celery.platforms.Pidfile 方法) (celery.result.ResultSet 方法) (hub 方法) remove_by (celery.app.defaults.Option 属性) remove_if_stale() (celery.platforms.Pidfile 方法) replace() (celery.signature 方法) reply_exchange (celery.app.control.Control.Mailbox 属性) reply_exchange_fmt (celery.app.control.Control.Mailbox 属性) reply_queue (celery.app.control.Control.Mailbox 属性) reply_to (celery.worker.job.Request 属性) report() (celery.app.control.Inspect 方法) repr_result() (celery.worker.job.Request 方法) republish() (在 celery.contrib.migrate 模块中) request (celery.app.task.Task 属性) Request (celery.worker.job 中的类) request (Task 属性) request_dict (celery.worker.job.Request 属性)

requires (celery.bootsteps.ConsumerStep 属性) (celery.bootsteps.StartStopStep 属性) (celery.bootsteps.Step 属性) (celery.worker.autoreload.WorkerComponent 属性) (celery.worker.autoscale.WorkerComponent 属性) (celery.worker.components.Beat 属性) (celery.worker.components.Consumer 属性) (celery.worker.components.Hub 属性) (celery.worker.components.Pool 属性) (celery.worker.components.Queues 属性) (celery.worker.components.StateDB 属性) (celery.worker.components.Timer 属性) (celery.worker.consumer.Agent 属性) (celery.worker.consumer.Connection 属性) (celery.worker.consumer.Control 属性) (celery.worker.consumer.Events 属性) (celery.worker.consumer.Evloop 属性) (celery.worker.consumer.Gossip 属性) (celery.worker.consumer.Heart 属性) (celery.worker.consumer.Mingle 属性) (celery.worker.consumer.Tasks 属性) reraise_errors() (在 celery.security.utils 模块中) reserve() (celery.beat.Scheduler 方法) reserved() (celery.app.control.Inspect 方法) reserved_requests() (在 celery.worker.state 模块中) reset() (celery.utils.term.colored 方法) (celery.worker.pidbox.Pidbox 方法) (celery.worker.pidbox.gPidbox 方法) reset_multiprocessing_logger() (在 celery.utils.log 模块中) reset_rate_limits() (celery.worker.consumer.Consumer 方法) (consumer 方法) reset_worker_optimizations() (在 celery.app.trace 模块中) resetscreen() (celery.events.cursesmon.CursesMonitor 方法) resolve_all() (在 celery.app.annotations 模块中) respects_app_option (celery.bin.base.Command 属性) respond() (celery.bin.amqp.AMQShell 方法) restart() (celery.bin.multi.MultiTool 方法) (celery.bootsteps.Blueprint 方法) (celery.concurrency.base.BasePool 方法) (celery.concurrency.prefork.TaskPool 方法) restart_count (celery.worker.consumer.Consumer 属性) restore() (celery.result.GroupResult 类方法) (celery.utils.serialization.UnpickleableExceptionWrapper 方法) restore_group() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.base.BaseBackend 方法) result (celery.backends.database.models.Task 属性) (celery.backends.database.models.TaskSet 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) (celery.result.AsyncResult 属性) (celery.result.EagerResult 属性) result_from_tuple() (在 celery.result 模块中) ResultBase (celery.result 中的类) results (celery.result.GroupResult 属性) (celery.result.ResultSet 属性) ResultSession() (celery.backends.database.DatabaseBackend 方法) (在 celery.backends.database.session 模块中) ResultSet (celery.result 中的类) retcode (celery.bin.multi.MultiTool 属性) retried (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) retries (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) RETRY state Retry retry() (celery.app.task.Task 方法) RETRY() (在 celery.states 模块中) retry_msg (celery.worker.job.Request 属性) retry_policy (celery.backends.amqp.AMQPBackend 属性) retval (celery.app.trace.TraceInfo 属性) reverse() (celery.utils.term.colored 方法) revive() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.amqp.AMQPBackend.Consumer 方法) (celery.backends.amqp.AMQPBackend.Producer 方法) revoke control revoke() (celery.app.control.Control 方法) (celery.result.AsyncResult 方法) (celery.result.EagerResult 方法) (celery.result.ResultSet 方法) revoke_selection() (celery.events.cursesmon.CursesMonitor 方法) REVOKED state revoked (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) revoked() (celery.app.control.Inspect 方法) (celery.worker.job.Request 方法) REVOKED() (在 celery.states 模块中) revoked() (在 celery.worker.state 模块中) rkey() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.rpc.RPCBackend 方法) route() (celery.app.routes.Router 方法) route_for_task() (celery.app.routes.MapRoute 方法) router (celery.app.amqp.AMQP 属性) Router (celery.app.routes 中的类) Router() (celery.app.amqp.AMQP 方法) routes (celery.app.amqp.AMQP 属性) routing_key (celery.backends.amqp.AMQPBackend.Producer 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) RPCBackend (celery.backends.rpc 中的类) RPCBackend.Consumer (celery.backends.rpc 中的类) RUN (celery.concurrency.base.BasePool 属性) run() (celery.app.task.Task 方法) (celery.apps.beat.Beat 方法) (celery.bin.amqp.AMQPAdmin 方法) (celery.bin.amqp.amqp 方法) (celery.bin.base.Command 方法) (celery.bin.beat.beat 方法) (celery.bin.events.events 方法) (celery.bin.graph.graph 方法) (celery.bin.worker.worker 方法) (celery.concurrency.base.BasePool.Timer 方法) (celery.contrib.batches.Batches 方法) (celery.utils.threads.bgThread 方法) (celery.utils.timer2.Timer 方法) run_evcam() (celery.bin.events.events 方法) run_evdump() (celery.bin.events.events 方法) run_evtop() (celery.bin.events.events 方法) run_from_argv() (celery.bin.base.Command 方法) (celery.bin.worker.worker 方法) running (celery.concurrency.base.BasePool.Timer 属性) (celery.utils.timer2.Timer 属性) runtime (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) rusage() (celery.worker.WorkController 方法)

S

s() (celery.app.task.Task 方法) safe_add_str() (celery.events.cursesmon.CursesMonitor 方法) safe_ref() (在 celery.utils.dispatch.saferef 模块中) sample() (在 celery.utils.debug 模块中) sample_mem() (在 celery.utils.debug 模块中) save() (celery.result.GroupResult 方法) (celery.worker.state.Persistent 方法) save_group() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.base.BaseBackend 方法) say() (celery.bin.amqp.AMQShell 方法) (celery.bin.multi.MultiTool 方法) (celery.events.dumper.Dumper 方法) say_chat() (celery.bin.base.Command 方法) say_remote_command_reply() (celery.bin.base.Command 方法) scale_down() (celery.worker.autoscale.Autoscaler 方法) scale_up() (celery.worker.autoscale.Autoscaler 方法) schedule (celery.beat.PersistentScheduler 属性) (celery.beat.ScheduleEntry 属性) (celery.beat.Scheduler 属性) Schedule (celery.concurrency.base.BasePool.Timer 属性) schedule (celery.schedules 中的类) Schedule (celery.utils.timer2.Timer 属性) Schedule() (在 celery.utils.timer2 模块中) scheduled() (celery.app.control.Inspect 方法) ScheduleEntry (celery.beat 中的类) scheduler (celery.apps.beat.Beat.Service 属性) Scheduler (celery.beat 中的类) scheduler (celery.beat.Service 属性) scheduler_cls (celery.apps.beat.Beat.Service 属性) (celery.beat.Service 属性) SchedulingError screen_delay (celery.events.cursesmon.CursesMonitor 属性) screen_height (celery.events.cursesmon.CursesMonitor 属性) screen_width (celery.events.cursesmon.CursesMonitor 属性) seconds (celery.schedules.schedule 属性) SecureSerializer (celery.security.serialization 中的类) SecurityError select() (celery.app.amqp.Queues 方法) select_add() (celery.app.amqp.Queues 方法) select_queues() (celery.Celery 方法) select_remove() (celery.app.amqp.Queues 方法) select_subset() (celery.app.amqp.Queues 方法) selected_position (celery.events.cursesmon.CursesMonitor 属性) selected_str (celery.events.cursesmon.CursesMonitor 属性) selected_task (celery.events.cursesmon.CursesMonitor 属性) selection_info() (celery.events.cursesmon.CursesMonitor 方法) selection_rate_limit() (celery.events.cursesmon.CursesMonitor 方法) selection_result() (celery.events.cursesmon.CursesMonitor 方法) selection_traceback() (celery.events.cursesmon.CursesMonitor 方法) semaphore (celery.worker.WorkController 属性) send() (celery.events.EventDispatcher 方法) (celery.utils.dispatch.Signal 方法) (celery.utils.dispatch.signal.Signal 方法) (celery.utils.mail.ErrorMail 方法) (celery.utils.mail.Mailer 方法) send_all() (celery.bootsteps.Blueprint 方法) send_error_emails (celery.app.task.Task 属性) (Task 属性) send_event() (celery.worker.job.Request 方法) send_robust() (celery.utils.dispatch.Signal 方法) (celery.utils.dispatch.signal.Signal 方法) send_task() (celery.beat.Scheduler 方法) (celery.Celery 方法) SendmailWarning sent (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) serializable() (celery.result.AsyncResult 方法) (celery.result.GroupResult 方法) serialize() (celery.security.serialization.SecureSerializer 方法) serializer (celery.app.task.Task 属性) (Task 属性) (celery.backends.amqp.AMQPBackend.Producer 属性) SERVER_EMAIL setting servers (celery.backends.cache.CacheBackend 属性) (celery.backends.cassandra.CassandraBackend 属性), [1] Service (celery.beat 中的类) set() (celery.backends.base.KeyValueStoreBackend 方法) (celery.backends.cache.CacheBackend 方法) (celery.backends.couchbase.CouchBaseBackend 方法) (celery.backends.redis.RedisBackend 方法) (celery.signature 方法) set_current() (celery.Celery 方法) set_default_app() (在 celery._state 模块中) set_in_sighandler() (在 celery.utils.log 模块中) set_mp_process_title() (在 celery.platforms 模块中) set_process_status() (celery.apps.worker.Worker 方法) (celery.bin.events.events 方法) set_process_title() (celery.apps.beat.Beat 方法) (在 celery.platforms 模块中) set_schedule() (celery.beat.PersistentScheduler 方法) (celery.beat.Scheduler 方法) set_trace() (在 celery.contrib.rdb 模块中) setdefault() (celery.datastructures.ConfigurationView 方法) (celery.datastructures.DictAttribute 方法) setgid() (在 celery.platforms 模块中) setgroups() (在 celery.platforms 模块中) setter() (celery.utils.cached_property 方法) setting ADMINS BROKER_CONNECTION_MAX_RETRIES BROKER_CONNECTION_RETRY BROKER_CONNECTION_TIMEOUT BROKER_FAILOVER_STRATEGY BROKER_HEARTBEAT BROKER_HEARTBEAT_CHECKRATE BROKER_LOGIN_METHOD BROKER_POOL_LIMIT BROKER_TRANSPORT BROKER_TRANSPORT_OPTIONS BROKER_URL BROKER_USE_SSL CASSANDRA_COLUMN_FAMILY CASSANDRA_DETAILED_MODE CASSANDRA_KEYSPACE CASSANDRA_READ_CONSISTENCY CASSANDRA_SERVERS CASSANDRA_WRITE_CONSISTENCY CELERYBEAT_MAX_LOOP_INTERVAL CELERYBEAT_SCHEDULE CELERYBEAT_SCHEDULER CELERYBEAT_SCHEDULE_FILENAME CELERYD_AUTORELOADER CELERYD_AUTOSCALER CELERYD_CONCURRENCY CELERYD_CONSUMER CELERYD_FORCE_EXECV CELERYD_HIJACK_ROOT_LOGGER CELERYD_LOG_COLOR CELERYD_LOG_FORMAT CELERYD_MAX_TASKS_PER_CHILD CELERYD_POOL CELERYD_POOL_RESTARTS CELERYD_PREFETCH_MULTIPLIER CELERYD_STATE_DB CELERYD_TASK_LOG_FORMAT CELERYD_TASK_SOFT_TIME_LIMIT CELERYD_TASK_TIME_LIMIT CELERYD_TIMER CELERYD_TIMER_PRECISION CELERYD_WORKER_LOST_WAIT CELERYMON_LOG_FORMAT CELERY_ACCEPT_CONTENT CELERY_ACKS_LATE CELERY_ALWAYS_EAGER CELERY_ANNOTATIONS CELERY_BROADCAST_EXCHANGE CELERY_BROADCAST_EXCHANGE_TYPE CELERY_BROADCAST_QUEUE CELERY_CACHE_BACKEND CELERY_CACHE_BACKEND_OPTIONS CELERY_CHORD_PROPAGATES CELERY_COUCHBASE_BACKEND_SETTINGS CELERY_CREATE_MISSING_QUEUES CELERY_DEFAULT_DELIVERY_MODE CELERY_DEFAULT_EXCHANGE CELERY_DEFAULT_EXCHANGE_TYPE CELERY_DEFAULT_QUEUE CELERY_DEFAULT_RATE_LIMIT CELERY_DEFAULT_ROUTING_KEY CELERY_DISABLE_RATE_LIMITS CELERY_EAGER_PROPAGATES_EXCEPTIONS CELERY_ENABLE_REMOTE_CONTROL CELERY_ENABLE_UTC CELERY_EVENT_QUEUE_EXPIRES CELERY_EVENT_QUEUE_TTL CELERY_EVENT_SERIALIZER CELERY_IGNORE_RESULT CELERY_IMPORTS CELERY_INCLUDE CELERY_MAX_CACHED_RESULTS CELERY_MESSAGE_COMPRESSION CELERY_MONGODB_BACKEND_SETTINGS CELERY_QUEUES CELERY_QUEUE_HA_POLICY CELERY_REDIRECT_STDOUTS CELERY_REDIRECT_STDOUTS_LEVEL CELERY_REDIS_MAX_CONNECTIONS CELERY_RESULT_BACKEND CELERY_RESULT_DBURI CELERY_RESULT_DB_SHORT_LIVED_SESSIONS CELERY_RESULT_DB_SHORT_LIVED_SESSIONS = True CELERY_RESULT_DB_TABLENAMES CELERY_RESULT_ENGINE_OPTIONS CELERY_RESULT_EXCHANGE CELERY_RESULT_EXCHANGE_TYPE CELERY_RESULT_PERSISTENT CELERY_RESULT_SERIALIZER CELERY_ROUTES CELERY_SECURITY_CERTIFICATE CELERY_SECURITY_CERT_STORE CELERY_SECURITY_KEY CELERY_SEND_EVENTS CELERY_SEND_TASK_ERROR_EMAILS CELERY_SEND_TASK_SENT_EVENT CELERY_STORE_ERRORS_EVEN_IF_IGNORED CELERY_TASK_PUBLISH_RETRY CELERY_TASK_PUBLISH_RETRY_POLICY CELERY_TASK_RESULT_EXPIRES CELERY_TASK_SERIALIZER CELERY_TIMEZONE CELERY_TRACK_STARTED CELERY_WORKER_DIRECT EMAIL_HOST EMAIL_HOST_PASSWORD EMAIL_HOST_USER EMAIL_PORT EMAIL_TIMEOUT EMAIL_USE_SSL EMAIL_USE_TLS SERVER_EMAIL Settings (celery.app.utils 中的类) setuid() (在 celery.platforms 模块中) setup() (celery.app.log.Logging 方法) setup_app_from_commandline() (celery.bin.base.Command 方法) setup_defaults() (celery.worker.WorkController 方法) setup_handlers() (celery.app.log.Logging 方法) setup_includes() (celery.worker.WorkController 方法) setup_instance() (celery.worker.WorkController 方法) setup_logger() (celery.app.log.Logging 方法) setup_logging signal setup_logging() (celery.apps.beat.Beat 方法) (celery.apps.worker.Worker 方法) setup_logging_subsystem() (celery.app.log.Logging 方法) setup_queues() (celery.worker.WorkController 方法) setup_schedule() (celery.beat.PersistentScheduler 方法) (celery.beat.Scheduler 方法) setup_security() (celery.Celery 方法) (在 celery.security 模块中) setup_settings() (celery.loaders.default.Loader 方法) setup_task_loggers() (celery.app.log.Logging 方法) setup_worker_optimizations() (在 celery.app.trace 模块中) shared_task() (在 celery.app.builtins 模块中) Shell (celery.bin.amqp.AMQPAdmin 属性) shortinfo() (celery.worker.job.Request 方法)

should_send() (celery.app.task.Task.ErrorMail 方法) (celery.utils.mail.ErrorMail 方法) should_sync() (celery.beat.Scheduler 方法) should_use_eventloop() (celery.worker.WorkController 方法) show() (celery.bin.multi.MultiTool 方法) show_body (celery.bin.base.Command 属性) show_reply (celery.bin.base.Command 属性) shrink() (celery.concurrency.gevent.TaskPool 方法) shutdown control shutdown() (celery.bootsteps.ConsumerStep 方法) (celery.worker.consumer.Connection 方法) (celery.worker.consumer.Consumer 方法) (celery.worker.consumer.Consumer.Blueprint 方法) (celery.worker.consumer.Events 方法) (celery.worker.consumer.Heart 方法) (celery.worker.consumer.Tasks 方法) (celery.worker.pidbox.Pidbox 方法) shutdown_nodes() (celery.bin.multi.MultiTool 方法) shutdown_worker() (celery.loaders.base.BaseLoader 方法) shutter() (celery.events.snapshot.Polaroid 方法) shutter_signal (celery.events.snapshot.Polaroid 属性) si() (celery.app.task.Task 方法) sign() (celery.security.key.PrivateKey 方法) signal after_setup_logger after_setup_task_logger after_task_publish beat_embedded_init beat_init before_task_publish celeryd_after_setup celeryd_init eventlet_pool_apply eventlet_pool_postshutdown eventlet_pool_preshutdown eventlet_pool_started import_modules setup_logging task_failure task_postrun task_prerun task_revoked task_sent task_success user_preload_options worker_init worker_process_init worker_process_shutdown worker_ready worker_shutdown Signal (celery.utils.dispatch 中的类) (celery.utils.dispatch.signal 中的类) signal_consumer_close() (celery.worker.WorkController 方法) signal_node() (celery.bin.multi.MultiTool 方法) signal_safe (celery.concurrency.base.BasePool 属性) (celery.concurrency.eventlet.TaskPool 属性) (celery.concurrency.gevent.TaskPool 属性) signature (celery 中的类) signature() (celery.Celery 方法) simple_format() (celery.bin.base.Command 方法) SimpleRequest (celery.contrib.batches 中的类) soft_time_limit (celery.app.task.Task 属性) (Task 属性) SoftTimeLimitExceeded SOFTWARE_INFO() (在 celery.worker.state 模块中) Spec (celery.bin.amqp 中的类) splash() (celery.bin.multi.MultiTool 方法) starmap() (celery.app.task.Task 方法) start() (celery.apps.beat.Beat.Service 方法) (celery.Celery 方法) (celery.beat.Service 方法) (celery.bin.multi.MultiTool 方法) (celery.bootsteps.Blueprint 方法) (celery.bootsteps.ConsumerStep 方法) (celery.bootsteps.StartStopStep 方法) (celery.concurrency.base.BasePool 方法) (celery.concurrency.eventlet.TaskPool.Timer 方法) (celery.concurrency.gevent.TaskPool.Timer 方法) (celery.worker.WorkController 方法) (celery.worker.autoreload.BaseMonitor 方法) (celery.worker.autoreload.InotifyMonitor 方法) (celery.worker.autoreload.KQueueMonitor 方法) (celery.worker.autoreload.StatMonitor 方法) (celery.worker.components.Hub 方法) (celery.worker.consumer.Connection 方法) (celery.worker.consumer.Consumer 方法) (celery.worker.consumer.Events 方法) (celery.worker.consumer.Evloop 方法) (celery.worker.consumer.Gossip 方法) (celery.worker.consumer.Heart 方法) (celery.worker.consumer.Mingle 方法) (celery.worker.consumer.Tasks 方法) (celery.worker.heartbeat.Heart 方法) (celery.worker.pidbox.Pidbox 方法) (celery.worker.pidbox.gPidbox 方法) start_filter() (在 celery.contrib.migrate 模块中) start_scheduler() (celery.apps.beat.Beat 方法) STARTED state started (celery.bootsteps.Blueprint 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) STARTED() (在 celery.states 模块中) StartStopStep (celery.bootsteps 中的类) startup_info() (celery.apps.beat.Beat 方法) (celery.apps.worker.Worker 方法) stat (celery.utils.sysinfo.df 属性) state ALL_STATES EXCEPTION_STATES FAILURE PENDING PROPAGATE_STATES READY_STATES RETRY REVOKED STARTED SUCCESS UNREADY_STATES state (celery.app.trace.TraceInfo 属性) (celery.bootsteps.Blueprint 属性) State (celery.contrib.migrate 中的类) (celery.events.Events 属性) (celery.events.state 中的类) state (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) (celery.result.AsyncResult 属性) (celery.result.EagerResult 属性) (celery.states 中的类) (celery.worker.WorkController 属性) State.Task (celery.events.state 中的类) State.Worker (celery.events.state 中的类) state_to_name (celery.bootsteps.Blueprint 属性) statedb StateDB (celery.worker.components 中的类) StatMonitor (celery.worker.autoreload 中的类) stats() (celery.app.control.Inspect 方法) (celery.worker.WorkController 方法) status (celery.backends.database.models.Task 属性) (celery.bin.base.Command.Error 属性) (celery.bin.base.Command.UsageError 属性) (celery.bin.base.Error 属性) (celery.bin.base.UsageError 属性) (celery.result.AsyncResult 属性) (celery.result.EagerResult 属性) status_string (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) Step (celery.bootsteps 中的类) steps (celery.Celery 属性) stop() (celery.apps.beat.Beat.Service 方法) (celery.beat.Service 方法) (celery.bin.multi.MultiTool 方法) (celery.bootsteps.Blueprint 方法) (celery.bootsteps.ConsumerStep 方法) (celery.bootsteps.StartStopStep 方法) (celery.concurrency.base.BasePool 方法) (celery.concurrency.base.BasePool.Timer 方法) (celery.concurrency.eventlet.TaskPool.Timer 方法) (celery.concurrency.gevent.TaskPool.Timer 方法) (celery.utils.threads.bgThread 方法) (celery.utils.timer2.Timer 方法) (celery.worker.WorkController 方法) (celery.worker.autoreload.Autoreloader 方法) (celery.worker.autoreload.BaseMonitor 方法) (celery.worker.autoreload.InotifyMonitor 方法) (celery.worker.autoreload.KQueueMonitor 方法) (celery.worker.components.Hub 方法) (celery.worker.consumer.Consumer 方法) (celery.worker.consumer.Events 方法) (celery.worker.consumer.Heart 方法) (celery.worker.consumer.Tasks 方法) (celery.worker.heartbeat.Heart 方法) (celery.worker.pidbox.Pidbox 方法) stop_verify() (celery.bin.multi.MultiTool 方法) StopFiltering stopwait() (celery.bin.multi.MultiTool 方法) storage (celery.worker.state.Persistent 属性) STORE_ACTIONS (celery.bin.base.Option 属性) store_errors (celery.worker.job.Request 属性) store_errors_even_if_ignored (celery.app.task.Task 属性) (Task 属性) store_result() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.base.BaseBackend 方法) (celery.backends.base.DisabledBackend 方法) str_args_to_python() (celery.bin.amqp.Spec 方法) strategies Strategies (celery.worker.consumer.Consumer 属性) Strategy (celery.app.task.Task 属性) Strategy() (celery.contrib.batches.Batches 方法) strtobool() (在 celery.utils 模块中) strtotal (celery.contrib.migrate.State 属性) subclass_exception() (在 celery.utils.serialization 模块中) subject (celery.utils.mail.ErrorMail 属性) subpolling_interval (celery.backends.base.BaseBackend 属性) (celery.backends.database.DatabaseBackend 属性) subtask() (celery.app.task.Task 方法) subtasks (celery.result.ResultSet 属性) succeeded (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) SUCCESS state SUCCESS() (在 celery.states 模块中) success_msg (celery.worker.job.Request 属性) successful() (celery.result.AsyncResult 方法) (celery.result.ResultSet 方法) supports_args (celery.bin.base.Command 属性) (celery.bin.beat.beat 属性) (celery.bin.events.events 属性) (celery.bin.worker.worker 属性) supports_autoexpire (celery.backends.amqp.AMQPBackend 属性) (celery.backends.base.BaseBackend 属性) (celery.backends.cache.CacheBackend 属性) (celery.backends.cassandra.CassandraBackend 属性) (celery.backends.mongodb.MongoBackend 属性) (celery.backends.redis.RedisBackend 属性) supports_color() (celery.app.log.Logging 方法) supports_native_join (celery.backends.amqp.AMQPBackend 属性) (celery.backends.base.BaseBackend 属性) (celery.backends.cache.CacheBackend 属性) (celery.backends.redis.RedisBackend 属性) (celery.result.AsyncResult 属性) (celery.result.EagerResult 属性) (celery.result.ResultSet 属性) sw_ident (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) sw_sys (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) sw_ver (celery.events.state.State.Worker 属性) (celery.events.state.Worker 属性) symbol_by_name() (celery.bin.base.Command 方法) (在 celery.utils.imports 模块中) sync() (celery.apps.beat.Beat.Service 方法) (celery.beat.PersistentScheduler 方法) (celery.beat.Scheduler 方法) (celery.beat.Service 方法) (celery.worker.state.Persistent 方法) sync_every (celery.beat.Scheduler 属性) synloop() (在 celery.worker.loops 模块中) SystemTerminate

T

table() (celery.app.utils.Settings 方法) take_action() (celery.bin.base.Option 方法) takes_value() (celery.bin.base.Option 方法) Task (celery.app.task 中的类) (celery.Celery 属性) (celery.backends.database.models 中的类) (celery.events.state 中的类) task (celery.worker.job.Request 属性) task() (celery.Celery 方法) (在 celery.contrib.methods 模块中) task-failed event task-received event task-retried event task-revoked event task-sent event task-started event task-succeeded event Task.ErrorMail (celery.app.task 中的类) Task.MaxRetriesExceededError task_accepted() (在 celery.worker.state 模块中) task_buckets task_consumer task_count (celery.events.state.State 属性) task_event() (celery.events.state.State 方法) task_failure signal task_id (celery.backends.database.models.Task 属性) (celery.result.AsyncResult 属性) (celery.worker.job.Request 属性) task_id_eq() (在 celery.contrib.migrate 模块中) task_id_in() (在 celery.contrib.migrate 模块中) task_join_will_block (celery.concurrency.base.BasePool 属性) (celery.concurrency.eventlet.TaskPool 属性) (celery.concurrency.gevent.TaskPool 属性) task_keyprefix (celery.backends.base.KeyValueStoreBackend 属性) task_method (celery.contrib.methods 中的类) task_name (celery.result.EagerResult 属性) (celery.worker.job.Request 属性) task_postrun signal task_prerun signal task_ready() (在 celery.worker.state 模块中), [1] task_reserved() (在 celery.worker.state 模块中), [1] task_revoked signal task_sent signal task_success signal task_types() (celery.events.state.State 方法) TaskConsumer (celery.app.amqp.AMQP 属性) TaskFormatter (celery.app.log 中的类) tasklist() (celery.apps.worker.Worker 方法) taskmeta_collection (celery.backends.mongodb.MongoBackend 属性) TaskPool (celery.concurrency.eventlet 中的类) (celery.concurrency.gevent 中的类) (celery.concurrency.prefork 中的类) (celery.concurrency.solo 中的类) (celery.concurrency.threads 中的类) TaskPool.Timer (celery.concurrency.eventlet 中的类) (celery.concurrency.gevent 中的类) TaskPool.Timer.Schedule (celery.concurrency.eventlet 中的类) (celery.concurrency.gevent 中的类) TaskProducer (celery.app.amqp.AMQP 属性) TaskPublisher (celery.app.amqp 中的类) TaskRegistry (celery.app.registry 中的类) TaskRegistry.NotRegistered TaskRevokedError tasks (celery.Celery 属性) (celery.events.cursesmon.CursesMonitor 属性) Tasks (celery.worker.consumer 中的类) tasks_by_time() (celery.events.state.State 方法) tasks_by_timestamp() (celery.events.state.State 方法)

tasks_by_type() (celery.events.state.State 方法) tasks_by_worker() (celery.events.state.State 方法) TaskSet (celery.backends.database.models 中的类) taskset_id (celery.backends.database.models.TaskSet 属性) TaskType (celery.app.task 中的类) tb (celery.datastructures.ExceptionInfo 属性) TERMINATE (celery.concurrency.base.BasePool 属性) terminate() (celery.bootsteps.StartStopStep 方法) (celery.concurrency.base.BasePool 方法) (celery.worker.WorkController 方法) (celery.worker.components.Hub 方法) (celery.worker.components.Pool 方法) (celery.worker.job.Request 方法) terminate_job() (celery.concurrency.base.BasePool 方法) Terminated thaw() (State 方法) throws (celery.app.task.Task 属性) (Task 属性) tick() (celery.beat.Scheduler 方法) time_limit (celery.app.task.Task 属性) (Task 属性) time_limit() (celery.app.control.Control 方法) time_start (celery.worker.job.Request 属性) timedelta_seconds() (在 celery.utils.timeutils 模块中) TimeLimitExceeded timeout (celery.backends.couchbase.CouchBaseBackend 属性) (celery.task.http.HttpDispatch 属性) TimeoutError timer, [1] (celery.events.snapshot.Polaroid 属性) Timer (celery.utils.timer2 中的类) (celery.worker.components 中的类) timer (celery.worker.consumer.Consumer 属性) Timer.Entry (celery.utils.timer2 中的类) timestamp (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) timezone (celery.Celery 属性) to_dict() (celery.backends.database.models.Task 方法) (celery.backends.database.models.TaskSet 方法) to_local() (celery.schedules.schedule 方法) to_python() (celery.app.defaults.Option 方法) to_timestamp() (在 celery.utils.timer2 模块中) to_utc() (在 celery.utils.timeutils 模块中) total_apx (celery.contrib.migrate.State 属性) total_blocks (celery.utils.sysinfo.df 属性) total_count() (在 celery.worker.state 模块中) total_run_count (celery.beat.ScheduleEntry 属性) trace_task() (在 celery.app.trace 模块中) traceback (celery.backends.database.models.Task 属性) (celery.datastructures.ExceptionInfo 属性) (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) (celery.result.AsyncResult 属性) (celery.result.EagerResult 属性) TraceInfo (celery.app.trace 中的类) track_started (celery.app.task.Task 属性) (Task 属性) trail (celery.app.task.Task 属性) transcoder (celery.backends.couchbase.CouchBaseBackend 属性) TRANSIENT_DELIVERY_MODE (celery.backends.amqp.AMQPBackend.Exchange 属性) tref (celery.concurrency.base.BasePool.Timer.Entry 属性) (celery.utils.timer2.Entry 属性) (celery.utils.timer2.Timer.Entry 属性) truncate() (在 celery.utils.text 模块中) type (celery.app.control.Control.Mailbox 属性) (celery.backends.amqp.AMQPBackend.Exchange 属性), [1] (celery.datastructures.ExceptionInfo 属性) TYPE_CHECKER (celery.bin.base.Option 属性) TYPED_ACTIONS (celery.bin.base.Option 属性) typemap (celery.app.defaults.Option 属性) TYPES (celery.bin.base.Option 属性) tz (celery.schedules.schedule 属性) tzlocal (celery.worker.job.Request 属性) tzname() (celery.utils.timeutils.LocalTimezone 方法)

U

unbind_from() (celery.backends.amqp.AMQPBackend.Exchange 方法) underline() (celery.utils.term.colored 方法) uniq() (在 celery.utils.functional 模块中) UnknownStatusError unlock_gil (celery.backends.couchbase.CouchBaseBackend 属性) UnpickleableExceptionWrapper UNREADY_STATES state UNREADY_STATES (celery.backends.base.BaseBackend 属性) unregister() (celery.app.registry.TaskRegistry 方法) update() (celery.beat.ScheduleEntry 方法) (celery.datastructures.ConfigurationView 方法) (celery.datastructures.LRUCache 方法) (celery.datastructures.LimitedSet 方法) (celery.events.state.State.Task 方法) (celery.events.state.State.Worker 方法) (celery.events.state.Task 方法) (celery.events.state.Worker 方法) (celery.result.ResultSet 方法) (celery.utils.functional.LRUCache 方法) (celery.worker.autoscale.Autoscaler 方法) update_from_dict() (celery.beat.Scheduler 方法) update_heartbeat() (celery.events.state.State.Worker 方法) (celery.events.state.Worker 方法) update_state() (celery.app.task.Task 方法) update_strategies() (celery.worker.consumer.Consumer 方法)

URL (celery.task.http 中的类) usage() (celery.bin.base.Command 方法) (celery.bin.multi.MultiTool 方法) UsageError USE_FAST_LOCALS user (celery.backends.mongodb.MongoBackend 属性) user_agent (celery.task.http.HttpDispatch 属性) user_options (celery.Celery 属性) user_preload_options signal username (celery.backends.couchbase.CouchBaseBackend 属性) uses_semaphore (celery.concurrency.base.BasePool 属性) (celery.concurrency.prefork.TaskPool 属性) utc (celery.worker.job.Request 属性) utc_enabled (celery.schedules.schedule 属性) utcoffset() (celery.utils.timeutils.LocalTimezone 方法) (在 celery.utils.timeutils 模块中)

V

value_set_for() (celery.app.utils.Settings 方法) values() (celery.datastructures.ConfigurationView 方法) (celery.datastructures.DictAttribute 方法) (celery.datastructures.LRUCache 方法) (celery.utils.functional.LRUCache 方法) verify() (celery.security.certificate.Certificate 方法)

verify_args() (celery.bin.base.Command 方法) version (celery.bin.base.Command 属性)

W

wait() (celery.result.AsyncResult 方法) (celery.result.EagerResult 方法) wait_for() (celery.backends.amqp.AMQPBackend 方法) (celery.backends.base.BaseBackend 方法) (celery.backends.base.DisabledBackend 方法) waitexec() (celery.bin.multi.MultiTool 方法) waiting() (celery.result.ResultSet 方法) wakeup_workers() (celery.events.EventReceiver 方法) warn_deprecated() (在 celery.utils 模块中) warn_if_yajl() (celery.events.EventDispatcher 方法) weekday() (在 celery.utils.timeutils 模块中) when (celery.exceptions.Retry 属性) white() (celery.utils.term.colored 方法) win (celery.events.cursesmon.CursesMonitor 属性) with_detacher_default_options() (celery.bin.multi.MultiTool 方法) with_pool_option() (celery.bin.base.Command 方法) (celery.bin.celery.CeleryCommand 方法) (celery.bin.worker.worker 方法) without_defaults() (celery.app.utils.Settings 方法) WorkController (celery.Celery 属性) (celery.worker 中的类) WorkController.Blueprint (celery.worker 中的类) Worker (celery.apps.worker 中的类) worker (celery.bin.worker 中的类) Worker (celery.Celery 属性) (celery.events.state 中的类) worker (celery.events.state.State.Task 属性) (celery.events.state.Task 属性) worker-heartbeat event

worker-offline event worker-online event worker_direct() (在 celery.utils 模块中) worker_event() (celery.events.state.State 方法) worker_init signal worker_initialized (celery.loaders.base.BaseLoader 属性) worker_main() (celery.Celery 方法) worker_pid (celery.worker.job.Request 属性) worker_process_init signal worker_process_shutdown signal worker_ready signal worker_shutdown signal WorkerComponent (celery.worker.autoreload 中的类) (celery.worker.autoscale 中的类) WorkerLostError workers (celery.events.cursesmon.CursesMonitor 属性) workers() (celery.bin.graph.graph 方法) write() (celery.utils.log.LoggingProxy 方法) write_pid() (celery.platforms.Pidfile 方法) write_stats (celery.concurrency.prefork.TaskPool 属性) writelines() (celery.utils.log.LoggingProxy 方法)

Y

yellow() (celery.utils.term.colored 方法)

符号

命令行选项 --config --gid --loader --pidfile --uid --umask --workdir -A, --app -b, --broker -f, --logfile

环境变量 AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY CELERYD_FSNOTIFY, [1] CELERY_BENCH CELERY_BROKER_URL CELERY_CONFIG_MODULE, [1], [2] CELERY_CREATE_DIRS CELERY_LOADER, [1], [2], [3], [4], [5] CELERY_RDBSIG CELERY_RDB_HOST, [1] CELERY_RDB_PORT, [1] CELERY_TRACE_APP, [1], [2] C_FAKEFORK, [1], [2] C_IMPDEBUG DJANGO_SETTINGS_MODULE, [1], [2], [3], [4] IRON_PROJECT_ID IRON_TOKEN MP_LOG, [1] NOSE_VERBOSE PATH USE_FAST_LOCALS