索引

符号

--ack-messages celery-migrate命令行选项 --app celery命令行选项 --args celery-call命令行选项 --autoscale celery-worker命令行选项 --beat celery-worker命令行选项 --bpython celery-shell命令行选项 --broker celery命令行选项 --camera celery-events命令行选项 --compat celery-upgrade-settings命令行选项 --concurrency celery-worker命令行选项 --config celery命令行选项 --countdown celery-call命令行选项 --destination celery-control命令行选项 celery-inspect命令行选项 celery-status命令行选项 --detach celery-beat命令行选项 celery-events命令行选项 celery-worker命令行选项 --discard celery-worker命令行选项 --django celery-upgrade-settings命令行选项 --dump celery-events命令行选项 --eta celery-call命令行选项 --eventlet celery-shell命令行选项 --events celery-worker命令行选项 --exchange celery-call命令行选项 --exclude-queues celery-purge命令行选项 celery-worker命令行选项 --executable celery-beat命令行选项 celery-events命令行选项 celery-worker命令行选项 --expires celery-call命令行选项 --force celery-purge命令行选项 --forever celery-migrate命令行选项 --freq celery-events命令行选项 --frequency celery-events命令行选项 --gevent celery-shell命令行选项 --gid celery-beat命令行选项 celery-events命令行选项 celery-worker命令行选项 --heartbeat-interval celery-worker命令行选项 --hostname celery-worker命令行选项 --include celery-worker命令行选项 --ipython celery-shell命令行选项 --json celery-control命令行选项 celery-inspect命令行选项 celery-status命令行选项 --kwargs celery-call命令行选项 --limit celery-migrate命令行选项 --list celery-control命令行选项 celery-inspect命令行选项 --loader celery命令行选项 --logfile celery-beat命令行选项 celery-events命令行选项 celery-worker命令行选项 --loglevel celery-beat命令行选项 celery-events命令行选项 celery-worker命令行选项 --max-interval celery-beat命令行选项 --max-memory-per-child celery-worker命令行选项 --max-tasks-per-child celery-worker命令行选项 --maxrate celery-events命令行选项 --no-backup celery-upgrade-settings命令行选项 --no-color celery命令行选项 --optimization celery-worker命令行选项 --pidfile celery-beat命令行选项 celery-events命令行选项 celery-worker命令行选项 --pool celery-worker命令行选项 --prefetch-multiplier celery-worker命令行选项 --purge celery-worker命令行选项 --python celery-shell命令行选项 --queue celery-call命令行选项 --queues celery-migrate命令行选项 celery-purge命令行选项 celery-worker命令行选项 --quiet celery命令行选项

--result-backend celery命令行选项 --routing-key celery-call命令行选项 --schedule celery-beat命令行选项 celery-worker命令行选项 --schedule-filename celery-worker命令行选项 --scheduler celery-beat命令行选项 celery-worker命令行选项 --serializer celery-call命令行选项 --skip-checks celery命令行选项 --soft-time-limit celery-worker命令行选项 --statedb celery-worker命令行选项 --task celery-result命令行选项 --task-events celery-worker命令行选项 --tasks celery-migrate命令行选项 --time-limit celery-worker命令行选项 --timeout celery-control命令行选项 celery-inspect命令行选项 celery-migrate命令行选项 celery-status命令行选项 --traceback celery-result命令行选项 --uid celery-beat命令行选项 celery-events命令行选项 celery-worker命令行选项 --umask celery-beat命令行选项 celery-events命令行选项 celery-worker命令行选项 --version celery命令行选项 --without-gossip celery-worker命令行选项 --without-heartbeat celery-worker命令行选项 --without-mingle celery-worker命令行选项 --without-tasks celery-shell命令行选项 --workdir celery命令行选项 -A celery命令行选项 -a celery-call命令行选项 celery-migrate命令行选项 -B celery-shell命令行选项 celery-worker命令行选项 -b celery命令行选项 -C celery命令行选项 -c celery-events命令行选项 celery-worker命令行选项 -D celery-worker命令行选项 -d celery-control命令行选项 celery-events命令行选项, [1] celery-inspect命令行选项 celery-status命令行选项 -E celery-worker命令行选项 -F celery-events命令行选项 celery-migrate命令行选项 -f celery-beat命令行选项 celery-events命令行选项 celery-purge命令行选项 celery-worker命令行选项 -I celery-shell命令行选项 celery-worker命令行选项 -j celery-control命令行选项 celery-inspect命令行选项 celery-status命令行选项 -k celery-call命令行选项 -l celery-beat命令行选项 celery-events命令行选项 celery-worker命令行选项 -n celery-migrate命令行选项 celery-worker命令行选项 -O celery-worker命令行选项 -P celery-worker命令行选项 -Q celery-migrate命令行选项 celery-purge命令行选项 celery-worker命令行选项 -q celery命令行选项 -r celery-events命令行选项 -S celery-beat命令行选项 celery-worker命令行选项 -s celery-beat命令行选项 celery-worker命令行选项 -T celery-migrate命令行选项 celery-shell命令行选项 -t celery-control命令行选项 celery-inspect命令行选项 celery-migrate命令行选项 celery-result命令行选项 celery-status命令行选项 -X celery-purge命令行选项 celery-worker命令行选项

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 属性） abstract（celery.contrib.abortable.AbortableTask 属性） accept_content setting accept（celery.app.control.Control.Mailbox 属性） accept（celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 属性） ack acknowledge() （celery.worker.request.Request 方法） acknowledged acknowledged（celery.worker.request.Request 属性） acks_late（celery.app.task.Task 属性） acks_late（Task 属性） acks_on_failure_or_timeout（celery.app.task.Task 属性） acquire() （celery.platforms.Pidfile 方法） active() （celery.app.control.Inspect 方法） active_queues control active_queues() （celery.app.control.Inspect 方法） active_requests()（在 celery.worker.state 模块中） active（celery.concurrency.base.BasePool 属性） active（celery.events.state.State.Worker 属性） active（celery.events.state.Worker 属性） add() （celery.app.amqp.Queues 方法） add() （celery.beat.Scheduler 方法） add() （celery.result.ResultSet 方法） add() （celery.utils.collections.LimitedSet 方法） add() （hub 方法） add_arc() （celery.utils.graph.DependencyGraph 方法） add_autoretry_behaviour()（在 celery.app.autoretry 模块中） 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 方法） add_defaults() （celery.utils.collections.ChainMap 方法） add_edge() （celery.utils.graph.DependencyGraph 方法） add_pending_result() （celery.backends.asynchronous.AsyncBackendMixin 方法） add_pending_results() （celery.backends.asynchronous.AsyncBackendMixin 方法） add_periodic_task() （celery.Celery 方法） add_queue() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） add_reader() （hub 方法） add_task_queue() （celery.worker.consumer.Consumer 方法） add_task_queue() （celery.worker.consumer.consumer.Consumer 方法） add_to_chord() （celery.app.task.Task 方法） add_to_chord() （celery.backends.redis.RedisBackend 方法） add_writer() （hub 方法） adjust() （celery.beat.Scheduler 方法） adjust_timestamp()（在 celery.utils.time 模块中） after_return() after_return() （celery.app.task.Task 方法） after_setup_logger signal after_setup_task_logger signal after_task_publish signal Agent（celery.worker.consumer 中的类） Agent（celery.worker.consumer.agent 中的类） alert() （celery.events.cursesmon.CursesMonitor 方法） alert_remote_control_reply() （celery.events.cursesmon.CursesMonitor 方法） alias（celery.bootsteps.Blueprint 属性） alias（celery.bootsteps.Step 属性） alive() （celery.apps.multi.Node 方法） alive() （celery.bin.multi.MultiTool.MultiParser.Node 方法） alive_workers() （celery.events.state.State 方法） alive（celery.events.state.State.Worker 属性） alive（celery.events.state.Worker 属性） ALL_STATES state already_setup（celery.app.log.Logging 属性） AlreadyRegistered alt（celery.app.defaults.Option 属性） AlwaysEagerIgnored AMQP（celery.app.amqp 中的类） amqp（celery.Celery 属性） annotate() （celery.app.annotations.MapAnnotation 方法） annotate_any() （celery.app.annotations.MapAnnotation 方法） anon_nodename()（在 celery.utils.nodenames 模块中） app, [1] app_or_default()（在 celery.app 模块中） AppLoader（celery.loaders.app 中的类） apply apply() （celery.app.task.Task 方法） apply() （celery.bootsteps.Blueprint 方法） apply() （celery.utils.abstract.CallableTask 方法） apply_async() （celery.app.task.Task 方法） apply_async() （celery.beat.Scheduler 方法） apply_async() （celery.concurrency.base.BasePool 方法） apply_async() （celery.utils.abstract.CallableTask 方法） apply_async_on_commit() （celery.contrib.django.task.DjangoTask 方法） apply_chord() （celery.backends.redis.RedisBackend 方法） apply_entry() （celery.beat.Scheduler 方法）

apply_eta_task() apply_eta_task() （celery.worker.consumer.Consumer 方法） apply_eta_task() （celery.worker.consumer.consumer.Consumer 方法） apply_target()（在 celery.concurrency.base 模块中） appstr()（在 celery.app.utils 模块中） app（celery.app.control.Inspect 属性） app（celery.apps.beat.Beat 属性） app（celery.events.dispatcher.EventDispatcher 属性） app（celery.events.EventDispatcher 属性） app（celery.events.EventReceiver 属性） app（celery.events.receiver.EventReceiver 属性） app（celery.result.AsyncResult 属性） app（celery.result.ResultSet 属性） app（celery.schedules.crontab 属性） app（celery.utils.abstract.CallableSignature 属性） app（celery.worker.request.Request 属性） app（celery.worker.WorkController 属性） app（celery.worker.worker.WorkController 属性） arangodb_backend_settings setting ArangoDbBackend（celery.backends.arangodb 中的类） argsrepr_maxsize（celery.app.amqp.AMQP 属性） argsrepr（celery.worker.request.Request 属性） args（celery.backends.database.models.TaskExtended 属性） args（celery.beat.ScheduleEntry 属性） args（celery.concurrency.base.BasePool.Timer.Entry 属性） args（celery.events.state.State.Task 属性） args（celery.events.state.Task 属性） args（celery.result.AsyncResult 属性） args（celery.utils.abstract.CallableSignature 属性） args（celery.utils.timer2.Entry 属性） args（celery.utils.timer2.Timer.Entry 属性） args（celery.worker.request.Request 属性） argv_with_executable（celery.apps.multi.Node 属性） argv_with_executable（celery.bin.multi.MultiTool.MultiParser.Node 属性） as_dict() （celery.events.state.State.Task 方法） as_dict() （celery.events.state.Task 方法） as_dict() （celery.utils.collections.LimitedSet 方法） as_list() （celery.result.AsyncResult 方法） as_tuple() （celery.result.AsyncResult 方法） as_tuple() （celery.result.GroupResult 方法） as_uri() （celery.backends.base.DisabledBackend 方法） as_uri() （celery.backends.cache.CacheBackend 方法） as_uri() （celery.backends.cassandra.CassandraBackend 方法） as_uri() （celery.backends.mongodb.MongoBackend 方法） as_uri() （celery.backends.redis.SentinelBackend 方法） as_uri() （celery.backends.rpc.RPCBackend 方法） assert_accepted() （celery.contrib.testing.manager.ManagerMixin 方法） assert_received() （celery.contrib.testing.manager.ManagerMixin 方法） assert_result_tasks_in_progress_or_completed() （celery.contrib.testing.manager.ManagerMixin 方法） assert_task_state_from_result() （celery.contrib.testing.manager.ManagerMixin 方法） assert_task_worker_state() （celery.contrib.testing.manager.ManagerMixin 方法） AsyncBackendMixin（celery.backends.asynchronous 中的类） AsyncResult() （celery.app.task.Task 方法） AsyncResult() （celery.contrib.abortable.AbortableTask 方法） AsyncResult.TimeoutError AsyncResult（celery.Celery 属性） AsyncResult（celery.result 中的类） asynloop()（在 celery.worker.loops 模块中） attr() （celery.utils.graph.GraphFormatter 方法） AttributeDictMixin（celery.utils.collections 中的类） AttributeDict（celery.utils.collections 中的类） attrs() （celery.utils.graph.GraphFormatter 方法） ATTRSEP（celery.utils.graph.DOT 属性） attrs（celery.backends.rpc.RPCBackend.Exchange 属性） ATTR（celery.utils.graph.DOT 属性） auto_declare（celery.backends.rpc.RPCBackend.Consumer 属性） auto_declare（celery.backends.rpc.RPCBackend.Producer 属性） auto_declare（celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 属性） AUTO_DELETE celery-amqp-exchange.declare命令行选项 celery-amqp-queue.declare命令行选项 auto_delete（celery.backends.rpc.RPCBackend.Exchange 属性） autodiscover_tasks() （celery.Celery 方法） autodiscover_tasks() （celery.loaders.base.BaseLoader 方法） autodoc_skip_member_handler()（在 celery.contrib.sphinx 模块中） autoreloader autoretry_for（Task 属性） autoscale() （celery.app.control.Control 方法） autoscaler Autoscaler（celery.worker.autoscale 中的类） Autoscale（celery.bin.worker 中的类） available（celery.utils.sysinfo.df 属性） AWS_ACCESS_KEY_ID aws_region（celery.backends.dynamodb.DynamoDBBackend 属性） AWS_SECRET_ACCESS_KEY azureblockblob_base_path setting azureblockblob_connection_timeout setting azureblockblob_container_name setting azureblockblob_read_timeout setting azureblockblob_retry_increment_base setting azureblockblob_retry_initial_backoff_sec setting azureblockblob_retry_max_attempts setting

B

BackendError BackendGetMetaError BackendStoreError backend（celery.app.task.Task 属性） backend（celery.Celery 属性） backend（celery.result.AsyncResult 属性） backend（celery.result.ResultSet 属性） backend（Task 属性） background（celery.events.cursesmon.CursesMonitor 属性） BacklogLimitExceeded banner() （celery.apps.beat.Beat 方法） BaseBackend（celery.backends.base 中的类） BaseLoader（celery.loaders.base 中的类） BasePool.Timer.Entry（celery.concurrency.base 中的类） BasePool.Timer（celery.concurrency.base 中的类） BasePool（celery.concurrency.base 中的类） BaseResultConsumer（celery.backends.asynchronous 中的类） Beat.Service（celery.apps.beat 中的类） beat_cron_starting_deadline setting beat_embedded_init signal beat_executable setting beat_gid setting beat_init signal beat_logfile setting beat_max_loop_interval setting beat_pidfile setting beat_schedule setting beat_schedule_filename setting beat_scheduler setting beat_sync_every setting beat_uid setting beat_umask setting Beat（celery.apps.beat 中的类） Beat（celery.Celery 属性） Beat（celery.worker.components 中的类） before_start() before_start() （celery.app.task.Task 方法） before_task_publish signal bgThread（celery.utils.threads 中的类） billiard bind() （queue 方法） bind_to() （celery.backends.rpc.RPCBackend.Exchange 方法） bind_to() （celery.utils.collections.ChainMap 方法） binding() （celery.backends.rpc.RPCBackend.Exchange 方法） binding（celery.backends.rpc.RPCBackend 属性） 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 属性） blueprint（celery.worker.worker.WorkController 属性） body() （celery.utils.threads.bgThread 方法） body() （celery.worker.autoscale.Autoscaler 方法） body_can_be_buffer（celery.concurrency.base.BasePool 属性） body_can_be_buffer（celery.concurrency.solo.TaskPool 属性） body_can_be_buffer（celery.concurrency.thread.TaskPool 属性） body（celery.worker.request.Request 属性） bold() （celery.utils.term.colored 方法） bright() （celery.utils.term.colored 方法） broadcast() （celery.app.control.Control 方法） broker_connection_max_retries setting broker_connection_retry setting broker_connection_retry_on_startup setting broker_connection_timeout setting broker_failover_strategy setting broker_heartbeat setting broker_heartbeat_checkrate setting broker_login_method setting broker_native_delayed_delivery_queue_type setting broker_pool_limit setting broker_read_url setting broker_read_url（celery.app.utils.Settings 属性） broker_transport_options setting broker_url setting broker_url（celery.app.utils.Settings 属性） broker_use_ssl setting broker_write_url setting broker_write_url（celery.app.utils.Settings 属性） bucket_for_task() （celery.worker.consumer.Consumer 方法） bucket_for_task() （celery.worker.consumer.consumer.Consumer 方法） bucket_for_task() （consumer 方法） bucket（celery.backends.couchbase.CouchbaseBackend 属性） BufferMap.Empty BufferMap（celery.utils.collections 中的类） Buffer（celery.utils.collections.BufferMap 属性） bufmaxsize（celery.utils.collections.BufferMap 属性） bugreport() （celery.Celery 方法） bugreport()（在 celery.app.utils 模块中） build_graph() （celery.result.AsyncResult 方法） build_tracer()（在 celery.app.trace 模块中） builtin_fixups（celery.Celery 属性） builtin_modules（celery.loaders.base.BaseLoader 属性） Bunch（celery.utils.objects 中的类） bundle_path（celery.backends.cassandra.CassandraBackend 属性） by_name()（在 celery.app.backends 模块中） by_url()（在 celery.app.backends 模块中）

C

C_FAKEFORK, [1], [2], [3], [4], [5], [6] C_FORCE_ROOT, [1], [2], [3] C_IMPDEBUG cache_backend setting cache_backend_options setting CacheBackend（celery.backends.cache 中的类） cached_property（celery.utils 中的类） call() （celery.app.control.Control.Mailbox 方法） call_after() （celery.concurrency.base.BasePool.Timer 方法） call_after() （celery.utils.timer2.Timer 方法） call_at() （celery.concurrency.base.BasePool.Timer 方法） call_at() （celery.utils.timer2.Timer 方法） call_command() （celery.bin.multi.MultiTool 方法） call_repeatedly() （celery.concurrency.base.BasePool.Timer 方法） call_repeatedly() （celery.utils.timer2.Timer 方法） call_soon() （celery.worker.consumer.Consumer 方法） call_soon() （celery.worker.consumer.consumer.Consumer 方法） call_task() （celery.worker.consumer.Gossip 方法） call_task() （celery.worker.consumer.gossip.Gossip 方法） Callable()（在 celery.utils.deprecated 模块中） CallableSignature（celery.utils.abstract 中的类） CallableTask（celery.utils.abstract 中的类） callbacks（celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 属性） calling can_cache_declaration（celery.backends.rpc.RPCBackend.Exchange 属性） can_cache_declaration（celery.backends.rpc.RPCBackend.Queue 属性） can_document_member()（celery.contrib.sphinx.TaskDocumenter 类方法） cancel() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） cancel() （celery.concurrency.base.BasePool.Timer 方法） cancel() （celery.concurrency.base.BasePool.Timer.Entry 方法） cancel() （celery.concurrency.eventlet.TaskPool.Timer 方法） cancel() （celery.events.snapshot.Polaroid 方法） cancel() （celery.utils.timer2.Entry 方法） cancel() （celery.utils.timer2.Timer 方法） cancel() （celery.utils.timer2.Timer.Entry 方法） cancel() （celery.worker.request.Request 方法） cancel_all_unacked_requests() （celery.worker.consumer.Consumer 方法） cancel_all_unacked_requests() （celery.worker.consumer.consumer.Consumer 方法） cancel_by_queue() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） cancel_consumer control cancel_consumer() cancel_consumer() （celery.app.control.Control 方法） cancel_for() （celery.backends.asynchronous.BaseResultConsumer 方法） cancel_for() （celery.backends.redis.RedisBackend.ResultConsumer 方法） cancel_for() （celery.backends.rpc.RPCBackend.ResultConsumer 方法） cancel_task_queue() （celery.worker.consumer.Consumer 方法） cancel_task_queue() （celery.worker.consumer.consumer.Consumer 方法） cancel_task_queue() （consumer 方法） canceled（celery.concurrency.base.BasePool.Timer.Entry 属性） canceled（celery.utils.timer2.Entry 属性） canceled（celery.utils.timer2.Timer.Entry 属性） cancelled（celery.concurrency.base.BasePool.Timer.Entry 属性） cancelled（celery.utils.timer2.Entry 属性） cancelled（celery.utils.timer2.Timer.Entry 属性） capacity（celery.utils.sysinfo.df 属性） capture() （celery.events.EventReceiver 方法） capture() （celery.events.receiver.EventReceiver 方法） capture() （celery.events.snapshot.Polaroid 方法） cassandra_auth_kwargs setting cassandra_auth_provider setting cassandra_entry_ttl setting cassandra_keyspace setting cassandra_options setting cassandra_port setting cassandra_read_consistency setting cassandra_secure_bundle_path setting cassandra_servers setting cassandra_table setting cassandra_write_consistency setting CassandraBackend（celery.backends.cassandra 中的类） cast() （celery.app.control.Control.Mailbox 方法） CDeprecationWarning celery module celery-amqp-basic.ack命令行选项 DELIVERY_TAG celery-amqp-basic.get命令行选项 NO_ACK QUEUE celery-amqp-basic.publish命令行选项 EXCHANGE IMMEDIATE MANDATORY MSG ROUTING_KEY celery-amqp-exchange.declare命令行选项 AUTO_DELETE DURABLE EXCHANGE PASSIVE TYPE celery-amqp-exchange.delete命令行选项 EXCHANGE IF_UNUSED celery-amqp-queue.bind命令行选项 EXCHANGE QUEUE ROUTING_KEY celery-amqp-queue.declare命令行选项 AUTO_DELETE DURABLE PASSIVE QUEUE celery-amqp-queue.delete命令行选项 IF_EMPTY IF_UNUSED QUEUE celery-amqp-queue.purge命令行选项 QUEUE celery-beat命令行选项 --detach --executable --gid --logfile --loglevel --max-interval --pidfile --schedule --scheduler --uid --umask -f -l -s -S celery-call命令行选项 --args --countdown --eta --exchange --expires --kwargs --queue --routing-key --serializer -a -k NAME celery-control命令行选项 --destination --json --list --timeout -d -j -t COMMAND celery-events命令行选项 --camera --detach --dump --executable --freq --frequency --gid --logfile --loglevel --maxrate --pidfile --uid --umask -c -d, [1] -F -f -l -r celery-inspect命令行选项 --destination --json --list --timeout -d -j -t COMMAND celery-logtool-debug命令行选项 FILES celery-logtool-errors命令行选项 FILES celery-logtool-incomplete命令行选项 FILES celery-logtool-stats命令行选项 FILES celery-logtool-traces命令行选项 FILES celery-migrate命令行选项 --ack-messages --forever --limit --queues --tasks --timeout -a -F -n -Q -t -T DESTINATION SOURCE celery-purge命令行选项 --exclude-queues --force --queues -f -Q -X celery-result命令行选项 --task --traceback -t TASK_ID celery-shell命令行选项 --bpython --eventlet --gevent --ipython --python --without-tasks -B -I -T celery-status命令行选项 --destination --json --timeout -d -j -t celery-upgrade-settings命令行选项 --compat --django --no-backup FILENAME celery-worker命令行选项 --autoscale --beat --concurrency --detach --discard --events --exclude-queues --executable --gid --heartbeat-interval --hostname --include --logfile --loglevel --max-memory-per-child --max-tasks-per-child --optimization --pidfile --pool --prefetch-multiplier --purge --queues --schedule --schedule-filename --scheduler --soft-time-limit --statedb --task-events --time-limit --uid --umask --without-gossip --without-heartbeat --without-mingle -B -c -D -E -f -I -l -n -O -P -Q -S -s -X celery._state module celery.app module celery.app.amqp module celery.app.annotations module celery.app.autoretry module celery.app.backends module celery.app.builtins module celery.app.control module celery.app.defaults module celery.app.events module celery.app.log module celery.app.registry module celery.app.routes module celery.app.task module celery.app.trace module celery.app.utils module celery.apps.beat module celery.apps.multi module celery.apps.worker module celery.backends module celery.backends.arangodb module celery.backends.asynchronous module celery.backends.base module celery.backends.cache module celery.backends.cassandra module celery.backends.consul module celery.backends.cosmosdbsql module celery.backends.couchbase module celery.backends.couchdb module celery.backends.database module celery.backends.database.models module celery.backends.database.session module celery.backends.dynamodb module celery.backends.elasticsearch module celery.backends.filesystem module celery.backends.gcs module celery.backends.mongodb module celery.backends.redis module celery.backends.rpc module celery.backends.s3 module celery.beat module celery.bin.amqp module celery.bin.base module celery.bin.beat module celery.bin.call module celery.bin.celery module celery.bin.control module celery.bin.events module celery.bin.graph module celery.bin.list module celery.bin.logtool module celery.bin.migrate module celery.bin.multi module celery.bin.purge module celery.bin.result module celery.bin.shell module celery.bin.upgrade module celery.bin.worker module celery.bootsteps module celery.concurrency module celery.concurrency.base module celery.concurrency.eventlet module celery.concurrency.gevent module celery.concurrency.prefork module celery.concurrency.solo module celery.concurrency.thread module celery.contrib.abortable module celery.contrib.django.task module celery.contrib.migrate module celery.contrib.pytest module celery.contrib.rdb module celery.contrib.sphinx module

celery.contrib.testing.app module celery.contrib.testing.manager module celery.contrib.testing.mocks module celery.contrib.testing.worker module celery.events module celery.events.cursesmon module celery.events.dispatcher module celery.events.dumper module celery.events.event module celery.events.receiver module celery.events.snapshot module celery.events.state module celery.exceptions module celery.loaders module celery.loaders.app module celery.loaders.base module celery.loaders.default module Celery.on_after_configure()（在 celery 模块中） Celery.on_after_finalize()（在 celery 模块中） Celery.on_after_fork()（在 celery 模块中） Celery.on_configure()（在 celery 模块中） celery.platforms module celery.result module celery.schedules module celery.security module celery.security.certificate module celery.security.key module celery.security.serialization module celery.security.utils module celery.signals module celery.states module celery.utils module celery.utils.abstract module celery.utils.collections module celery.utils.debug module celery.utils.deprecated module celery.utils.dispatch module celery.utils.dispatch.signal module celery.utils.functional module celery.utils.graph module celery.utils.imports module celery.utils.iso8601 module celery.utils.log module celery.utils.nodenames module celery.utils.objects module celery.utils.saferepr module celery.utils.serialization module celery.utils.sysinfo module celery.utils.term module celery.utils.text module celery.utils.threads module celery.utils.time module celery.utils.timer2 module celery.worker module celery.worker.autoscale module celery.worker.components module celery.worker.consumer module celery.worker.consumer.agent module celery.worker.consumer.connection module celery.worker.consumer.consumer module celery.worker.consumer.control module celery.worker.consumer.events module celery.worker.consumer.gossip module celery.worker.consumer.heart module celery.worker.consumer.mingle module celery.worker.consumer.tasks module celery.worker.control module celery.worker.heartbeat module celery.worker.loops module celery.worker.pidbox module celery.worker.request module celery.worker.state module celery.worker.strategy module celery.worker.worker module celery_app()（在 celery.contrib.pytest 模块中） CELERY_BENCH CELERY_BROKER_URL CELERY_CHDIR celery_class_tasks()（在 celery.contrib.pytest 模块中） celery_config()（在 celery.contrib.pytest 模块中） CELERY_CONFIG_MODULE, [1], [2], [3] CELERY_CREATE_DIRS celery_enable_logging()（在 celery.contrib.pytest 模块中） celery_includes()（在 celery.contrib.pytest 模块中） CELERY_LOADER, [1], [2], [3], [4], [5], [6] celery_parameters()（在 celery.contrib.pytest 模块中） CELERY_RDB_HOST, [1] CELERY_RDB_PORT, [1] CELERY_RDBSIG, [1] celery_session_app()（在 celery.contrib.pytest 模块中） celery_session_worker()（在 celery.contrib.pytest 模块中） CELERY_SU CELERY_TRACE_APP, [1], [2], [3], [4] celery_worker()（在 celery.contrib.pytest 模块中） celery_worker_parameters()（在 celery.contrib.pytest 模块中） celery_worker_pool()（在 celery.contrib.pytest 模块中） CeleryBeat（celery.bin.worker 中的类） CeleryCommandException CeleryCommand（celery.bin.base 中的类） CELERYCTL celeryd_after_setup signal celeryd_init signal CELERYD_SU_ARGS CeleryDaemonCommand（celery.bin.base 中的类） CeleryError CeleryOption（celery.bin.base 中的类） CeleryWarning celery命令行选项 --app --broker --config --loader --no-color --quiet --result-backend --skip-checks --version --workdir -A -b -C -q Celery（celery 中的类） Certificate（celery.security.certificate 中的类） CertStore（celery.security.certificate 中的类） ChainMap（celery.utils.collections 中的类） chain（celery 中的类） changes（celery.utils.collections.ChainMap 属性） channel（celery.backends.rpc.RPCBackend.Producer 属性） channel（celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 属性） check_module() （celery.contrib.sphinx.TaskDocumenter 方法） children（celery.result.AsyncResult 属性） children（celery.result.GroupResult 属性） chord()（在 celery 模块中） chord_size（celery.utils.abstract.CallableSignature 属性） ChordError chord（celery.worker.request.Request 属性） chunks() （celery.app.task.Task 方法） chunks()（在 celery.utils 模块中） chunks()（在 celery.utils.functional 模块中） cipater claim_steps() （celery.bootsteps.Blueprint 方法） cleanup() （celery.backends.arangodb.ArangoDbBackend 方法） cleanup() （celery.backends.database.DatabaseBackend 方法） cleanup() （celery.backends.filesystem.FilesystemBackend 方法） cleanup() （celery.backends.mongodb.MongoBackend 方法） cleanup() （celery.events.snapshot.Polaroid 方法） cleanup() （celery.utils.threads.LocalManager 方法） cleanup_signal（celery.events.snapshot.Polaroid 属性） clear() （celery.concurrency.base.BasePool.Timer 方法） clear() （celery.concurrency.eventlet.TaskPool.Timer 方法） clear() （celery.concurrency.gevent.TaskPool.Timer 方法） clear() （celery.events.state.State 方法） clear() （celery.result.ResultSet 方法） clear() （celery.utils.collections.ChainMap 方法） clear() （celery.utils.collections.ConfigurationView 方法） clear() （celery.utils.collections.LimitedSet 方法） clear() （celery.utils.timer2.Timer 方法） clear_after（celery.events.snapshot.Polaroid 属性） clear_tasks() （celery.events.state.State 方法） CLIContext（celery.bin.base 中的类） client() （celery.backends.consul.ConsulBackend 方法） client（celery.backends.cache.CacheBackend 属性） client（celery.backends.dynamodb.DynamoDBBackend 属性） client（celery.backends.redis.RedisBackend 属性） client（celery.events.state.State.Task 属性） client（celery.events.state.Task 属性） clock() （celery.app.control.Inspect 方法） clock（celery.events.state.State.Task 属性） clock（celery.events.state.State.Worker 属性） clock（celery.events.state.Task 属性） clock（celery.events.state.Worker 属性） clone() （celery.utils.abstract.CallableSignature 方法） close() （celery.backends.rpc.RPCBackend.Producer 方法） close() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） close() （celery.beat.PersistentScheduler 方法） close() （celery.beat.Scheduler 方法） close() （celery.bootsteps.Blueprint 方法） close() （celery.bootsteps.StartStopStep 方法） close() （celery.Celery 方法） close() （celery.concurrency.base.BasePool 方法） close() （celery.events.dispatcher.EventDispatcher 方法） close() （celery.events.EventDispatcher 方法） close() （celery.platforms.DaemonContext 方法） close() （celery.utils.log.LoggingProxy 方法） close() （celery.worker.components.Pool 方法） close() （celery.worker.state.Persistent 方法） close_open_fds()（在 celery.platforms 模块中） closed（celery.utils.log.LoggingProxy 属性） CLOSE（celery.concurrency.base.BasePool 属性） Cluster() （celery.bin.multi.MultiTool 方法） cluster_from_argv() （celery.bin.multi.MultiTool 方法） Cluster（celery.apps.multi 中的类） cmdline_config_parser() （celery.loaders.base.BaseLoader 方法） collect() （celery.result.AsyncResult 方法） collection（celery.backends.arangodb.ArangoDbBackend 属性） collection（celery.backends.mongodb.MongoBackend 属性） colored() （celery.app.log.Logging 方法） colored（celery.utils.term 中的类） ColorFormatter（celery.utils.log 中的类） COLORS（celery.utils.log.ColorFormatter 属性） colors（celery.utils.log.ColorFormatter 属性） COMMAND celery-control命令行选项 celery-inspect命令行选项 CommaSeparatedList（celery.bin.base 中的类） compatible_transport() （celery.worker.consumer.Gossip 方法） compatible_transport() （celery.worker.consumer.gossip.Gossip 方法） compatible_transport() （celery.worker.consumer.Mingle 方法） compatible_transport() （celery.worker.consumer.mingle.Mingle 方法） compatible_transports（celery.worker.consumer.Gossip 属性） compatible_transports（celery.worker.consumer.gossip.Gossip 属性） compatible_transports（celery.worker.consumer.Mingle 属性） compatible_transports（celery.worker.consumer.mingle.Mingle 属性） completed_count() （celery.result.ResultSet 方法） compress() （celery.worker.state.Persistent 方法） compression（celery.backends.rpc.RPCBackend.Producer 属性） compression（Task 属性） conditional（celery.bootsteps.Step 属性） conditional（celery.worker.autoscale.WorkerComponent 属性） conditional（celery.worker.components.Beat 属性） conditional（celery.worker.consumer.Agent 属性） conditional（celery.worker.consumer.agent.Agent 属性） conf() （celery.app.control.Inspect 方法） config_from_envvar() （celery.Celery 方法） config_from_object() （celery.Celery 方法） config_from_object() （celery.loaders.base.BaseLoader 方法） ConfigurationView（celery.utils.collections 中的类） configure()（celery.backends.database.models.Task 类方法） configure()（celery.backends.database.models.TaskSet 类方法） configured（celery.loaders.base.BaseLoader 属性） conf（celery.loaders.base.BaseLoader 属性） connect() （celery.utils.dispatch.Signal 方法） connect() （celery.utils.dispatch.signal.Signal 方法） connect() （celery.utils.graph.DependencyGraph 方法） connect() （celery.worker.consumer.Consumer 方法） connect() （celery.worker.consumer.consumer.Consumer 方法） connect_on_app_finalize()（在 celery._state 模块中） connect_with() （celery.bootsteps.Blueprint 方法） connection connection() （celery.Celery 方法） connection_class_ssl（celery.backends.redis.RedisBackend 属性） connection_class_ssl（celery.backends.redis.SentinelBackend 属性） connection_errors（celery.worker.request.Request 属性） connection_for_read() （celery.Celery 方法） connection_for_read() （celery.worker.consumer.Consumer 方法） connection_for_read() （celery.worker.consumer.consumer.Consumer 方法） connection_for_write() （celery.Celery 方法） connection_for_write() （celery.worker.consumer.Consumer 方法） connection_for_write() （celery.worker.consumer.consumer.Consumer 方法） connection_or_acquire() （celery.Celery 方法） ConnectionPool（celery.backends.redis.RedisBackend 属性） Connection（celery.app.amqp.AMQP 属性） connection（celery.app.control.Control.Mailbox 属性） connection（celery.backends.arangodb.ArangoDbBackend 属性） connection（celery.backends.couchbase.CouchbaseBackend 属性） connection（celery.backends.couchdb.CouchBackend 属性） connection（celery.backends.rpc.RPCBackend.Producer 属性） connection（celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 属性） connection（celery.beat.Scheduler 属性） connection（celery.events.EventReceiver 属性） connection（celery.events.receiver.EventReceiver 属性） Connection（celery.worker.consumer 中的类） Connection（celery.worker.consumer.connection 中的类） consistency（celery.backends.consul.ConsulBackend 属性） ConsulBackend（celery.backends.consul 中的类） consul（celery.backends.consul.ConsulBackend 属性） consume() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） consume_from() （celery.backends.asynchronous.BaseResultConsumer 方法） consume_from() （celery.backends.redis.RedisBackend.ResultConsumer 方法） consume_from() （celery.backends.rpc.RPCBackend.ResultConsumer 方法） consume_from（celery.app.amqp.Queues 属性） Consumer.Blueprint（celery.worker.consumer 中的类） Consumer.Blueprint（celery.worker.consumer.consumer 中的类） ConsumerStep（celery.bootsteps 中的类） consumers（celery.bootsteps.ConsumerStep 属性） Consumer（celery.app.amqp.AMQP 属性） Consumer（celery.worker.components 中的类） Consumer（celery.worker.consumer 中的类） Consumer（celery.worker.consumer.consumer 中的类） consumer（celery.worker.pidbox.Pidbox 属性） consuming_from() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） container（celery.backends.couchdb.CouchBackend 属性） content_encoding（celery.worker.request.Request 属性） content_type（celery.worker.request.Request 属性） context ContextMock()（在 celery.contrib.testing.mocks 模块中） Context（celery.app.task 中的类） control active_queues add_consumer cancel_consumer disable_events enable_events ping rate_limit revoke revoke_by_stamped_headers shutdown Control.Mailbox（celery.app.control 中的类） control_exchange setting control_queue_expires setting control_queue_ttl setting controller Control（celery.app.control 中的类） control（celery.Celery 属性） Control（celery.worker.consumer 中的类） Control（celery.worker.consumer.control 中的类） convert() （celery.bin.base.CommaSeparatedList 方法） convert() （celery.bin.base.ISO8601DateTime 方法） convert() （celery.bin.base.ISO8601DateTimeOrFloat 方法） convert() （celery.bin.base.JsonArray 方法） convert() （celery.bin.base.JsonObject 方法） convert() （celery.bin.base.LogLevel 方法） convert() （celery.bin.worker.Autoscale 方法） convert() （celery.bin.worker.CeleryBeat 方法） convert() （celery.bin.worker.Hostname 方法） convert() （celery.bin.worker.WorkersPool 方法） copy() （celery.utils.collections.ChainMap 方法） correlation_id（celery.worker.request.Request 属性） cosmosdbsql_collection_name setting cosmosdbsql_consistency_level setting cosmosdbsql_database_name setting cosmosdbsql_max_retry_attempts setting cosmosdbsql_max_retry_wait_time setting CosmosDBSQLBackend（celery.backends.cosmosdbsql 中的类） CouchBackend（celery.backends.couchdb 中的类） couchbase_backend_settings setting CouchbaseBackend（celery.backends.couchbase 中的类） count（celery.contrib.migrate.State 属性） CPendingDeprecationWarning create() （celery.bootsteps.Step 方法） create() （celery.worker.autoscale.WorkerComponent 方法） create() （celery.worker.components.Beat 方法） create() （celery.worker.components.Consumer 方法） create() （celery.worker.components.Hub 方法） create() （celery.worker.components.Pool 方法） create() （celery.worker.components.StateDB 方法） create() （celery.worker.components.Timer 方法） create() （celery.worker.consumer.Agent 方法） create() （celery.worker.consumer.agent.Agent 方法） create_exception_cls()（在 celery.utils.serialization 模块中） create_pidlock()（在 celery.platforms 模块中） create_session() （celery.backends.database.session.SessionManager 方法） create_task_handler() （celery.worker.consumer.Consumer 方法） create_task_handler() （celery.worker.consumer.consumer.Consumer 方法） create_task_message（celery.app.amqp.AMQP 属性） crontab_parser.ParseException crontab_parser（celery.schedules 中的类） crontab（celery.schedules 中的类） current_app()（在 celery 模块中） current_app()（在 celery._state 模块中） current_task()（在 celery 模块中） current_task()（在 celery._state 模块中） current_task（celery.Celery 属性） current_worker_task（celery.Celery 属性） CursesMonitor（celery.events.cursesmon 中的类） cwd_in_path()（在 celery.utils.imports 模块中） cyan() （celery.utils.term.colored 方法） CycleError

D

daemon_setting() （celery.bin.base.DaemonOption 方法） DaemonContext（celery.platforms 中的类） DaemonOption（celery.bin.base 中的类） database_create_tables_at_setup setting database_engine_options setting database_name（celery.backends.mongodb.MongoBackend 属性） database_short_lived_sessions setting database_table_names setting database_table_schemas setting DatabaseBackend（celery.backends.database 中的类） database（celery.backends.arangodb.ArangoDbBackend 属性） database（celery.backends.mongodb.MongoBackend 属性） data（celery.apps.multi.Cluster 属性） data（celery.worker.control.Panel 属性） date_done（celery.backends.database.models.Task 属性） date_done（celery.backends.database.models.TaskExtended 属性） date_done（celery.backends.database.models.TaskSet 属性） date_done（celery.result.AsyncResult 属性） day_of_month（celery.schedules.crontab 属性） day_of_week（celery.schedules.crontab 属性） db（celery.backends.arangodb.ArangoDbBackend 属性） db（celery.worker.state.Persistent 属性） debugger()（在 celery.contrib.rdb 模块中） declare() （celery.backends.rpc.RPCBackend.Exchange 方法） declare() （celery.backends.rpc.RPCBackend.Producer 方法） declare() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） declare() （queue 方法） decode() （celery.backends.elasticsearch.ElasticsearchBackend 方法） decode() （celery.backends.mongodb.MongoBackend 方法） decompress() （celery.worker.state.Persistent 方法） dedent()（在 celery.utils.text 模块中） dedent_initial()（在 celery.utils.text 模块中） default()（在 celery.worker.strategy 模块中） default_app()（在 celery.app 模块中） default_dispatcher() （celery.app.events.Events 方法） default_exchange（celery.app.amqp.AMQP 属性） default_modules（celery.loaders.base.BaseLoader 属性） default_nodename()（在 celery.utils.nodenames 模块中） default_now() （celery.beat.ScheduleEntry 方法） default_queue（celery.app.amqp.AMQP 属性） default_retry_delay（celery.app.task.Task 属性） default_retry_delay（Task 属性） default_socket_timeout()（在 celery.utils.threads 模块中） default_steps（celery.bootsteps.Blueprint 属性） default_steps（celery.worker.consumer.Consumer.Blueprint 属性） default_steps（celery.worker.consumer.consumer.Consumer.Blueprint 属性） default_steps（celery.worker.WorkController.Blueprint 属性） default_steps（celery.worker.worker.WorkController.Blueprint 属性） DEFAULT_TEST_CONFIG()（在 celery.contrib.testing.app 模块中） defaults（celery.utils.collections.ChainMap 属性） delay() （celery.app.task.Task 方法） delay() （celery.utils.abstract.CallableTask 方法） delay_on_commit() （celery.contrib.django.task.DjangoTask 方法） delete() （celery.backends.arangodb.ArangoDbBackend 方法） delete() （celery.backends.cache.CacheBackend 方法） delete() （celery.backends.consul.ConsulBackend 方法） delete() （celery.backends.cosmosdbsql.CosmosDBSQLBackend 方法） delete() （celery.backends.couchbase.CouchbaseBackend 方法） delete() （celery.backends.couchdb.CouchBackend 方法） delete() （celery.backends.dynamodb.DynamoDBBackend 方法） delete() （celery.backends.elasticsearch.ElasticsearchBackend 方法） delete() （celery.backends.filesystem.FilesystemBackend 方法） delete() （celery.backends.redis.RedisBackend 方法） delete() （celery.backends.rpc.RPCBackend.Exchange 方法） delete() （celery.backends.s3.S3Backend 方法）

delete() （celery.result.GroupResult 方法） delete() （exchange 方法） delete() （queue 方法） delete_group() （celery.backends.rpc.RPCBackend 方法） deleter() （celery.utils.cached_property 方法） delivery_info（celery.worker.request.Request 属性） delivery_mode（celery.backends.rpc.RPCBackend.Exchange 属性） DELIVERY_TAG celery-amqp-basic.ack命令行选项 delta_resolution()（在 celery.utils.time 模块中） DependencyGraph（celery.utils.graph 中的类） depends_on_current_app()（在 celery.contrib.pytest 模块中） deprecate_by（celery.app.defaults.Option 属性） deselect() （celery.app.amqp.Queues 方法） deserialize() （celery.security.serialization.SecureSerializer 方法） DESTINATION celery-migrate命令行选项 destination_for() （celery.backends.rpc.RPCBackend 方法） detach()（在 celery.bin.worker 模块中） detached()（在 celery.platforms 模块中） df（celery.utils.sysinfo 中的类） DictAttribute（celery.utils.collections 中的类） dictfilter()（在 celery.utils.functional 模块中） did_start_ok() （celery.concurrency.base.BasePool 方法） did_start_ok() （celery.concurrency.prefork.TaskPool 方法） DIRS（celery.utils.graph.DOT 属性） disable() （celery.events.dispatcher.EventDispatcher 方法） disable() （celery.events.EventDispatcher 方法） disable_events control disable_events() （celery.app.control.Control 方法） disable_trace()（在 celery.app 模块中） DISABLED_TRANSPORTS（celery.events.dispatcher.EventDispatcher 属性） DISABLED_TRANSPORTS（celery.events.EventDispatcher 属性） DisabledBackend（celery.backends.base 中的类） discard() （celery.result.ResultSet 方法） discard() （celery.utils.collections.LimitedSet 方法） discard_all() （celery.app.control.Control 方法） disconnect() （celery.utils.dispatch.Signal 方法） disconnect() （celery.utils.dispatch.signal.Signal 方法） dispatcher_cls（celery.app.events.Events 属性） Dispatcher（celery.app.events.Events 属性） 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], [5], [6] DjangoTask（celery.contrib.django.task 中的类） doc_type（celery.backends.elasticsearch.ElasticsearchBackend 属性） document_members() （celery.contrib.sphinx.TaskDocumenter 方法） dont_autoretry_for（Task 属性） DOT（celery.utils.graph 中的类） DOWN（celery.bin.multi.MultiTool 属性） drain_events() （celery.backends.asynchronous.BaseResultConsumer 方法） drain_events() （celery.backends.redis.RedisBackend.ResultConsumer 方法） drain_events() （celery.backends.rpc.RPCBackend.ResultConsumer 方法） drain_events_until() （celery.backends.asynchronous.BaseResultConsumer 方法） drain_events_until() （celery.backends.asynchronous.Drainer 方法） Drainer（celery.backends.asynchronous 中的类） draw() （celery.events.cursesmon.CursesMonitor 方法） draw_edge() （celery.utils.graph.GraphFormatter 方法） draw_node() （celery.utils.graph.GraphFormatter 方法） dst() （celery.utils.time.LocalTimezone 方法） dump_body()（在 celery.worker.consumer.consumer 模块中） Dumper（celery.events.dumper 中的类） DuplicateNodenameWarning DURABLE celery-amqp-exchange.declare命令行选项 celery-amqp-queue.declare命令行选项 durable（celery.backends.rpc.RPCBackend.Exchange 属性） DynamoDBBackend（celery.backends.dynamodb 中的类）

E

EagerResult（celery.result 中的类） early ack early acknowledgment echo() （celery.bin.base.CLIContext 方法） edge() （celery.utils.graph.GraphFormatter 方法） edge_scheme（celery.utils.graph.GraphFormatter 属性） edges() （celery.utils.graph.DependencyGraph 方法） EDGE（celery.utils.graph.DOT 属性） editable_fields_equal() （celery.beat.ScheduleEntry 方法） elasticsearch_max_retries setting elasticsearch_retry_on_timeout setting elasticsearch_save_meta_as_text setting elasticsearch_timeout setting ElasticsearchBackend（celery.backends.elasticsearch 中的类） election() （celery.app.control.Control 方法） election() （celery.worker.consumer.Gossip 方法） election() （celery.worker.consumer.gossip.Gossip 方法） embed() （celery.utils.term.colored 方法） EmbeddedService()（在 celery.beat 模块中） emit_banner() （celery.apps.worker.Worker 方法） empty() （celery.concurrency.base.BasePool.Timer 方法） empty() （celery.utils.timer2.Timer 方法） enable() （celery.events.dispatcher.EventDispatcher 方法） enable() （celery.events.EventDispatcher 方法） enable_events control enable_events() （celery.app.control.Control 方法） enable_trace()（在 celery.app 模块中） enable_utc setting enabled（celery.bootsteps.Step 属性） encode() （celery.backends.elasticsearch.ElasticsearchBackend 方法） encode() （celery.backends.mongodb.MongoBackend 方法） endpoint_url（celery.backends.dynamodb.DynamoDBBackend 属性） ensure() （celery.backends.redis.RedisBackend 方法） ensure_chords_allowed() （celery.backends.base.DisabledBackend 方法） ensure_chords_allowed() （celery.backends.rpc.RPCBackend 方法） ensure_connected() （celery.worker.consumer.Consumer 方法） ensure_connected() （celery.worker.consumer.consumer.Consumer 方法） ensure_newlines()（在 celery.utils.text 模块中） ensure_not_for_a_while() （celery.contrib.testing.manager.ManagerMixin 方法） ensure_sep()（在 celery.utils.text 模块中） ensure_started() （celery.concurrency.base.BasePool.Timer 方法） ensure_started() （celery.contrib.testing.worker.TestWorkController 方法） ensure_started() （celery.utils.timer2.Timer 方法） enter() （celery.concurrency.base.BasePool.Timer 方法） enter() （celery.utils.timer2.Timer 方法） enter_after() （celery.concurrency.base.BasePool.Timer 方法） enter_after() （celery.utils.timer2.Timer 方法） Entry（celery.beat.Scheduler 属性） Entry（celery.utils.timer2 中的类） errbacks（celery.worker.request.Request 属性） error() （celery.bin.base.CLIContext 方法） ERROR（celery.bin.base.CLIContext 属性） es_max_retries（celery.backends.elasticsearch.ElasticsearchBackend 属性） es_retry_on_timeout（celery.backends.elasticsearch.ElasticsearchBackend 属性） es_timeout（celery.backends.elasticsearch.ElasticsearchBackend 属性） ETA eta（celery.events.state.State.Task 属性） eta（celery.events.state.Task 属性） eta（celery.worker.request.Request 属性） evaluate() （celery.utils.functional.lazy 方法） evaluate() （celery.utils.functional.mlazy 方法） evaluated（celery.utils.functional.mlazy 属性） evcam()（在 celery.events.snapshot 模块中） evdump()（在 celery.events.dumper 模块中） event task-failed task-received task-rejected task-retried task-revoked task-sent task-started task-succeeded worker-heartbeat worker-offline worker-online event() （celery.events.state.State 方法） event() （celery.events.state.State.Task 方法） event() （celery.events.state.Task 方法） Event()（在 celery.events 模块中） Event()（在 celery.events.event 模块中） event_count（celery.events.state.State 属性） event_dispatcher event_exchange setting event_exchange()（在 celery.events.event 模块中） event_from_message() （celery.events.EventReceiver 方法）

event_from_message() （celery.events.receiver.EventReceiver 方法） event_queue_expires setting event_queue_prefix setting event_queue_ttl setting event_serializer setting EventDispatcher（celery.events 中的类） EventDispatcher（celery.events.dispatcher 中的类） eventer（celery.worker.request.Request 属性） eventlet_pool_apply signal eventlet_pool_postshutdown signal eventlet_pool_preshutdown signal eventlet_pool_started signal EventReceiver（celery.events 中的类） EventReceiver（celery.events.receiver 中的类） events_executable setting events_gid setting events_logfile setting events_pidfile setting events_uid setting events_umask setting Events（celery.app.events 中的类） events（celery.Celery 属性） Events（celery.worker.consumer 中的类） Events（celery.worker.consumer.events 中的类） event（celery.events.state.State.Worker 属性） event（celery.events.state.Worker 属性） evict() （celery.utils.collections.Evictable 方法） Evictable.Empty Evictable（celery.utils.collections 中的类） Evloop（celery.worker.consumer.consumer 中的类） evtop()（在 celery.events.cursesmon 模块中） exc_args（celery.utils.serialization.UnpickleableExceptionWrapper 属性） exc_cls_name（celery.utils.serialization.UnpickleableExceptionWrapper 属性） exc_module（celery.utils.serialization.UnpickleableExceptionWrapper 属性） exception_safe_to_retry() （celery.backends.elasticsearch.ElasticsearchBackend 方法） exception_safe_to_retry() （celery.backends.redis.RedisBackend 方法） EXCEPTION_STATES state exception（celery.events.state.State.Task 属性） exception（celery.events.state.Task 属性） EXCHANGE celery-amqp-basic.publish命令行选项 celery-amqp-exchange.declare命令行选项 celery-amqp-exchange.delete命令行选项 celery-amqp-queue.bind命令行选项 exchange_fmt（celery.app.control.Control.Mailbox 属性） exchange（celery.app.control.Control.Mailbox 属性） exchange（celery.backends.rpc.RPCBackend.Producer 属性） exchange（celery.events.state.State.Task 属性） exchange（celery.events.state.Task 属性） exc（celery.exceptions.Retry 属性） executable（celery.apps.multi.Node 属性） executable（celery.bin.multi.MultiTool.MultiParser.Node 属性） execute() （celery.worker.request.Request 方法） execute_from_commandline() （celery.bin.multi.MultiTool 方法） execute_using_pool() （celery.worker.request.Request 方法） executing exit_after() （celery.concurrency.base.BasePool.Timer 方法） exit_after() （celery.utils.timer2.Timer 方法） exitcode（celery.worker.WorkController 属性） exitcode（celery.worker.worker.WorkController 属性） expand() （celery.bin.multi.MultiTool 方法） expand_destination() （celery.app.routes.Router 方法） expand_router_string()（在 celery.app.routes 模块中） expire() （celery.backends.cache.CacheBackend 方法） expire() （celery.backends.redis.RedisBackend 方法） expire_window（celery.events.state.State.Worker 属性） expire_window（celery.events.state.Worker 属性） expires_delta（celery.backends.arangodb.ArangoDbBackend 属性） expires_delta（celery.backends.mongodb.MongoBackend 属性） expires（celery.app.task.Task 属性） expires（celery.events.state.State.Task 属性） expires（celery.events.state.Task 属性） expires（celery.worker.request.Request 属性） extend() （celery.utils.collections.BufferMap 方法） extend() （celery.utils.collections.Messagebuffer 方法） extend_buffer() （celery.events.dispatcher.EventDispatcher 方法） extend_buffer() （celery.events.EventDispatcher 方法） extended_result（celery.backends.database.DatabaseBackend 属性） extra_info() （celery.apps.worker.Worker 方法）

F

failed() （celery.result.AsyncResult 方法） failed() （celery.result.ResultSet 方法） FAILED（celery.bin.multi.MultiTool 属性） failed（celery.events.state.State.Task 属性） failed（celery.events.state.Task 属性） FAILURE state FAILURE()（在 celery.states 模块中） FallbackContext（celery.utils.objects 中的类） fd_by_path()（在 celery.platforms 模块中） ffwd（celery.utils.time 中的类） FILENAME celery-upgrade-settings命令行选项 FILES celery-logtool-debug命令行选项 celery-logtool-errors命令行选项 celery-logtool-incomplete命令行选项 celery-logtool-stats命令行选项 celery-logtool-traces命令行选项 FilesystemBackend（celery.backends.filesystem 中的类） fill_paragraphs()（在 celery.utils.text 模块中） filter_hidden_settings()（在 celery.app.utils 模块中） filter_types() （celery.app.registry.TaskRegistry 方法） filtered（celery.contrib.migrate.State 属性） finalize() （celery.app.utils.Settings 方法） finalize() （celery.Celery 方法） find() （celery.apps.multi.Cluster 方法） find()（在 celery.app.defaults 模块中） find_app()（在 celery.app.utils 模块中） find_module() （celery.loaders.base.BaseLoader 方法） find_module()（在 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 方法） firestore_client（celery.backends.gcs.GCSBackend 属性） first() （celery.utils.collections.ConfigurationView 方法） first()（在 celery.utils.functional 模块中） first_connection_attempt（celery.worker.consumer.Consumer 属性） first_connection_attempt（celery.worker.consumer.consumer.Consumer 属性） firstmethod()（在 celery.utils.functional 模块中）

FixupWarning flatten()（在 celery.app.defaults 模块中） flatten_reply()（在 celery.app.control 模块中） flow() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） flush() （celery.concurrency.base.BasePool 方法） flush() （celery.events.dispatcher.EventDispatcher 方法） flush() （celery.events.EventDispatcher 方法） flush() （celery.utils.log.LoggingProxy 方法） flush_routes() （celery.app.amqp.AMQP 方法） FMT() （celery.utils.graph.GraphFormatter 方法） force_mapping()（在 celery.utils.collections 模块中） foreground（celery.events.cursesmon.CursesMonitor 属性） forget() （celery.backends.redis.RedisBackend 方法） forget() （celery.result.AsyncResult 方法） forget() （celery.result.EagerResult 方法） forget() （celery.result.ResultSet 方法） format() （celery.app.amqp.Queues 方法） format() （celery.app.log.TaskFormatter 方法） format() （celery.utils.graph.DependencyGraph 方法） format() （celery.utils.log.ColorFormatter 方法） format_args() （celery.contrib.sphinx.TaskDocumenter 方法） format_options() （celery.bin.base.CeleryCommand 方法） format_row() （celery.events.cursesmon.CursesMonitor 方法） format_task_event() （celery.events.dumper.Dumper 方法） formatException() （celery.utils.log.ColorFormatter 方法） freeze() （celery.utils.abstract.CallableSignature 方法） freeze() （State 方法） freeze_while() （celery.events.state.State 方法） freeze_while() （State 方法） freq（celery.events.state.State.Worker 属性） freq（celery.events.state.Worker 属性） from_exception()（celery.utils.serialization.UnpickleableExceptionWrapper 类方法） from_kwargs()（celery.apps.multi.Node 类方法） from_kwargs()（celery.bin.multi.MultiTool.MultiParser.Node 类方法） from_string()（celery.schedules.crontab 类方法） fromkeys()（celery.utils.collections.ChainMap 类方法） fromutc() （celery.utils.time.LocalTimezone 方法） FSCertStore（celery.security.certificate 中的类） fun_accepts_kwargs()（在 celery.utils.functional 模块中） fun（celery.concurrency.base.BasePool.Timer.Entry 属性） fun（celery.utils.timer2.Entry 属性） fun（celery.utils.timer2.Timer.Entry 属性）

G

gcs_base_path setting gcs_bucket setting gcs_project setting GCSBackend（celery.backends.gcs 中的类） gen_task_name() （celery.Celery 方法） gen_task_name()（在 celery.utils 模块中） gen_task_name()（在 celery.utils.imports 模块中） gen_unique_id()（在 celery.utils 模块中） get() （celery.backends.arangodb.ArangoDbBackend 方法） get() （celery.backends.cache.CacheBackend 方法） get() （celery.backends.consul.ConsulBackend 方法） get() （celery.backends.cosmosdbsql.CosmosDBSQLBackend 方法） get() （celery.backends.couchbase.CouchbaseBackend 方法） get() （celery.backends.couchdb.CouchBackend 方法） get() （celery.backends.dynamodb.DynamoDBBackend 方法） get() （celery.backends.elasticsearch.ElasticsearchBackend 方法） get() （celery.backends.filesystem.FilesystemBackend 方法） get() （celery.backends.redis.RedisBackend 方法） get() （celery.backends.s3.S3Backend 方法） get() （celery.bin.multi.MultiTool 方法） get() （celery.result.AsyncResult 方法） get() （celery.result.EagerResult 方法） get() （celery.result.ResultSet 方法） get() （celery.utils.collections.ChainMap 方法） get() （celery.utils.collections.ConfigurationView 方法） get() （celery.utils.collections.DictAttribute 方法） get_available_pool_names()（在 celery.concurrency 模块中） get_by_parts() （celery.app.utils.Settings 方法） get_cls_by_name()（在 celery.utils 模块中） get_consumers() （celery.bootsteps.ConsumerStep 方法） get_consumers() （celery.events.EventReceiver 方法） get_consumers() （celery.events.receiver.EventReceiver 方法） get_consumers() （celery.worker.consumer.Gossip 方法） get_consumers() （celery.worker.consumer.gossip.Gossip 方法） get_current_app()（在 celery._state 模块中） get_current_task()（在 celery._state 模块中） get_current_worker_task()（在 celery._state 模块中） get_default() （celery.bin.base.CeleryOption 方法） get_default_logger() （celery.app.log.Logging 方法） get_digest_algorithm()（在 celery.security.utils 模块中） get_engine() （celery.backends.database.session.SessionManager 方法） get_errno_name()（在 celery.platforms 模块中） get_exchange()（在 celery.events 模块中） get_exchange()（在 celery.events.event 模块中） get_exponential_backoff_interval()（在 celery.utils.time 模块中） get_fdmax()（在 celery.platforms 模块中） get_full_cls_name()（在 celery.utils 模块中） get_id() （celery.security.certificate.Certificate 方法） get_ident() （celery.utils.threads.LocalManager 方法） get_ident()（在 celery.utils.threads 模块中） get_implementation()（在 celery.concurrency 模块中）

get_issuer() （celery.security.certificate.Certificate 方法） get_leaf() （celery.result.AsyncResult 方法） get_loader_cls()（在 celery.loaders 模块中） get_logger()（在 celery.utils.log 模块中） get_many() （celery.backends.base.DisabledBackend 方法） get_multiprocessing_logger()（在 celery.utils.log 模块中） 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_pubkey() （celery.security.certificate.Certificate 方法） get_queue() （celery.app.control.Control.Mailbox 方法） get_reply_queue() （celery.app.control.Control.Mailbox 方法） get_result() （celery.backends.base.DisabledBackend 方法） get_schedule() （celery.beat.PersistentScheduler 方法） get_schedule() （celery.beat.Scheduler 方法） get_scheduler() （celery.apps.beat.Beat.Service 方法） get_scheduler() （celery.beat.Service 方法） get_serial_number() （celery.security.certificate.Certificate 方法） get_signature_prefix() （celery.contrib.sphinx.TaskDirective 方法） get_state() （celery.backends.base.DisabledBackend 方法） get_status() （celery.backends.base.DisabledBackend 方法） get_task_logger()（在 celery.utils.log 模块中） get_task_meta() （celery.backends.rpc.RPCBackend 方法） get_task_meta_for() （celery.backends.base.DisabledBackend 方法） get_traceback() （celery.backends.base.DisabledBackend 方法） gethostname()（在 celery.utils.nodenames 模块中） getitem_property（celery.utils.objects 中的类） getopt() （celery.apps.multi.Node 方法） getopt() （celery.bin.multi.MultiTool.MultiParser.Node 方法） getpids() （celery.apps.multi.Cluster 方法） gossip Gossip（celery.worker.consumer 中的类） Gossip（celery.worker.consumer.gossip 中的类） gPidbox（celery.worker.pidbox 中的类） graph_scheme（celery.utils.graph.GraphFormatter 属性） GraphFormatter（celery.bootsteps.Blueprint 属性） GraphFormatter（celery.utils.graph 中的类） graph（celery.result.AsyncResult 属性） green() （celery.utils.term.colored 方法） greet（celery.events.cursesmon.CursesMonitor 属性） group_collection（celery.backends.mongodb.MongoBackend 属性） group_from()（在 celery.events 模块中） group_from()（在 celery.events.event 模块中） group_index（celery.worker.request.Request 属性） groupmeta_collection（celery.backends.mongodb.MongoBackend 属性） GroupResult（celery.Celery 属性） GroupResult（celery.result 中的类） groups（celery.worker.request.Request 属性） group（celery 中的类） group（celery.worker.request.Request 属性） grow() （celery.concurrency.eventlet.TaskPool 方法） grow() （celery.concurrency.gevent.TaskPool 方法）

H

handle_error_state() （celery.app.trace.TraceInfo 方法） handle_failure() （celery.app.trace.TraceInfo 方法） handle_ignore() （celery.app.trace.TraceInfo 方法） handle_keypress() （celery.events.cursesmon.CursesMonitor 方法） handle_preload_options()（在 celery.bin.base 模块中） handle_process_exit() （celery.apps.multi.Node 方法） handle_process_exit() （celery.bin.multi.MultiTool.MultiParser.Node 方法） handle_reject() （celery.app.trace.TraceInfo 方法） handle_retry() （celery.app.trace.TraceInfo 方法） handleError() （celery.contrib.testing.worker.TestWorkController.QueueHandler 方法） has_expired() （celery.security.certificate.Certificate 方法） has_listeners() （celery.utils.dispatch.Signal 方法） has_listeners() （celery.utils.dispatch.signal.Signal 方法） head() （celery.utils.graph.GraphFormatter 方法） head_from_fun()（在 celery.utils.functional 模块中） HEAD（celery.utils.graph.DOT 属性） heap_multiplier（celery.events.state.State 属性） heart heartbeat() （celery.app.control.Control 方法） heartbeat_expires()（在 celery.events.state 模块中） heartbeat_expires（celery.events.state.State.Worker 属性） heartbeat_expires（celery.events.state.Worker 属性） heartbeat_max（celery.events.state.State.Worker 属性） heartbeat_max（celery.events.state.Worker 属性） heartbeat_sent signal heartbeats（celery.events.state.State.Worker 属性） heartbeats（celery.events.state.Worker 属性）

Heart（celery.worker.consumer 中的类） Heart（celery.worker.consumer.heart 中的类） Heart（celery.worker.heartbeat 中的类） hello() （celery.app.control.Inspect 方法） help() （celery.bin.multi.MultiTool 方法） help_title（celery.events.cursesmon.CursesMonitor 属性） help（celery.events.cursesmon.CursesMonitor 属性） host_format()（在 celery.utils.nodenames 模块中） hostname, [1] Hostname（celery.bin.worker 中的类） hostname（celery.events.state.State.Worker 属性） hostname（celery.events.state.Worker 属性） hostname（celery.worker.request.Request 属性） host（celery.backends.arangodb.ArangoDbBackend 属性） host（celery.backends.couchbase.CouchbaseBackend 属性） host（celery.backends.couchdb.CouchBackend 属性） host（celery.backends.elasticsearch.ElasticsearchBackend 属性） host（celery.backends.mongodb.MongoBackend 属性） hour（celery.schedules.crontab 属性） http_protocol（celery.backends.arangodb.ArangoDbBackend 属性） hub, [1] Hub（celery.worker.components 中的类） human_seconds（celery.schedules.schedule 属性） human_state() （celery.bootsteps.Blueprint 方法） humaninfo() （celery.worker.request.Request 方法） humanize() （celery.app.utils.Settings 方法） humanize() （celery.exceptions.Retry 方法） humanize_seconds()（在 celery.utils.time 模块中）

I

iblue() （celery.utils.term.colored 方法） icyan() （celery.utils.term.colored 方法） idempotent id（celery.backends.database.models.Task 属性） id（celery.backends.database.models.TaskExtended 属性） id（celery.backends.database.models.TaskSet 属性） id（celery.events.state.State.Task 属性） id（celery.events.state.State.Worker 属性） id（celery.events.state.Task 属性） id（celery.events.state.Worker 属性） id（celery.result.AsyncResult 属性） id（celery.result.GroupResult 属性） id（celery.utils.abstract.CallableSignature 属性） id（celery.worker.request.Request 属性） IF_EMPTY celery-amqp-queue.delete命令行选项 IF_UNUSED celery-amqp-exchange.delete命令行选项 celery-amqp-queue.delete命令行选项 Ignore ignore_errno()（在 celery.platforms 模块中） ignore_result（celery.app.task.Task 属性） ignore_result（celery.worker.request.Request 属性） ignore_result（Task 属性） ignored（celery.result.AsyncResult 属性） igreen() （celery.utils.term.colored 方法） imagenta() （celery.utils.term.colored 方法） IMMEDIATE celery-amqp-basic.publish命令行选项 immutable（celery.utils.abstract.CallableSignature 属性） implements_incr（celery.backends.cache.CacheBackend 属性） implements_incr（celery.backends.dynamodb.DynamoDBBackend 属性） implements_incr（celery.backends.gcs.GCSBackend 属性） import_default_modules() （celery.loaders.base.BaseLoader 方法） import_from_cwd() （celery.loaders.base.BaseLoader 方法） import_from_cwd()（在 celery.utils 模块中） import_from_cwd()（在 celery.utils.imports 模块中） import_module() （celery.loaders.base.BaseLoader 方法） import_modules signal import_task_module() （celery.loaders.base.BaseLoader 方法） imports setting ImproperlyConfigured in_sighandler()（在 celery.utils.log 模块中） include setting include() （celery.bootsteps.StartStopStep 方法） include() （celery.bootsteps.Step 方法） include_if() （celery.bootsteps.Step 方法） include_if() （celery.worker.components.Hub 方法） include_if() （celery.worker.consumer.Control 方法） include_if() （celery.worker.consumer.control.Control 方法） IncompleteStream incr() （celery.backends.cache.CacheBackend 方法） incr() （celery.backends.dynamodb.DynamoDBBackend 方法） incr() （celery.backends.gcs.GCSBackend 方法） incr() （celery.backends.redis.RedisBackend 方法） incr() （celery.utils.functional.LRUCache 方法） indent()（在 celery.utils.text 模块中） index（celery.backends.elasticsearch.ElasticsearchBackend 属性） info() （celery.bootsteps.Blueprint 方法） info() （celery.bootsteps.Step 方法） info() （celery.events.state.State.Task 方法） info() （celery.events.state.Task 方法） info() （celery.worker.autoscale.Autoscaler 方法） info() （celery.worker.autoscale.WorkerComponent 方法） info() （celery.worker.components.Pool 方法） info() （celery.worker.consumer.Connection 方法） info() （celery.worker.consumer.connection.Connection 方法） info() （celery.worker.consumer.Tasks 方法）

info() （celery.worker.consumer.tasks.Tasks 方法） info() （celery.worker.request.Request 方法） info() （celery.worker.WorkController 方法） info() （celery.worker.worker.WorkController 方法） info_str（celery.events.cursesmon.CursesMonitor 属性） info（celery.beat.PersistentScheduler 属性） info（celery.beat.Scheduler 属性） info（celery.concurrency.base.BasePool 属性） info（celery.result.AsyncResult 属性） init_callback（celery.worker.consumer.Consumer 属性） init_callback（celery.worker.consumer.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 模块中） inspect() （celery.contrib.testing.manager.ManagerMixin 方法） 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 方法） instantiate()（在 celery.utils 模块中） instantiate()（在 celery.utils.imports 模块中） InvalidTaskError ired() （celery.utils.term.colored 方法） is_aborted() （celery.contrib.abortable.AbortableAsyncResult 方法） is_aborted() （celery.contrib.abortable.AbortableTask 方法） is_accepted() （celery.contrib.testing.manager.ManagerMixin 方法） is_async（celery.backends.asynchronous.AsyncBackendMixin 属性） is_due() （celery.beat.ScheduleEntry 方法） is_due() （celery.beat.Scheduler 方法） is_due() （celery.schedules.crontab 方法） is_due() （celery.schedules.schedule 方法） is_due() （celery.schedules.solar 方法） is_green（celery.concurrency.base.BasePool 属性） is_green（celery.concurrency.eventlet.TaskPool 属性） is_green（celery.concurrency.gevent.TaskPool 属性） is_list()（在 celery.utils.functional 模块中） is_locked() （celery.platforms.Pidfile 方法） is_naive()（在 celery.utils.time 模块中） is_received() （celery.contrib.testing.manager.ManagerMixin 方法） is_result_task_in_progress()（celery.contrib.testing.manager.ManagerMixin 静态方法） isatty() （celery.utils.log.LoggingProxy 方法） isatty()（在 celery.platforms 模块中） ISO8601DateTimeOrFloat（celery.bin.base 中的类） ISO8601DateTime（celery.bin.base 中的类） items() （celery.utils.collections.ChainMap 方法） items() （celery.utils.collections.DictAttribute 方法） items() （celery.utils.functional.LRUCache 方法） items() （celery.utils.graph.DependencyGraph 方法） iter_native() （celery.backends.asynchronous.AsyncBackendMixin 方法） iter_native() （celery.result.ResultSet 方法） itercapture() （celery.events.EventReceiver 方法） itercapture() （celery.events.receiver.EventReceiver 方法） itercerts() （celery.security.certificate.CertStore 方法） iterdeps() （celery.result.AsyncResult 方法） iteritems() （celery.utils.collections.ChainMap 方法） iteritems() （celery.utils.collections.DictAttribute 方法） iteritems() （celery.utils.functional.LRUCache 方法） iteritems() （celery.utils.graph.DependencyGraph 方法） iterkeys() （celery.utils.collections.ChainMap 方法） iterkeys() （celery.utils.collections.DictAttribute 方法） iterkeys() （celery.utils.functional.LRUCache 方法） itertasks() （celery.events.state.State 方法） itervalues() （celery.utils.collections.ChainMap 方法） itervalues() （celery.utils.collections.DictAttribute 方法） itervalues() （celery.utils.functional.LRUCache 方法） iwhite() （celery.utils.term.colored 方法） iyellow() （celery.utils.term.colored 方法）

J

join() （celery.bootsteps.Blueprint 方法） join() （celery.contrib.testing.manager.ManagerMixin 方法） join() （celery.result.ResultSet 方法）

join()（在 celery.utils.text 模块中） join_native() （celery.result.ResultSet 方法） JsonArray（celery.bin.base 中的类） JsonObject（celery.bin.base 中的类）

K

key_t（celery.backends.arangodb.ArangoDbBackend 属性） key_t（celery.backends.couchbase.CouchbaseBackend 属性） key_t（celery.utils.collections.ChainMap 属性） keyalias（celery.events.cursesmon.CursesMonitor 属性） keymap（celery.events.cursesmon.CursesMonitor 属性） keys() （celery.utils.collections.ChainMap 方法） keys() （celery.utils.collections.DictAttribute 方法） keys() （celery.utils.functional.LRUCache 方法） KeyValueStoreBackend（celery.backends.base 中的类） kill() （celery.apps.multi.Cluster 方法） kill() （celery.bin.multi.MultiTool 方法） known_suffixes（celery.beat.PersistentScheduler 属性）

kombu kwargsrepr_maxsize（celery.app.amqp.AMQP 属性） kwargsrepr（celery.worker.request.Request 属性） kwargs（celery.backends.database.models.TaskExtended 属性） kwargs（celery.beat.ScheduleEntry 属性） kwargs（celery.concurrency.base.BasePool.Timer.Entry 属性） kwargs（celery.events.state.State.Task 属性） kwargs（celery.events.state.Task 属性） kwargs（celery.result.AsyncResult 属性） kwargs（celery.utils.abstract.CallableSignature 属性） kwargs（celery.utils.timer2.Entry 属性） kwargs（celery.utils.timer2.Timer.Entry 属性） kwargs（celery.worker.request.Request 属性）

L

label() （celery.utils.graph.GraphFormatter 方法） label（celery.bootsteps.Step 属性） label（celery.worker.autoscale.WorkerComponent 属性） label（celery.worker.components.Beat 属性） label（celery.worker.consumer.consumer.Evloop 属性） label（celery.worker.consumer.Gossip 属性） label（celery.worker.consumer.gossip.Gossip 属性） label（celery.worker.consumer.Mingle 属性） label（celery.worker.consumer.mingle.Mingle 属性） last_run_at（celery.beat.ScheduleEntry 属性） last（celery.bootsteps.Step 属性） last（celery.worker.components.Consumer 属性） last（celery.worker.consumer.consumer.Evloop 属性） late ack late acknowledgment lazy（celery.utils.functional 中的类） LimitedSet（celery.utils.collections 中的类） limit（celery.concurrency.thread.TaskPool 属性） limit（celery.events.cursesmon.CursesMonitor 属性） link() （celery.utils.abstract.CallableSignature 方法） link_error() （celery.utils.abstract.CallableSignature 方法） load_average()（在 celery.utils.sysinfo 模块中） load_step() （celery.bootsteps.Blueprint 方法） loadavg（celery.events.state.State.Worker 属性）

loadavg（celery.events.state.Worker 属性） loader（celery.Celery 属性） Loader（celery.loaders.default 中的类） localize()（在 celery.utils.time 模块中） LocalManager（celery.utils.threads 中的类） LocalStack()（在 celery.utils.threads 模块中） LocalTimezone（celery.utils.time 中的类） Local（celery.utils.threads 中的类） LockFailed logfile（celery.apps.multi.Node 属性） logfile（celery.bin.multi.MultiTool.MultiParser.Node 属性） logger_queue（celery.contrib.testing.worker.TestWorkController 属性） logger（celery.beat.Scheduler 属性） LoggingProxy（celery.utils.log 中的类） Logging（celery.app.log 中的类） LogLevel（celery.bin.base 中的类） loglevel（celery.utils.log.LoggingProxy 属性） log（celery.Celery 属性） lookup_route() （celery.app.routes.Router 方法） loop() （celery.worker.pidbox.gPidbox 方法） loop_args() （celery.worker.consumer.Consumer 方法） loop_args() （celery.worker.consumer.consumer.Consumer 方法） lpmerge()（在 celery.utils.collections 模块中） LRUCache（celery.utils.functional 中的类）

M

macOS_proxy_detection_workaround() （celery.apps.worker.Worker 方法） magenta() （celery.utils.term.colored 方法） main()（在 celery.bin.celery 模块中） maintain_pool() （celery.concurrency.base.BasePool 方法） make_aware()（在 celery.utils.time 模块中） ManagerMixin（celery.contrib.testing.manager 中的类） Manager（celery.contrib.testing.manager 中的类） MANDATORY celery-amqp-basic.publish命令行选项 map() （celery.app.task.Task 方法） MapAnnotation（celery.app.annotations 中的类） MapRoute（celery.app.routes 中的类） maps（celery.utils.collections.ChainMap 属性） mattrgetter()（在 celery.utils.functional 模块中） max_connections（celery.backends.redis.RedisBackend 属性） max_heap_percent_overload（celery.utils.collections.LimitedSet 属性） max_interval（celery.beat.Scheduler 属性） max_pool_size（celery.backends.mongodb.MongoBackend 属性） max_prefetch_count（celery.worker.consumer.Consumer 属性） max_prefetch_count（celery.worker.consumer.consumer.Consumer 属性） max_retries（celery.app.task.Task 属性） max_retries（Task 属性）, [1] MaxRetriesExceededError maxsize（celery.utils.collections.BufferMap 属性） maybe()（在 celery.utils.functional 模块中） maybe_declare() （celery.backends.rpc.RPCBackend.Producer 方法） maybe_drop_privileges()（在 celery.platforms 模块中） maybe_evaluate()（在 celery.utils.functional 模块中） maybe_expire() （celery.worker.request.Request 方法） maybe_iso8601()（在 celery.utils.time 模块中） maybe_list()（在 celery.utils.functional 模块中） maybe_make_aware()（在 celery.utils.time 模块中） maybe_reraise() （celery.result.AsyncResult 方法） maybe_reraise() （celery.result.ResultSet 方法） maybe_scale() （celery.worker.autoscale.Autoscaler 方法） maybe_schedule()（在 celery.schedules 模块中） maybe_shutdown()（在 celery.worker.state 模块中） maybe_throw() （celery.result.AsyncResult 方法） maybe_throw() （celery.result.ResultSet 方法） maybe_timedelta()（在 celery.utils.time 模块中） maybe_warn_deprecated_settings() （celery.app.utils.Settings 方法） mem_rss()（在 celery.utils.debug 模块中） member_order（celery.contrib.sphinx.TaskDocumenter 属性） memdump() （celery.app.control.Inspect 方法） memdump()（在 celery.utils.debug 模块中） memoize()（在 celery.utils 模块中） memoize()（在 celery.utils.functional 模块中） memsample() （celery.app.control.Inspect 方法） merge() （celery.worker.state.Persistent 方法） merge_inplace() （celery.beat.Scheduler 方法） merge_rules（celery.events.state.State.Task 属性） merge_rules（celery.events.state.Task 属性） Message() （celery.backends.rpc.RPCBackend.Exchange 方法） Messagebuffer.Empty Messagebuffer（celery.utils.collections 中的类） message（celery.exceptions.Retry 属性） message（celery.worker.request.Request 属性） meta（celery.worker.control.Panel 属性） mget() （celery.backends.arangodb.ArangoDbBackend 方法） mget() （celery.backends.cache.CacheBackend 方法） mget() （celery.backends.consul.ConsulBackend 方法） mget() （celery.backends.cosmosdbsql.CosmosDBSQLBackend 方法） mget() （celery.backends.couchbase.CouchbaseBackend 方法） mget() （celery.backends.couchdb.CouchBackend 方法） mget() （celery.backends.dynamodb.DynamoDBBackend 方法） mget() （celery.backends.elasticsearch.ElasticsearchBackend 方法） mget() （celery.backends.filesystem.FilesystemBackend 方法） mget() （celery.backends.redis.RedisBackend 方法） migrate_task()（在 celery.contrib.migrate 模块中） migrate_tasks()（在 celery.contrib.migrate 模块中） Mingle（celery.worker.consumer 中的类） Mingle（celery.worker.consumer.mingle 中的类） minute（celery.schedules.crontab 属性） missing_results() （celery.contrib.testing.manager.ManagerMixin 方法） mlazy（celery.utils.functional 中的类） mlevel()（在 celery.utils.log 模块中） mode（celery.utils.log.LoggingProxy 属性） module celery celery._state celery.app celery.app.amqp celery.app.annotations celery.app.autoretry celery.app.backends celery.app.builtins celery.app.control celery.app.defaults celery.app.events celery.app.log celery.app.registry celery.app.routes celery.app.task celery.app.trace celery.app.utils celery.apps.beat celery.apps.multi celery.apps.worker celery.backends celery.backends.arangodb celery.backends.asynchronous celery.backends.base celery.backends.cache celery.backends.cassandra celery.backends.consul celery.backends.cosmosdbsql celery.backends.couchbase celery.backends.couchdb celery.backends.database celery.backends.database.models celery.backends.database.session celery.backends.dynamodb celery.backends.elasticsearch celery.backends.filesystem celery.backends.gcs celery.backends.mongodb celery.backends.redis celery.backends.rpc celery.backends.s3 celery.beat celery.bin.amqp celery.bin.base celery.bin.beat celery.bin.call celery.bin.celery celery.bin.control celery.bin.events celery.bin.graph celery.bin.list celery.bin.logtool celery.bin.migrate celery.bin.multi celery.bin.purge celery.bin.result celery.bin.shell celery.bin.upgrade celery.bin.worker celery.bootsteps celery.concurrency celery.concurrency.base celery.concurrency.eventlet celery.concurrency.gevent celery.concurrency.prefork celery.concurrency.solo celery.concurrency.thread celery.contrib.abortable celery.contrib.django.task celery.contrib.migrate celery.contrib.pytest celery.contrib.rdb celery.contrib.sphinx celery.contrib.testing.app celery.contrib.testing.manager celery.contrib.testing.mocks celery.contrib.testing.worker celery.events celery.events.cursesmon celery.events.dispatcher celery.events.dumper celery.events.event celery.events.receiver 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.utils celery.utils.abstract celery.utils.collections celery.utils.debug celery.utils.deprecated celery.utils.dispatch celery.utils.dispatch.signal celery.utils.functional celery.utils.graph celery.utils.imports celery.utils.iso8601 celery.utils.log celery.utils.nodenames celery.utils.objects celery.utils.saferepr celery.utils.serialization celery.utils.sysinfo celery.utils.term celery.utils.text celery.utils.threads celery.utils.time celery.utils.timer2 celery.worker celery.worker.autoscale celery.worker.components celery.worker.consumer celery.worker.consumer.agent celery.worker.consumer.connection celery.worker.consumer.consumer celery.worker.consumer.control celery.worker.consumer.events celery.worker.consumer.gossip celery.worker.consumer.heart celery.worker.consumer.mingle celery.worker.consumer.tasks celery.worker.control celery.worker.heartbeat celery.worker.loops celery.worker.pidbox celery.worker.request celery.worker.state celery.worker.strategy celery.worker.worker

module_file()（在 celery.utils.imports 模块中） mongo_host（celery.backends.mongodb.MongoBackend 属性） MongoBackend（celery.backends.mongodb 中的类） mongodb_backend_settings setting month_of_year（celery.schedules.crontab 属性） move()（在 celery.contrib.migrate 模块中） move_by_idmap()（在 celery.contrib.migrate 模块中） move_by_taskmap()（在 celery.contrib.migrate 模块中） move_direct()（在 celery.contrib.migrate 模块中） move_direct_by_id()（在 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 模块中） MSG celery-amqp-basic.publish命令行选项 multi_call() （celery.app.control.Control.Mailbox 方法） MultiTool.MultiParser.Node（celery.bin.multi 中的类） MultiTool.MultiParser（celery.bin.multi 中的类） MultiTool（celery.bin.multi 中的类）

N

NAME celery-call命令行选项 names() （celery.bin.multi.MultiTool 方法） namespace（celery.app.control.Control.Mailbox 属性） name（celery.app.task.Task 属性） name（celery.backends.database.models.TaskExtended 属性） name（celery.backends.rpc.RPCBackend.Exchange 属性）, [1] name（celery.beat.ScheduleEntry 属性） name（celery.bin.base.CommaSeparatedList 属性） name（celery.bin.base.ISO8601DateTime 属性） name（celery.bin.base.ISO8601DateTimeOrFloat 属性） name（celery.bin.base.JsonArray 属性） name（celery.bin.base.JsonObject 属性） name（celery.bin.worker.Autoscale 属性） name（celery.bin.worker.CeleryBeat 属性） name（celery.bin.worker.Hostname 属性） name（celery.bin.worker.WorkersPool 属性） name（celery.bootsteps.Blueprint 属性） name（celery.bootsteps.ConsumerStep 属性） name（celery.bootsteps.StartStopStep 属性） name（celery.bootsteps.Step 属性） name（celery.events.state.State.Task 属性） name（celery.events.state.Task 属性） name（celery.result.AsyncResult 属性） name（celery.utils.abstract.CallableSignature 属性） name（celery.utils.log.LoggingProxy 属性） name（celery.worker.autoscale.WorkerComponent 属性） name（celery.worker.components.Beat 属性） name（celery.worker.components.Consumer 属性） name（celery.worker.components.Hub 属性） name（celery.worker.components.Pool 属性） name（celery.worker.components.StateDB 属性） name（celery.worker.components.Timer 属性） name（celery.worker.consumer.Agent 属性） name（celery.worker.consumer.agent.Agent 属性） name（celery.worker.consumer.Connection 属性） name（celery.worker.consumer.connection.Connection 属性） name（celery.worker.consumer.Consumer.Blueprint 属性） name（celery.worker.consumer.consumer.Consumer.Blueprint 属性） name（celery.worker.consumer.consumer.Evloop 属性） name（celery.worker.consumer.Control 属性） name（celery.worker.consumer.control.Control 属性） name（celery.worker.consumer.Events 属性） name（celery.worker.consumer.events.Events 属性） name（celery.worker.consumer.Gossip 属性）

name（celery.worker.consumer.gossip.Gossip 属性） name（celery.worker.consumer.Heart 属性） name（celery.worker.consumer.heart.Heart 属性） name（celery.worker.consumer.Mingle 属性） name（celery.worker.consumer.mingle.Mingle 属性） name（celery.worker.consumer.Tasks 属性） name（celery.worker.consumer.tasks.Tasks 属性） name（celery.worker.request.Request 属性） name（celery.worker.WorkController.Blueprint 属性） name（celery.worker.worker.WorkController.Blueprint 属性） name（Task 属性） nap() （celery.events.cursesmon.CursesMonitor 方法） new_missing() （celery.app.amqp.Queues 方法） next() （celery.beat.ScheduleEntry 方法） next() （celery.concurrency.base.BasePool.Timer 方法） next() （celery.utils.timer2.Timer 方法） NO_ACK celery-amqp-basic.get命令行选项 no_ack（celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 属性） no_color() （celery.utils.term.colored 方法） no_declare（celery.backends.rpc.RPCBackend.Exchange 属性） Node() （celery.app.control.Control.Mailbox 方法） node() （celery.utils.graph.GraphFormatter 方法） node() （celery.utils.term.colored 方法） node_cls（celery.app.control.Control.Mailbox 属性） node_format()（在 celery.utils.nodenames 模块中） node_scheme（celery.utils.graph.GraphFormatter 属性） nodename()（在 celery.utils 模块中） nodename()（在 celery.utils.nodenames 模块中） nodesplit()（在 celery.utils 模块中） nodesplit()（在 celery.utils.nodenames 模块中） Node（celery.apps.multi 中的类） NODE（celery.utils.graph.DOT 属性） noop()（在 celery.utils 模块中） noop()（在 celery.utils.functional 模块中） NOSE_VERBOSE NotAPackage NotConfigured NotRegistered now() （celery.Celery 方法） now() （celery.loaders.base.BaseLoader 方法） nowfun（celery.schedules.crontab 属性） nullipotent num_processes（celery.concurrency.base.BasePool 属性） num_processes（celery.concurrency.gevent.TaskPool 属性） num_processes（celery.concurrency.prefork.TaskPool 属性）

O

objgraph() （celery.app.control.Inspect 方法） objtype（celery.contrib.sphinx.TaskDocumenter 属性） obj（celery.bootsteps.StartStopStep 属性） obj（celery.utils.collections.DictAttribute 属性） oid（celery.app.control.Control.Mailbox 属性） oid（celery.backends.rpc.RPCBackend 属性） oid（celery.Celery 属性） OK（celery.bin.base.CLIContext 属性） OK（celery.bin.multi.MultiTool 属性） old（celery.app.defaults.Option 属性） on_accepted() （celery.worker.request.Request 方法） on_ack（celery.worker.request.Request 属性） on_after_fork() （celery.backends.asynchronous.BaseResultConsumer 方法） on_after_fork() （celery.backends.redis.RedisBackend.ResultConsumer 方法） on_after_fork() （celery.backends.rpc.RPCBackend.ResultConsumer 方法） on_after_init() （celery.apps.worker.Worker 方法） on_after_init() （celery.worker.WorkController 方法） on_after_init() （celery.worker.worker.WorkController 方法） on_apply() （celery.concurrency.base.BasePool 方法） on_apply() （celery.concurrency.eventlet.TaskPool 方法） on_apply() （celery.concurrency.gevent.TaskPool 方法） on_apply() （celery.concurrency.thread.TaskPool 方法） on_before_init() （celery.apps.worker.Worker 方法） on_before_init() （celery.worker.WorkController 方法） on_before_init() （celery.worker.worker.WorkController 方法） on_bound()（celery.app.task.Task 类方法） on_child_failure() （celery.bin.multi.MultiTool 方法） on_child_signalled() （celery.bin.multi.MultiTool 方法） on_child_spawn() （celery.bin.multi.MultiTool 方法） on_chord_part_return() （celery.backends.gcs.GCSBackend 方法） on_chord_part_return() （celery.backends.redis.RedisBackend 方法） on_cleanup() （celery.events.snapshot.Polaroid 方法） on_clock_event() （celery.worker.consumer.Mingle 方法） on_clock_event() （celery.worker.consumer.mingle.Mingle 方法） on_close() （celery.concurrency.base.BasePool 方法） on_close() （celery.concurrency.prefork.TaskPool 方法） on_close() （celery.worker.consumer.Consumer 方法） on_close() （celery.worker.consumer.consumer.Consumer 方法） on_close() （celery.worker.WorkController 方法） on_close() （celery.worker.worker.WorkController 方法） on_connection_error() （celery.backends.redis.RedisBackend 方法） on_connection_error_after_connected() （celery.worker.consumer.Consumer 方法） on_connection_error_after_connected() （celery.worker.consumer.consumer.Consumer 方法） on_connection_error_before_connected() （celery.worker.consumer.Consumer 方法） on_connection_error_before_connected() （celery.worker.consumer.consumer.Consumer 方法） on_consume_ready() （celery.events.EventReceiver 方法） on_consume_ready() （celery.events.receiver.EventReceiver 方法） on_consumer_ready() （celery.apps.worker.Worker 方法） on_consumer_ready() （celery.contrib.testing.worker.TestWorkController 方法） on_consumer_ready() （celery.worker.WorkController 方法） on_consumer_ready() （celery.worker.worker.WorkController 方法） on_crash() （celery.utils.threads.bgThread 方法） on_decode_error() （celery.worker.consumer.Consumer 方法） on_decode_error() （celery.worker.consumer.consumer.Consumer 方法） on_decode_error（celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 属性） on_disabled（celery.events.dispatcher.EventDispatcher 属性） on_disabled（celery.events.EventDispatcher 属性） on_elect() （celery.worker.consumer.Gossip 方法） on_elect() （celery.worker.consumer.gossip.Gossip 方法） on_elect_ack() （celery.worker.consumer.Gossip 方法） on_elect_ack() （celery.worker.consumer.gossip.Gossip 方法） on_enabled（celery.events.dispatcher.EventDispatcher 属性） on_enabled（celery.events.EventDispatcher 属性） on_event() （celery.events.dumper.Dumper 方法） on_failure() on_failure() （celery.app.task.Task 方法） on_failure() （celery.worker.request.Request 方法） on_hard_timeout() （celery.concurrency.base.BasePool 方法） on_init() （celery.Celery 方法） on_init_blueprint() （celery.apps.worker.Worker 方法） on_init_blueprint() （celery.worker.WorkController 方法） on_init_blueprint() （celery.worker.worker.WorkController 方法） on_invalid_task() （celery.worker.consumer.Consumer 方法） on_invalid_task() （celery.worker.consumer.consumer.Consumer 方法） on_message() （celery.worker.consumer.Gossip 方法） on_message() （celery.worker.consumer.gossip.Gossip 方法） on_message() （celery.worker.pidbox.Pidbox 方法） on_message（celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 属性） on_node_down() （celery.bin.multi.MultiTool 方法） on_node_join() （celery.worker.consumer.Gossip 方法） on_node_join() （celery.worker.consumer.gossip.Gossip 方法） on_node_leave() （celery.worker.consumer.Gossip 方法） on_node_leave() （celery.worker.consumer.gossip.Gossip 方法） on_node_lost() （celery.worker.consumer.Gossip 方法） on_node_lost() （celery.worker.consumer.gossip.Gossip 方法） on_node_reply() （celery.worker.consumer.Mingle 方法）

on_node_reply() （celery.worker.consumer.mingle.Mingle 方法） on_node_restart() （celery.bin.multi.MultiTool 方法） on_node_shutdown_ok() （celery.bin.multi.MultiTool 方法） on_node_signal() （celery.bin.multi.MultiTool 方法） on_node_signal_dead() （celery.bin.multi.MultiTool 方法） on_node_start() （celery.bin.multi.MultiTool 方法） on_node_status() （celery.bin.multi.MultiTool 方法） on_out_of_band_result() （celery.backends.asynchronous.BaseResultConsumer 方法） on_out_of_band_result() （celery.backends.rpc.RPCBackend 方法） on_process_cleanup() （celery.loaders.base.BaseLoader 方法） on_ready() （celery.worker.consumer.Consumer 方法） on_ready() （celery.worker.consumer.consumer.Consumer 方法） on_reject（celery.worker.request.Request 属性） on_replace() （celery.app.task.Task 方法） on_reply_declare() （celery.backends.rpc.RPCBackend 方法） on_result_fulfilled() （celery.backends.asynchronous.AsyncBackendMixin 方法） on_result_fulfilled() （celery.backends.rpc.RPCBackend 方法） on_retry() on_retry() （celery.app.task.Task 方法） on_retry() （celery.worker.request.Request 方法） on_return（celery.backends.rpc.RPCBackend.Producer 属性） on_revoked_received() （celery.worker.consumer.Mingle 方法） on_revoked_received() （celery.worker.consumer.mingle.Mingle 方法） on_send_event_buffered() （celery.worker.consumer.Consumer 方法） on_send_event_buffered() （celery.worker.consumer.consumer.Consumer 方法） on_send_signal() （celery.bin.multi.MultiTool 方法） on_shutter() （celery.events.snapshot.Polaroid 方法） on_soft_timeout() （celery.concurrency.base.BasePool 方法） on_start() （celery.apps.worker.Worker 方法） on_start() （celery.concurrency.base.BasePool 方法） on_start() （celery.concurrency.eventlet.TaskPool 方法） on_start() （celery.concurrency.gevent.TaskPool 方法） on_start() （celery.concurrency.prefork.TaskPool 方法） on_start() （celery.worker.WorkController 方法） on_start() （celery.worker.worker.WorkController 方法） on_state_change() （celery.backends.asynchronous.BaseResultConsumer 方法） on_state_change() （celery.backends.redis.RedisBackend.ResultConsumer 方法） on_still_waiting_end() （celery.bin.multi.MultiTool 方法） on_still_waiting_for() （celery.bin.multi.MultiTool 方法） on_still_waiting_progress() （celery.bin.multi.MultiTool 方法） on_stop() （celery.concurrency.base.BasePool 方法） on_stop() （celery.concurrency.eventlet.TaskPool 方法） on_stop() （celery.concurrency.gevent.TaskPool 方法） on_stop() （celery.concurrency.prefork.TaskPool 方法） on_stop() （celery.concurrency.thread.TaskPool 方法） on_stop() （celery.worker.pidbox.gPidbox 方法） on_stop() （celery.worker.pidbox.Pidbox 方法） on_stopped() （celery.worker.WorkController 方法） on_stopped() （celery.worker.worker.WorkController 方法） on_stopping_preamble() （celery.bin.multi.MultiTool 方法） on_success() on_success() （celery.app.task.Task 方法） on_success() （celery.worker.request.Request 方法） on_task_call() （celery.backends.redis.RedisBackend 方法） on_task_call() （celery.backends.rpc.RPCBackend 方法） on_task_init() （celery.loaders.base.BaseLoader 方法） on_terminate() （celery.concurrency.base.BasePool 方法） on_terminate() （celery.concurrency.prefork.TaskPool 方法） on_tick（celery.concurrency.base.BasePool.Timer 属性） on_tick（celery.utils.timer2.Timer 属性） on_timeout() （celery.worker.request.Request 方法） on_timer_error() （celery.worker.components.Timer 方法） on_timer_tick() （celery.worker.components.Timer 方法） on_unknown_message() （celery.worker.consumer.Consumer 方法） on_unknown_message() （celery.worker.consumer.consumer.Consumer 方法） on_unknown_task() （celery.worker.consumer.Consumer 方法） on_unknown_task() （celery.worker.consumer.consumer.Consumer 方法） on_wait_for_pending() （celery.backends.asynchronous.BaseResultConsumer 方法） on_wait_for_pending() （celery.backends.redis.RedisBackend.ResultConsumer 方法） on_worker_init() （celery.loaders.base.BaseLoader 方法） on_worker_process_init() （celery.loaders.base.BaseLoader 方法） on_worker_shutdown() （celery.loaders.base.BaseLoader 方法） online_str（celery.events.cursesmon.CursesMonitor 属性） open() （celery.platforms.DaemonContext 方法） open() （celery.worker.state.Persistent 方法） OperationalError OptionParser（celery.bin.multi.MultiTool 属性） options（celery.backends.mongodb.MongoBackend 属性） options（celery.beat.ScheduleEntry 属性） options（celery.utils.abstract.CallableSignature 属性） Option（celery.app.defaults 中的类） OrderedDict（celery.utils.collections 中的类） origin（celery.events.state.State.Task 属性） origin（celery.events.state.Task 属性） override_backends setting override_backends（celery.loaders.base.BaseLoader 属性）

P

padlist()（在 celery.utils.functional 模块中） Panel（celery.worker.control 中的类） parent_id（celery.events.state.State.Task 属性） parent_id（celery.events.state.Task 属性） parent_id（celery.worker.request.Request 属性） parent（celery.events.state.State.Task 属性） parent（celery.events.state.Task 属性） parent（celery.result.ResultBase 属性） parse() （celery.bin.multi.MultiTool.MultiParser 方法） parse() （celery.schedules.crontab_parser 方法） parse_gid()（在 celery.platforms 模块中） parse_iso8601()（在 celery.utils.iso8601 模块中） parse_uid()（在 celery.platforms 模块中） ParseException PASSIVE celery-amqp-exchange.declare命令行选项 celery-amqp-queue.declare命令行选项 passive（celery.backends.rpc.RPCBackend.Exchange 属性） password（celery.backends.arangodb.ArangoDbBackend 属性） password（celery.backends.couchbase.CouchbaseBackend 属性） password（celery.backends.couchdb.CouchBackend 属性） password（celery.backends.elasticsearch.ElasticsearchBackend 属性） password（celery.backends.mongodb.MongoBackend 属性） patch_all() （celery.worker.consumer.consumer.Evloop 方法） path（celery.backends.consul.ConsulBackend 属性） path（celery.platforms.Pidfile 属性） PENDING state PENDING()（在 celery.states 模块中） perform_pending_operations() （celery.worker.consumer.Consumer 方法） perform_pending_operations() （celery.worker.consumer.consumer.Consumer 方法） periodic() （celery.app.registry.TaskRegistry 方法） periodic() （celery.worker.consumer.Gossip 方法） periodic() （celery.worker.consumer.gossip.Gossip 方法） persistence（celery.beat.PersistentScheduler 属性） PERSISTENT_DELIVERY_MODE（celery.backends.rpc.RPCBackend.Exchange 属性） PersistentScheduler（celery.beat 中的类） persistent（celery.backends.rpc.RPCBackend 属性） Persistent（celery.worker.state 中的类） pidbox Pidbox（celery.worker.pidbox 中的类） pidfile（celery.apps.multi.Node 属性） pidfile（celery.bin.multi.MultiTool.MultiParser.Node 属性） Pidfile（celery.platforms 中的类） pidlock（celery.worker.WorkController 属性） pidlock（celery.worker.worker.WorkController 属性） pid（celery.apps.multi.Node 属性） pid（celery.bin.multi.MultiTool.MultiParser.Node 属性） pid（celery.events.state.State.Worker 属性） pid（celery.events.state.Worker 属性） ping control ping() （celery.app.control.Control 方法） ping() （celery.app.control.Inspect 方法） pluralize()（在 celery.utils.text 模块中） Polaroid（celery.events.snapshot 中的类） poll() （celery.backends.rpc.RPCBackend 方法） pool, [1] pool_grow() （celery.app.control.Control 方法） pool_restart() （celery.app.control.Control 方法） pool_shrink() （celery.app.control.Control 方法） pool（celery.Celery 属性） Pool（celery.concurrency.prefork.TaskPool 属性） Pool（celery.worker.components 中的类） pool（celery.worker.consumer.Consumer 属性） pool（celery.worker.consumer.consumer.Consumer 属性） pool（celery.worker.WorkController 属性）

pool（celery.worker.worker.WorkController 属性） pop() （celery.utils.collections.ChainMap 方法） pop() （celery.utils.collections.LimitedSet 方法） pop_value() （celery.utils.collections.LimitedSet 方法） popitem() （celery.utils.functional.LRUCache 方法） populate_heap() （celery.beat.Scheduler 方法） port（celery.backends.arangodb.ArangoDbBackend 属性） port（celery.backends.couchbase.CouchbaseBackend 属性） port（celery.backends.couchdb.CouchBackend 属性） port（celery.backends.elasticsearch.ElasticsearchBackend 属性） port（celery.backends.mongodb.MongoBackend 属性） precedence()（在 celery.states 模块中） prefetch count prefetch multiplier prefetch_count（celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 属性） prepare() （celery.contrib.testing.worker.TestWorkController.QueueHandler 方法） prepare()（在 celery.app.annotations 模块中） prepare()（在 celery.app.routes 模块中） prepare_args() （celery.worker.WorkController 方法） prepare_args() （celery.worker.worker.WorkController 方法） prepare_argv() （celery.apps.multi.Node 方法） prepare_argv() （celery.bin.multi.MultiTool.MultiParser.Node 方法） prepare_config() （celery.Celery 方法） prepare_models() （celery.backends.database.session.SessionManager 方法） pretty() （celery.bin.base.CLIContext 方法） pretty()（在 celery.utils.text 模块中） pretty_dict_ok_error() （celery.bin.base.CLIContext 方法） pretty_list() （celery.bin.base.CLIContext 方法） priority（celery.app.task.Task 属性） PrivateKey（celery.security.key 中的类） process() （celery.events.EventReceiver 方法） process() （celery.events.receiver.EventReceiver 方法） process_destructor()（在 celery.concurrency.prefork 模块中） process_initializer()（在 celery.concurrency.prefork 模块中） processed（celery.events.state.State.Worker 属性） processed（celery.events.state.Worker 属性） processes（celery.worker.autoscale.Autoscaler 属性） producer_or_acquire() （celery.app.control.Control.Mailbox 方法） producer_or_acquire() （celery.Celery 方法） producer_pool（celery.app.amqp.AMQP 属性） producer_pool（celery.app.control.Control.Mailbox 属性） producer_pool（celery.Celery 属性） Producer（celery.app.amqp.AMQP 属性） producer（celery.beat.Scheduler 属性） PROPAGATE_STATES state Property()（在 celery.utils.deprecated 模块中） protocol（celery.worker.state.Persistent 属性） ps()（在 celery.utils.debug 模块中） publish() （celery.backends.rpc.RPCBackend.Exchange 方法） publish() （celery.backends.rpc.RPCBackend.Producer 方法） publish() （celery.events.dispatcher.EventDispatcher 方法） publish() （celery.events.EventDispatcher 方法） publisher（celery.events.dispatcher.EventDispatcher 属性） publisher（celery.events.EventDispatcher 属性） purge() （celery.app.control.Control 方法） purge() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） purge() （celery.utils.collections.LimitedSet 方法） purge_messages() （celery.apps.worker.Worker 方法） put() （celery.utils.collections.BufferMap 方法） put() （celery.utils.collections.Messagebuffer 方法） pydantic_context（Task 属性） pydantic_dump_kwargs（Task 属性） pydantic_strict（Task 属性） pyimplementation()（在 celery.platforms 模块中） pytest_configure()（在 celery.contrib.pytest 模块中） Python 增强建议；PEP 257, [1] Python 增强建议；PEP 8, [1], [2], [3], [4], [5]

Q

qos qos() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） qos_global() （celery.worker.consumer.Tasks 方法） qos_global() （celery.worker.consumer.tasks.Tasks 方法） qty（celery.worker.autoscale.Autoscaler 属性） qualname()（在 celery.utils.imports 模块中） query_router() （celery.app.routes.Router 方法） query_task() （celery.app.control.Inspect 方法） query_task_states() （celery.contrib.testing.manager.ManagerMixin 方法） query_tasks() （celery.contrib.testing.manager.ManagerMixin 方法） QUEUE celery-amqp-basic.get命令行选项 celery-amqp-queue.bind命令行选项 celery-amqp-queue.declare命令行选项 celery-amqp-queue.delete命令行选项 celery-amqp-queue.purge命令行选项

QueueNotFound Queues() （celery.app.amqp.AMQP 方法） Queues（celery.app.amqp 中的类） queues（celery.app.amqp.AMQP 属性） queues（celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 属性） queue（celery.backends.database.models.TaskExtended 属性） queue（celery.concurrency.base.BasePool.Timer 属性） queue（celery.concurrency.eventlet.TaskPool.Timer 属性） queue（celery.concurrency.gevent.TaskPool.Timer 属性） queue（celery.result.AsyncResult 属性） queue（celery.utils.timer2.Timer 属性） quiet（celery.backends.couchbase.CouchbaseBackend 属性）

R

rate()（在 celery.utils.time 模块中） rate_limit control rate_limit() （celery.app.control.Control 方法） rate_limit（celery.app.task.Task 属性） rate_limit（Task 属性） Rdb（celery.contrib.rdb 中的类） read_capacity_units（celery.backends.dynamodb.DynamoDBBackend 属性） read_configuration() （celery.loaders.base.BaseLoader 方法） read_configuration() （celery.loaders.default.Loader 方法） read_pid() （celery.platforms.Pidfile 方法） readline() （celery.events.cursesmon.CursesMonitor 方法） ready() （celery.result.AsyncResult 方法） ready() （celery.result.EagerResult 方法） ready() （celery.result.ResultSet 方法） READY_STATES state ready（celery.events.state.State.Task 属性） ready（celery.events.state.Task 属性） rebuild_taskheap() （celery.events.state.State 方法） receive() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） RECEIVED()（在 celery.states 模块中） received（celery.events.state.State.Task 属性） received（celery.events.state.Task 属性） receiver_cls（celery.app.events.Events 属性） receivers（celery.utils.dispatch.Signal 属性） receivers（celery.utils.dispatch.signal.Signal 属性） Receiver（celery.app.events.Events 属性） reconnect_on_error() （celery.backends.redis.RedisBackend.ResultConsumer 方法） recover() （celery.backends.rpc.RPCBackend.ResultConsumer.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_backend_health_check_interval setting redis_backend_use_ssl setting redis_max_connections setting redis_retry_on_timeout setting redis_socket_connect_timeout setting redis_socket_keepalive setting redis_socket_timeout setting RedisBackend.ResultConsumer（celery.backends.redis 中的类） RedisBackend（celery.backends.redis 中的类） redis（celery.backends.redis.RedisBackend 属性） reentrant regen()（在 celery.utils.functional 模块中） register() （celery.app.registry.TaskRegistry 方法） register()（celery.worker.control.Panel 类方法） register_auth()（在 celery.security.serialization 模块中） register_callback() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） register_drainer()（在 celery.backends.asynchronous 模块中） register_timer() （celery.worker.consumer.Gossip 方法） register_timer() （celery.worker.consumer.gossip.Gossip 方法） register_with_event_loop() （celery.concurrency.base.BasePool 方法） register_with_event_loop() （celery.concurrency.prefork.TaskPool 方法） register_with_event_loop() （celery.worker.autoscale.WorkerComponent 方法） register_with_event_loop() （celery.worker.components.Pool 方法） register_with_event_loop() （celery.worker.consumer.Consumer 方法） register_with_event_loop() （celery.worker.consumer.consumer.Consumer 方法） register_with_event_loop() （celery.worker.WorkController 方法） register_with_event_loop() （celery.worker.worker.WorkController 方法） registered() （celery.app.control.Inspect 方法） registered_tasks() （celery.app.control.Inspect 方法） regular() （celery.app.registry.TaskRegistry 方法） Reject reject() （celery.worker.request.Request 方法） reject_on_worker_lost（celery.app.task.Task 属性） rejected（celery.events.state.State.Task 属性） rejected（celery.events.state.Task 属性） relative（celery.schedules.schedule 属性） release() （celery.backends.rpc.RPCBackend.Producer 方法） release() （celery.platforms.Pidfile 方法） reload() （celery.worker.WorkController 方法） reload() （celery.worker.worker.WorkController 方法） reload_from_cwd()（在 celery.utils.imports 模块中） reload_group_result() （celery.backends.rpc.RPCBackend 方法） reload_task_result() （celery.backends.rpc.RPCBackend 方法） remaining()（在 celery.utils.time 模块中） remaining_delta() （celery.schedules.crontab 方法） remaining_estimate() （celery.schedules.crontab 方法） remaining_estimate() （celery.schedules.schedule 方法） remaining_estimate() （celery.schedules.solar 方法） remark() （celery.contrib.testing.manager.ManagerMixin 方法） remove() （celery.platforms.Pidfile 方法） remove() （celery.result.ResultSet 方法） remove() （hub 方法） remove_by（celery.app.defaults.Option 属性） remove_if_stale() （celery.platforms.Pidfile 方法） remove_pending_result() （celery.backends.asynchronous.AsyncBackendMixin 方法） replace() （celery.app.task.Task 方法） replaced_task_nesting（celery.worker.request.Request 属性） reply_exchange_fmt（celery.app.control.Control.Mailbox 属性） reply_exchange（celery.app.control.Control.Mailbox 属性） reply_queue（celery.app.control.Control.Mailbox 属性） reply_to（celery.worker.request.Request 属性） report() （celery.app.control.Inspect 方法） repr_node() （celery.utils.graph.DependencyGraph 方法） reprstream()（在 celery.utils.saferepr 模块中） republish()（在 celery.contrib.migrate 模块中） request request_dict（celery.worker.request.Request 属性） request_stack（celery.app.task.Task 属性） Request（celery.app.task.Task 属性） request（celery.app.task.Task 属性） Request（celery.worker.request 中的类） request（Task 属性） requires（celery.bootsteps.ConsumerStep 属性） requires（celery.bootsteps.Step 属性） requires（celery.worker.autoscale.WorkerComponent 属性） requires（celery.worker.components.Hub 属性） requires（celery.worker.components.Pool 属性） requires（celery.worker.consumer.Agent 属性） requires（celery.worker.consumer.agent.Agent 属性） requires（celery.worker.consumer.Control 属性） requires（celery.worker.consumer.control.Control 属性） requires（celery.worker.consumer.Events 属性） requires（celery.worker.consumer.events.Events 属性） requires（celery.worker.consumer.Gossip 属性） requires（celery.worker.consumer.gossip.Gossip 属性） requires（celery.worker.consumer.Heart 属性） requires（celery.worker.consumer.heart.Heart 属性） requires（celery.worker.consumer.Mingle 属性） requires（celery.worker.consumer.mingle.Mingle 属性） requires（celery.worker.consumer.Tasks 属性） requires（celery.worker.consumer.tasks.Tasks 属性） reraise()（在 celery.exceptions 模块中） reraise_errors()（在 celery.security.utils 模块中） reserve() （celery.beat.Scheduler 方法） reserved() （celery.app.control.Inspect 方法） reserved_options（celery.bin.multi.MultiTool 属性） reserved_requests()（在 celery.worker.state 模块中） reset() （celery.utils.term.colored 方法） reset() （celery.worker.pidbox.gPidbox 方法） reset() （celery.worker.pidbox.Pidbox 方法）

reset_multiprocessing_logger()（在 celery.utils.log 模块中） reset_rate_limits() （celery.worker.consumer.Consumer 方法） reset_rate_limits() （celery.worker.consumer.consumer.Consumer 方法） reset_rate_limits() （consumer 方法） reset_worker_optimizations()（在 celery.app.trace 模块中） resetscreen() （celery.events.cursesmon.CursesMonitor 方法） resolve_all()（在 celery.app.annotations 模块中） restart() （celery.apps.multi.Cluster 方法） restart() （celery.bin.multi.MultiTool 方法） restart() （celery.bootsteps.Blueprint 方法） restart() （celery.concurrency.base.BasePool 方法） restart() （celery.concurrency.prefork.TaskPool 方法） restart_count（celery.worker.consumer.Consumer 属性） restart_count（celery.worker.consumer.consumer.Consumer 属性） restore() （celery.utils.serialization.UnpickleableExceptionWrapper 方法） restore()（celery.result.GroupResult 类方法） restore_group() （celery.backends.rpc.RPCBackend 方法） result_accept_content setting result_backend setting result_backend_always_retry setting result_backend_base_sleep_between_retries_ms setting result_backend_max_retries setting result_backend_max_sleep_between_retries_ms setting result_backend_thread_safe setting result_backend_transport_options setting result_backend（celery.app.utils.Settings 属性） result_cache_max setting result_chord_join_timeout setting result_chord_retry_interval setting result_compression setting result_expires setting result_extended setting result_from_tuple()（在 celery.result 模块中） result_persistent setting result_serializer setting ResultBase（celery.result 中的类） resultrepr_maxsize（celery.app.task.Task 属性） ResultSession() （celery.backends.database.DatabaseBackend 方法） ResultSet（celery.result 中的类） results（celery.result.GroupResult 属性） results（celery.result.ResultSet 属性） result（celery.backends.database.models.Task 属性） result（celery.backends.database.models.TaskExtended 属性） result（celery.backends.database.models.TaskSet 属性） result（celery.events.state.State.Task 属性） result（celery.events.state.Task 属性） result（celery.result.AsyncResult 属性） result（celery.result.EagerResult 属性） retried（celery.events.state.State.Task 属性） retried（celery.events.state.Task 属性） retries（celery.backends.database.models.TaskExtended 属性） retries（celery.events.state.State.Task 属性） retries（celery.events.state.Task 属性） retries（celery.result.AsyncResult 属性） RETRY state Retry retry() （celery.app.task.Task 方法） RETRY()（在 celery.states 模块中） retry_backoff_max（Task 属性） retry_backoff（Task 属性） retry_jitter（Task 属性） retry_over_time() （celery.contrib.testing.manager.ManagerMixin 方法） retry_policy（celery.backends.redis.RedisBackend 属性） retry_policy（celery.backends.rpc.RPCBackend 属性） retval（celery.app.trace.TraceInfo 属性） reverse() （celery.utils.term.colored 方法） revive() （celery.backends.rpc.RPCBackend 方法） revive() （celery.backends.rpc.RPCBackend.Producer 方法） revive() （celery.backends.rpc.RPCBackend.ResultConsumer.Consumer 方法） revoke control revoke() （celery.app.control.Control 方法） revoke() （celery.result.AsyncResult 方法） revoke() （celery.result.EagerResult 方法） revoke() （celery.result.ResultSet 方法） revoke_by_stamped_headers control revoke_by_stamped_headers() （celery.app.control.Control 方法） revoke_by_stamped_headers() （celery.result.AsyncResult 方法） revoke_selection() （celery.events.cursesmon.CursesMonitor 方法） REVOKED state revoked() （celery.app.control.Inspect 方法） revoked() （celery.worker.request.Request 方法） REVOKED()（在 celery.states 模块中） revoked()（在 celery.worker.state 模块中） revoked（celery.events.state.State.Task 属性） revoked（celery.events.state.Task 属性） root_id（celery.events.state.State.Task 属性） root_id（celery.events.state.Task 属性） root_id（celery.worker.request.Request 属性） root（celery.events.state.State.Task 属性） root（celery.events.state.Task 属性） route() （celery.app.routes.Router 方法） Router() （celery.app.amqp.AMQP 方法） router（celery.app.amqp.AMQP 属性） Router（celery.app.routes 中的类） routes（celery.app.amqp.AMQP 属性） ROUTING_KEY celery-amqp-basic.publish命令行选项 celery-amqp-queue.bind命令行选项 routing_key（celery.backends.rpc.RPCBackend.Producer 属性） routing_key（celery.events.state.State.Task 属性） routing_key（celery.events.state.Task 属性） RPCBackend.BacklogLimitExceeded RPCBackend.Consumer（celery.backends.rpc 中的类） RPCBackend.Exchange（celery.backends.rpc 中的类） RPCBackend.Producer（celery.backends.rpc 中的类） RPCBackend.Queue（celery.backends.rpc 中的类） RPCBackend.ResultConsumer.Consumer.ContentDisallowed RPCBackend.ResultConsumer.Consumer（celery.backends.rpc 中的类） RPCBackend.ResultConsumer（celery.backends.rpc 中的类） RPCBackend（celery.backends.rpc 中的类） run() （celery.app.task.Task 方法） run() （celery.apps.beat.Beat 方法） run() （celery.concurrency.base.BasePool.Timer 方法） run() （celery.utils.threads.bgThread 方法） run() （celery.utils.timer2.Timer 方法） running（celery.concurrency.base.BasePool.Timer 属性） running（celery.utils.timer2.Timer 属性） runtime（celery.events.state.State.Task 属性） runtime（celery.events.state.Task 属性） RUN（celery.concurrency.base.BasePool 属性） rusage() （celery.worker.WorkController 方法） rusage() （celery.worker.worker.WorkController 方法）

S

s() （celery.app.task.Task 方法） s3_access_key_id setting s3_base_path setting s3_bucket setting s3_endpoint_url setting s3_region setting s3_secret_access_key setting S3Backend（celery.backends.s3 中的类） safe_add_str() （celery.events.cursesmon.CursesMonitor 方法） saferepr()（在 celery.utils.saferepr 模块中） sample()（在 celery.utils.debug 模块中） sample_mem()（在 celery.utils.debug 模块中） save() （celery.result.GroupResult 方法） save() （celery.worker.state.Persistent 方法） save_group() （celery.backends.rpc.RPCBackend 方法） say() （celery.events.dumper.Dumper 方法） say_chat() （celery.bin.base.CLIContext 方法） scale_down() （celery.worker.autoscale.Autoscaler 方法） scale_up() （celery.worker.autoscale.Autoscaler 方法） Schedule()（在 celery.utils.timer2 模块中） scheduled() （celery.app.control.Inspect 方法） ScheduleEntry（celery.beat 中的类） scheduler_cls（celery.apps.beat.Beat.Service 属性） scheduler_cls（celery.beat.Service 属性） scheduler（celery.apps.beat.Beat.Service 属性） Scheduler（celery.beat 中的类） scheduler（celery.beat.Service 属性） schedules_equal() （celery.beat.Scheduler 方法） schedule（celery.beat.PersistentScheduler 属性） schedule（celery.beat.ScheduleEntry 属性） schedule（celery.beat.Scheduler 属性） Schedule（celery.concurrency.base.BasePool.Timer 属性） schedule（celery.schedules 中的类） Schedule（celery.utils.timer2.Timer 属性） SchedulingError scheme（celery.backends.couchdb.CouchBackend 属性） scheme（celery.backends.elasticsearch.ElasticsearchBackend 属性） scheme（celery.utils.graph.GraphFormatter 属性） screen_delay（celery.events.cursesmon.CursesMonitor 属性） screen_height（celery.events.cursesmon.CursesMonitor 属性） screen_width（celery.events.cursesmon.CursesMonitor 属性） secho() （celery.bin.base.CLIContext 方法） seconds（celery.schedules.schedule 属性） SecureSerializer（celery.security.serialization 中的类） security_cert_store setting security_certificate setting security_digest setting security_key setting security_key_password setting SecurityError SecurityWarning select() （celery.app.amqp.Queues 方法） select_add() （celery.app.amqp.Queues 方法） select_queues() （celery.Celery 方法） 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 属性） semaphore（celery.worker.worker.WorkController 属性） send() （celery.apps.multi.Node 方法） send() （celery.bin.multi.MultiTool.MultiParser.Node 方法） send() （celery.events.dispatcher.EventDispatcher 方法） send() （celery.events.EventDispatcher 方法） send() （celery.utils.dispatch.Signal 方法） send() （celery.utils.dispatch.signal.Signal 方法） send_all() （celery.apps.multi.Cluster 方法） send_all() （celery.bootsteps.Blueprint 方法） send_event() （celery.app.task.Task 方法） send_event() （celery.worker.request.Request 方法） send_events（celery.app.task.Task 属性） send_hello() （celery.worker.consumer.Mingle 方法） send_hello() （celery.worker.consumer.mingle.Mingle 方法） send_robust() （celery.utils.dispatch.Signal 方法） send_robust() （celery.utils.dispatch.signal.Signal 方法） send_task() （celery.beat.Scheduler 方法） send_task() （celery.Celery 方法） send_task_message（celery.app.amqp.AMQP 属性） Sentinel SentinelBackend（celery.backends.redis 中的类） sentinel（celery.backends.redis.SentinelBackend 属性） sent（celery.events.state.State.Task 属性） sent（celery.events.state.Task 属性） serialize() （celery.security.serialization.SecureSerializer 方法） serializer（celery.app.control.Control.Mailbox 属性） serializer（celery.app.task.Task 属性） serializer（celery.backends.rpc.RPCBackend.Producer 属性） serializer（Task 属性） servers（celery.backends.cache.CacheBackend 属性） servers（celery.backends.cassandra.CassandraBackend 属性） server（celery.backends.elasticsearch.ElasticsearchBackend 属性） Service（celery.beat 中的类） session_factory() （celery.backends.database.session.SessionManager 方法） SessionManager（celery.backends.database.session 中的类） set() （celery.backends.arangodb.ArangoDbBackend 方法） set() （celery.backends.cache.CacheBackend 方法） set() （celery.backends.consul.ConsulBackend 方法） set() （celery.backends.cosmosdbsql.CosmosDBSQLBackend 方法） set() （celery.backends.couchbase.CouchbaseBackend 方法） set() （celery.backends.couchdb.CouchBackend 方法） set() （celery.backends.dynamodb.DynamoDBBackend 方法） set() （celery.backends.elasticsearch.ElasticsearchBackend 方法） set() （celery.backends.filesystem.FilesystemBackend 方法） set() （celery.backends.redis.RedisBackend 方法） set() （celery.backends.s3.S3Backend 方法） set() （celery.utils.abstract.CallableSignature 方法） set_chord_size() （celery.backends.redis.RedisBackend 方法） set_current() （celery.Celery 方法） set_default() （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 方法） set_process_title() （celery.apps.beat.Beat 方法） set_process_title()（在 celery.platforms 模块中） set_schedule() （celery.beat.PersistentScheduler 方法） set_schedule() （celery.beat.Scheduler 方法） set_trace()（在 celery.contrib.rdb 模块中） set_trap()（在 celery.contrib.testing.app 模块中） setdefault() （celery.utils.collections.ChainMap 方法） setdefault() （celery.utils.collections.DictAttribute 方法） setgid()（在 celery.platforms 模块中） setgroups()（在 celery.platforms 模块中） setter() （celery.utils.cached_property 方法） setting accept_content arangodb_backend_settings azureblockblob_base_path azureblockblob_connection_timeout azureblockblob_container_name azureblockblob_read_timeout azureblockblob_retry_increment_base azureblockblob_retry_initial_backoff_sec azureblockblob_retry_max_attempts beat_cron_starting_deadline beat_executable beat_gid beat_logfile beat_max_loop_interval beat_pidfile beat_schedule beat_schedule_filename beat_scheduler beat_sync_every beat_uid beat_umask broker_connection_max_retries broker_connection_retry broker_connection_retry_on_startup broker_connection_timeout broker_failover_strategy broker_heartbeat broker_heartbeat_checkrate broker_login_method broker_native_delayed_delivery_queue_type broker_pool_limit broker_read_url broker_transport_options broker_url broker_use_ssl broker_write_url cache_backend cache_backend_options cassandra_auth_kwargs cassandra_auth_provider cassandra_entry_ttl cassandra_keyspace cassandra_options cassandra_port cassandra_read_consistency cassandra_secure_bundle_path cassandra_servers cassandra_table cassandra_write_consistency control_exchange control_queue_expires control_queue_ttl cosmosdbsql_collection_name cosmosdbsql_consistency_level cosmosdbsql_database_name cosmosdbsql_max_retry_attempts cosmosdbsql_max_retry_wait_time couchbase_backend_settings database_create_tables_at_setup database_engine_options database_short_lived_sessions database_table_names database_table_schemas elasticsearch_max_retries elasticsearch_retry_on_timeout elasticsearch_save_meta_as_text elasticsearch_timeout enable_utc event_exchange event_queue_expires event_queue_prefix event_queue_ttl event_serializer events_executable events_gid events_logfile events_pidfile events_uid events_umask gcs_base_path gcs_bucket gcs_project imports include mongodb_backend_settings override_backends redis_backend_health_check_interval redis_backend_use_ssl redis_max_connections redis_retry_on_timeout redis_socket_connect_timeout redis_socket_keepalive redis_socket_timeout result_accept_content result_backend result_backend_always_retry result_backend_base_sleep_between_retries_ms result_backend_max_retries result_backend_max_sleep_between_retries_ms result_backend_thread_safe result_backend_transport_options result_cache_max result_chord_join_timeout result_chord_retry_interval result_compression result_expires result_extended result_persistent result_serializer s3_access_key_id s3_base_path s3_bucket s3_endpoint_url s3_region s3_secret_access_key security_cert_store security_certificate security_digest security_key security_key_password task_acks_late task_acks_on_failure_or_timeout task_allow_error_cb_on_chord_header task_always_eager task_annotations task_compression task_create_missing_queues task_default_delivery_mode task_default_exchange task_default_exchange_type task_default_priority task_default_queue task_default_queue_type task_default_rate_limit task_default_routing_key task_eager_propagates task_ignore_result task_inherit_parent_priority task_protocol task_publish_retry task_publish_retry_policy task_queue_max_priority task_queues task_reject_on_worker_lost task_remote_tracebacks task_routes task_send_sent_event task_serializer task_soft_time_limit task_store_eager_result task_store_errors_even_if_ignored task_time_limit task_track_started timezone worker_autoscaler worker_cancel_long_running_tasks_on_connection_loss worker_concurrency worker_consumer worker_deduplicate_successful_tasks worker_detect_quorum_queues worker_direct worker_disable_rate_limits worker_enable_prefetch_count_reduction worker_enable_remote_control worker_enable_soft_shutdown_on_idle worker_executable worker_gid worker_hijack_root_logger worker_log_color worker_log_format worker_logfile worker_lost_wait worker_max_memory_per_child worker_max_tasks_per_child worker_pidfile worker_pool worker_pool_restarts worker_prefetch_multiplier worker_proc_alive_timeout worker_redirect_stdouts worker_redirect_stdouts_level worker_send_task_events worker_soft_shutdown_timeout worker_state_db worker_task_log_format worker_timer worker_timer_precision worker_uid worker_umask

Settings（celery.app.utils 中的类） setuid()（在 celery.platforms 模块中） setup() （celery.app.log.Logging 方法） setup()（在 celery.contrib.sphinx 模块中） setup_app_for_worker()（在 celery.contrib.testing.worker 模块中） setup_default_app()（在 celery.contrib.testing.app 模块中） setup_defaults() （celery.worker.WorkController 方法） setup_defaults() （celery.worker.worker.WorkController 方法） setup_handlers() （celery.app.log.Logging 方法） setup_includes() （celery.worker.WorkController 方法） setup_includes() （celery.worker.worker.WorkController 方法） setup_instance() （celery.worker.WorkController 方法） setup_instance() （celery.worker.worker.WorkController 方法） setup_logging signal setup_logging() （celery.apps.beat.Beat 方法） setup_logging() （celery.apps.worker.Worker 方法） setup_logging_subsystem() （celery.app.log.Logging 方法） setup_queues() （celery.worker.WorkController 方法） setup_queues() （celery.worker.worker.WorkController 方法） setup_schedule() （celery.beat.PersistentScheduler 方法） setup_schedule() （celery.beat.Scheduler 方法） setup_security() （celery.Celery 方法） setup_security()（在 celery.security 模块中） setup_settings() （celery.loaders.default.Loader 方法） setup_task_loggers() （celery.app.log.Logging 方法） setup_worker_optimizations()（在 celery.app.trace 模块中） shadow_name() （celery.app.task.Task 方法） should_sync() （celery.beat.Scheduler 方法） should_use_eventloop() （celery.worker.WorkController 方法） should_use_eventloop() （celery.worker.worker.WorkController 方法） show() （celery.bin.multi.MultiTool 方法） shrink() （celery.concurrency.eventlet.TaskPool 方法） shrink() （celery.concurrency.gevent.TaskPool 方法） shutdown control shutdown() （celery.app.control.Control 方法） shutdown() （celery.bootsteps.ConsumerStep 方法） shutdown() （celery.worker.consumer.Connection 方法） shutdown() （celery.worker.consumer.connection.Connection 方法） shutdown() （celery.worker.consumer.Consumer 方法） shutdown() （celery.worker.consumer.Consumer.Blueprint 方法） shutdown() （celery.worker.consumer.consumer.Consumer 方法） shutdown() （celery.worker.consumer.consumer.Consumer.Blueprint 方法） shutdown() （celery.worker.consumer.Events 方法） shutdown() （celery.worker.consumer.events.Events 方法） shutdown() （celery.worker.consumer.Heart 方法） shutdown() （celery.worker.consumer.heart.Heart 方法） shutdown() （celery.worker.consumer.Tasks 方法） shutdown() （celery.worker.consumer.tasks.Tasks 方法） shutdown() （celery.worker.pidbox.Pidbox 方法） shutdown_nodes() （celery.apps.multi.Cluster 方法） 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 heartbeat_sent import_modules setup_logging task_failure task_internal_error task_postrun task_prerun task_received task_rejected task_retry task_revoked task_sent task_success task_unknown user_preload_options worker_before_create_process worker_init worker_process_init worker_process_shutdown worker_ready worker_shutdown worker_shutting_down signal_consumer_close() （celery.worker.WorkController 方法） signal_consumer_close() （celery.worker.worker.WorkController 方法） signal_name()（在 celery.platforms 模块中） signal_safe（celery.concurrency.base.BasePool 属性） signal_safe（celery.concurrency.eventlet.TaskPool 属性） signal_safe（celery.concurrency.gevent.TaskPool 属性） signal_safe（celery.concurrency.thread.TaskPool 属性） Signal（celery.utils.dispatch 中的类） Signal（celery.utils.dispatch.signal 中的类） signature() （celery.app.task.Task 方法） signature() （celery.Celery 方法） signature()（在 celery 模块中） Signature（celery 中的类） simple_format()（在 celery.utils.text 模块中） soft_time_limit（celery.app.task.Task 属性） soft_time_limit（Task 属性） SoftTimeLimitExceeded SOFTWARE_INFO()（在 celery.worker.state 模块中） solar（celery.schedules 中的类） SOURCE celery-migrate命令行选项 stamped_headers（celery.worker.request.Request 属性） stamps（celery.worker.request.Request 属性） starmap() （celery.app.task.Task 方法） start() （celery.apps.beat.Beat.Service 方法） start() （celery.apps.multi.Cluster 方法） start() （celery.apps.multi.Node 方法） start() （celery.backends.asynchronous.BaseResultConsumer 方法） start() （celery.backends.asynchronous.Drainer 方法） start() （celery.backends.redis.RedisBackend.ResultConsumer 方法） start() （celery.backends.rpc.RPCBackend.ResultConsumer 方法） start() （celery.beat.Service 方法） start() （celery.bin.multi.MultiTool 方法） start() （celery.bin.multi.MultiTool.MultiParser.Node 方法） start() （celery.bootsteps.Blueprint 方法） start() （celery.bootsteps.ConsumerStep 方法） start() （celery.bootsteps.StartStopStep 方法） start() （celery.concurrency.base.BasePool 方法） start() （celery.contrib.testing.worker.TestWorkController 方法） start() （celery.worker.components.Hub 方法） start() （celery.worker.consumer.Connection 方法） start() （celery.worker.consumer.connection.Connection 方法） start() （celery.worker.consumer.Consumer 方法） start() （celery.worker.consumer.consumer.Consumer 方法） start() （celery.worker.consumer.consumer.Evloop 方法） start() （celery.worker.consumer.Events 方法） start() （celery.worker.consumer.events.Events 方法） start() （celery.worker.consumer.Gossip 方法） start() （celery.worker.consumer.gossip.Gossip 方法） start() （celery.worker.consumer.Heart 方法） start() （celery.worker.consumer.heart.Heart 方法） start() （celery.worker.consumer.Mingle 方法） start() （celery.worker.consumer.mingle.Mingle 方法） start() （celery.worker.consumer.Tasks 方法） start() （celery.worker.consumer.tasks.Tasks 方法） start() （celery.worker.heartbeat.Heart 方法） start() （celery.worker.pidbox.gPidbox 方法） start() （celery.worker.pidbox.Pidbox 方法） start() （celery.worker.WorkController 方法） start() （celery.worker.worker.WorkController 方法） start_filter()（在 celery.contrib.migrate 模块中） start_node() （celery.apps.multi.Cluster 方法） start_scheduler() （celery.apps.beat.Beat 方法） start_worker()（在 celery.contrib.testing.worker 模块中） STARTED state STARTED()（在 celery.states 模块中） started（celery.bootsteps.Blueprint 属性） started（celery.events.state.State.Task 属性） started（celery.events.state.Task 属性） StartStopStep（celery.bootsteps 中的类） startup_info() （celery.apps.beat.Beat 方法） startup_info() （celery.apps.worker.Worker 方法） state ALL_STATES EXCEPTION_STATES FAILURE PENDING PROPAGATE_STATES READY_STATES RETRY REVOKED STARTED SUCCESS UNREADY_STATES State.Task（celery.events.state 中的类） State.Worker（celery.events.state 中的类） state_cls（celery.app.events.Events 属性） state_to_name（celery.bootsteps.Blueprint 属性） statedb StateDB（celery.worker.components 中的类） State（celery.app.events.Events 属性） state（celery.app.trace.TraceInfo 属性） state（celery.bootsteps.Blueprint 属性） State（celery.contrib.migrate 中的类） State（celery.events.state 中的类） state（celery.events.state.State.Task 属性） state（celery.events.state.Task 属性） state（celery.result.AsyncResult 属性） state（celery.result.EagerResult 属性） state（celery.states 中的类） state（celery.worker.WorkController 属性） state（celery.worker.worker.WorkController 属性） stats() （celery.app.control.Inspect 方法） stats() （celery.worker.WorkController 方法） stats() （celery.worker.worker.WorkController 方法） status_string（celery.events.state.State.Worker 属性） status_string（celery.events.state.Worker 属性） status（celery.backends.database.models.Task 属性） status（celery.backends.database.models.TaskExtended 属性） status（celery.result.AsyncResult 属性） status（celery.result.EagerResult 属性） stat（celery.utils.sysinfo.df 属性） steps（celery.Celery 属性） Step（celery.bootsteps 中的类） stop() （celery.apps.beat.Beat.Service 方法） stop() （celery.apps.multi.Cluster 方法） stop() （celery.backends.asynchronous.BaseResultConsumer 方法） stop() （celery.backends.asynchronous.Drainer 方法） stop() （celery.backends.redis.RedisBackend.ResultConsumer 方法） stop() （celery.backends.rpc.RPCBackend.ResultConsumer 方法） stop() （celery.beat.Service 方法） stop() （celery.bin.multi.MultiTool 方法） stop() （celery.bootsteps.Blueprint 方法） stop() （celery.bootsteps.ConsumerStep 方法） stop() （celery.bootsteps.StartStopStep 方法） stop() （celery.concurrency.base.BasePool 方法） stop() （celery.concurrency.base.BasePool.Timer 方法） stop() （celery.utils.threads.bgThread 方法） stop() （celery.utils.timer2.Timer 方法） stop() （celery.worker.components.Hub 方法） stop() （celery.worker.consumer.Consumer 方法） stop() （celery.worker.consumer.consumer.Consumer 方法） stop() （celery.worker.consumer.Events 方法） stop() （celery.worker.consumer.events.Events 方法） stop() （celery.worker.consumer.Heart 方法） stop() （celery.worker.consumer.heart.Heart 方法） stop() （celery.worker.consumer.Tasks 方法） stop() （celery.worker.consumer.tasks.Tasks 方法） stop() （celery.worker.heartbeat.Heart 方法） stop() （celery.worker.pidbox.Pidbox 方法） stop() （celery.worker.WorkController 方法） stop() （celery.worker.worker.WorkController 方法） stop_verify() （celery.bin.multi.MultiTool 方法） StopFiltering stopwait() （celery.apps.multi.Cluster 方法） stopwait() （celery.bin.multi.MultiTool 方法） storage（celery.worker.state.Persistent 属性） store_errors_even_if_ignored（celery.app.task.Task 属性） store_errors_even_if_ignored（Task 属性） store_errors（celery.worker.request.Request 属性） store_result() （celery.backends.base.DisabledBackend 方法） store_result() （celery.backends.rpc.RPCBackend 方法） str_to_list()（在 celery.utils.text 模块中） strategies Strategies（celery.worker.consumer.Consumer 属性） Strategies（celery.worker.consumer.consumer.Consumer 属性） Strategy（celery.app.task.Task 属性） strtobool()（在 celery.utils.serialization 模块中） strtotal（celery.contrib.migrate.State 属性） style() （celery.bin.base.CLIContext 方法） subclass_exception()（在 celery.utils.serialization 模块中） subpolling_interval（celery.backends.database.DatabaseBackend 属性） subtask() （celery.app.task.Task 方法） subtask_type（celery.utils.abstract.CallableSignature 属性） succeeded（celery.events.state.State.Task 属性） succeeded（celery.events.state.Task 属性） SUCCESS state SUCCESS()（在 celery.states 模块中） successful() （celery.result.AsyncResult 方法） successful() （celery.result.ResultSet 方法） supports_autoexpire（celery.backends.cache.CacheBackend 属性） supports_autoexpire（celery.backends.cassandra.CassandraBackend 属性） supports_autoexpire（celery.backends.consul.ConsulBackend 属性） supports_autoexpire（celery.backends.couchbase.CouchbaseBackend 属性） supports_autoexpire（celery.backends.dynamodb.DynamoDBBackend 属性） supports_autoexpire（celery.backends.mongodb.MongoBackend 属性） supports_autoexpire（celery.backends.redis.RedisBackend 属性） supports_autoexpire（celery.backends.rpc.RPCBackend 属性） supports_color() （celery.app.log.Logging 方法） supports_native_join（celery.backends.cache.CacheBackend 属性） supports_native_join（celery.backends.gcs.GCSBackend 属性） supports_native_join（celery.backends.redis.RedisBackend 属性） supports_native_join（celery.backends.rpc.RPCBackend 属性） supports_native_join（celery.result.AsyncResult 属性） supports_native_join（celery.result.EagerResult 属性） supports_native_join（celery.result.ResultSet 属性） sw_ident（celery.events.state.State.Worker 属性） sw_ident（celery.events.state.Worker 属性） sw_sys（celery.events.state.State.Worker 属性） sw_sys（celery.events.state.Worker 属性） sw_ver（celery.events.state.State.Worker 属性） sw_ver（celery.events.state.Worker 属性） swap_with() （celery.utils.collections.ConfigurationView 方法） symbol_by_name()（在 celery.utils.imports 模块中） sync() （celery.apps.beat.Beat.Service 方法） sync() （celery.beat.PersistentScheduler 方法） sync() （celery.beat.Scheduler 方法） sync() （celery.beat.Service 方法） sync() （celery.worker.consumer.Mingle 方法） sync() （celery.worker.consumer.mingle.Mingle 方法） sync() （celery.worker.state.Persistent 方法） sync_every_tasks（celery.beat.Scheduler 属性） sync_every（celery.beat.Scheduler 属性） sync_with_node() （celery.worker.consumer.Mingle 方法） sync_with_node() （celery.worker.consumer.mingle.Mingle 方法） synloop()（在 celery.worker.loops 模块中）

T

table() （celery.app.utils.Settings 方法） table_name（celery.backends.dynamodb.DynamoDBBackend 属性） tail() （celery.utils.graph.GraphFormatter 方法） TAIL（celery.utils.graph.DOT 属性） take() （celery.utils.collections.BufferMap 方法） take() （celery.utils.collections.Messagebuffer 方法） task() （celery.Celery 方法） task-failed event task-received event task-rejected event task-retried event task-revoked event task-sent event task-started event task-succeeded event Task.MaxRetriesExceededError Task.OperationalError task_accepted()（在 celery.worker.state 模块中） task_acks_late setting task_acks_on_failure_or_timeout setting task_allow_error_cb_on_chord_header setting task_always_eager setting task_annotations setting task_buckets task_cls（celery.backends.database.DatabaseBackend 属性） task_compression setting task_consumer task_count（celery.events.state.State 属性） task_create_missing_queues setting task_default_delivery_mode setting task_default_exchange setting task_default_exchange_type setting task_default_exchange（celery.app.utils.Settings 属性） task_default_priority setting task_default_queue setting task_default_queue_type setting task_default_rate_limit setting task_default_routing_key setting task_default_routing_key（celery.app.utils.Settings 属性） task_eager_propagates setting task_event() （celery.events.state.State 方法） task_failure signal TASK_ID celery-result命令行选项 task_id_eq()（在 celery.contrib.migrate 模块中） task_id_in()（在 celery.contrib.migrate 模块中） task_id（celery.backends.database.models.Task 属性） task_id（celery.backends.database.models.TaskExtended 属性） task_id（celery.result.AsyncResult 属性） task_id（celery.worker.request.Request 属性） task_ignore_result setting task_inherit_parent_priority setting task_internal_error signal task_join_will_block（celery.concurrency.base.BasePool 属性） task_join_will_block（celery.concurrency.eventlet.TaskPool 属性） task_join_will_block（celery.concurrency.gevent.TaskPool 属性） task_message_from_sig()（在 celery.contrib.testing.mocks 模块中） task_name（celery.worker.request.Request 属性） task_postrun signal task_prerun signal task_protocol setting task_publish_retry setting task_publish_retry_policy setting task_queue_max_priority setting task_queues setting task_ready()（在 celery.worker.state 模块中） task_received signal task_reject_on_worker_lost setting task_rejected signal task_remote_tracebacks setting task_reserved()（在 celery.worker.state 模块中） task_retry signal task_revoked signal task_routes setting task_send_sent_event setting task_sent signal task_serializer setting task_soft_time_limit setting task_store_eager_result setting task_store_errors_even_if_ignored setting task_success signal task_time_limit setting

task_track_started setting task_types() （celery.events.state.State 方法） task_unknown signal TaskDirective（celery.contrib.sphinx 中的类） TaskDocumenter（celery.contrib.sphinx 中的类） TaskError TaskExtended（celery.backends.database.models 中的类） TaskFormatter（celery.app.log 中的类） tasklist() （celery.apps.worker.Worker 方法） TaskMessage()（在 celery.contrib.testing.mocks 模块中） TaskMessage1()（在 celery.contrib.testing.mocks 模块中） taskmeta_collection（celery.backends.mongodb.MongoBackend 属性） TaskPool.Timer（celery.concurrency.eventlet 中的类） TaskPool.Timer（celery.concurrency.gevent 中的类） TaskPool（celery.concurrency.eventlet 中的类） TaskPool（celery.concurrency.gevent 中的类） TaskPool（celery.concurrency.prefork 中的类） TaskPool（celery.concurrency.solo 中的类） TaskPool（celery.concurrency.thread 中的类） TaskPredicate TaskRegistry.NotRegistered TaskRegistry（celery.app.registry 中的类） TaskRevokedError tasks_by_time() （celery.events.state.State 方法） tasks_by_timestamp() （celery.events.state.State 方法） taskset_cls（celery.backends.database.DatabaseBackend 属性） taskset_id（celery.backends.database.models.TaskSet 属性） TaskSet（celery.backends.database.models 中的类） tasks（celery.Celery 属性） tasks（celery.events.cursesmon.CursesMonitor 属性） Tasks（celery.worker.consumer 中的类） Tasks（celery.worker.consumer.tasks 中的类） TaskType()（在 celery.app.task 模块中） Task（celery.app.task 中的类） Task（celery.backends.database.models 中的类） Task（celery.Celery 属性） Task（celery.events.state 中的类） task（celery.utils.abstract.CallableSignature 属性） task（celery.worker.request.Request 属性） term_scheme（celery.utils.graph.GraphFormatter 属性） terminal_node() （celery.utils.graph.GraphFormatter 方法） terminate() （celery.app.control.Control 方法） terminate() （celery.bootsteps.StartStopStep 方法） terminate() （celery.concurrency.base.BasePool 方法） terminate() （celery.worker.components.Hub 方法） terminate() （celery.worker.components.Pool 方法） terminate() （celery.worker.request.Request 方法） terminate() （celery.worker.WorkController 方法） terminate() （celery.worker.worker.WorkController 方法） terminate_job() （celery.concurrency.base.BasePool 方法） terminate_job() （celery.concurrency.eventlet.TaskPool 方法） terminate_job() （celery.concurrency.gevent.TaskPool 方法） Terminated TERMINATE（celery.concurrency.base.BasePool 属性） TestApp()（在 celery.contrib.testing.app 模块中） TestWorkController.QueueHandler（celery.contrib.testing.worker 中的类） TestWorkController（celery.contrib.testing.worker 中的类） thaw() （State 方法） then() （celery.result.AsyncResult 方法） then() （celery.result.EagerResult 方法） then() （celery.result.ResultSet 方法） throw() （celery.result.AsyncResult 方法） throws（celery.app.task.Task 属性） throws（Task 属性） tick() （celery.beat.Scheduler 方法） time_limit() （celery.app.control.Control 方法） time_limits（celery.worker.request.Request 属性） time_limit（celery.app.task.Task 属性） time_limit（Task 属性） time_start（celery.worker.request.Request 属性） time_to_live_seconds（celery.backends.dynamodb.DynamoDBBackend 属性） TimeLimitExceeded TimeoutError timeout（celery.backends.couchbase.CouchbaseBackend 属性） timer, [1] Timer.Entry（celery.utils.timer2 中的类） timer（celery.events.snapshot.Polaroid 属性） Timer（celery.utils.timer2 中的类） Timer（celery.worker.components 中的类） timer（celery.worker.consumer.Consumer 属性） timer（celery.worker.consumer.consumer.Consumer 属性） timestamp（celery.events.state.State.Task 属性） timestamp（celery.events.state.Task 属性） timezone setting timezone（celery.app.utils.Settings 属性） timezone（celery.Celery 属性） to_dict() （celery.backends.database.models.Task 方法） to_dict() （celery.backends.database.models.TaskExtended 方法） to_dict() （celery.backends.database.models.TaskSet 方法） to_dot() （celery.utils.graph.DependencyGraph 方法） to_python() （celery.app.defaults.Option 方法） to_timestamp()（在 celery.utils.timer2 模块中） to_utc()（在 celery.utils.time 模块中） topsort() （celery.utils.graph.DependencyGraph 方法） total_apx（celery.contrib.migrate.State 属性） total_blocks（celery.utils.sysinfo.df 属性） total_count()（在 celery.worker.state 模块中） total_run_count（celery.beat.ScheduleEntry 属性） total（celery.utils.collections.BufferMap 属性） trace_task()（在 celery.app.trace 模块中） traceback（celery.backends.database.models.Task 属性） traceback（celery.backends.database.models.TaskExtended 属性） traceback（celery.events.state.State.Task 属性） traceback（celery.events.state.Task 属性） traceback（celery.result.AsyncResult 属性） traceback（celery.result.EagerResult 属性） TraceInfo（celery.app.trace 中的类） track_started（celery.app.task.Task 属性） track_started（Task 属性） trail（celery.app.task.Task 属性） TRANSIENT_DELIVERY_MODE（celery.backends.rpc.RPCBackend.Exchange 属性） Trap（celery.contrib.testing.app 中的类） tref（celery.concurrency.base.BasePool.Timer.Entry 属性） tref（celery.utils.timer2.Entry 属性） tref（celery.utils.timer2.Timer.Entry 属性） true_or_raise() （celery.contrib.testing.manager.ManagerMixin 方法） truncate()（在 celery.utils.text 模块中） TYPE celery-amqp-exchange.declare命令行选项 typemap（celery.app.defaults.Option 属性） type（celery.app.control.Control.Mailbox 属性） type（celery.backends.rpc.RPCBackend.Exchange 属性）, [1] type（celery.utils.abstract.CallableSignature 属性） type（celery.worker.request.Request 属性） typing（celery.app.task.Task 属性） tzlocal（celery.worker.request.Request 属性） tzname() （celery.utils.time.LocalTimezone 方法）

U

unbind_from() （celery.backends.rpc.RPCBackend.Exchange 方法） underline() （celery.utils.term.colored 方法） uniq()（在 celery.utils.functional 模块中） UnitLogging（celery.contrib.testing.app 中的类） UnpickleableExceptionWrapper UNREADY_STATES state unregister() （celery.app.registry.TaskRegistry 方法） update() （celery.beat.ScheduleEntry 方法） update() （celery.events.state.State.Worker 方法） update() （celery.events.state.Worker 方法） update() （celery.result.ResultSet 方法） update() （celery.utils.collections.ChainMap 方法） update() （celery.utils.collections.LimitedSet 方法） update() （celery.utils.functional.LRUCache 方法） update() （celery.utils.graph.DependencyGraph 方法） update() （celery.worker.autoscale.Autoscaler 方法） update_from_dict() （celery.beat.Scheduler 方法）

update_state() （celery.app.task.Task 方法） update_strategies() （celery.worker.consumer.Consumer 方法） update_strategies() （celery.worker.consumer.consumer.Consumer 方法） use_celery_app_trap()（在 celery.contrib.pytest 模块中） USE_FAST_LOCALS user_options（celery.Celery 属性） user_preload_options signal username（celery.backends.arangodb.ArangoDbBackend 属性） username（celery.backends.couchbase.CouchbaseBackend 属性） username（celery.backends.couchdb.CouchBackend 属性） username（celery.backends.elasticsearch.ElasticsearchBackend 属性） user（celery.backends.mongodb.MongoBackend 属性） uses_semaphore（celery.concurrency.base.BasePool 属性） uses_semaphore（celery.concurrency.prefork.TaskPool 属性） utcoffset() （celery.utils.time.LocalTimezone 方法） utcoffset()（在 celery.utils.time 模块中） utc（celery.worker.request.Request 属性） uuid()（在 celery.utils 模块中）

V

valency_of() （celery.utils.graph.DependencyGraph 方法） validate_arguments() （celery.bin.multi.MultiTool 方法） value_set_for() （celery.app.utils.Settings 方法） values() （celery.utils.collections.ChainMap 方法）

values() （celery.utils.collections.DictAttribute 方法） values() （celery.utils.functional.LRUCache 方法） verify() （celery.security.certificate.Certificate 方法） verify（celery.backends.arangodb.ArangoDbBackend 属性）

W

wait() （celery.result.AsyncResult 方法） wait() （celery.result.EagerResult 方法） wait_for() （celery.backends.asynchronous.Drainer 方法） wait_for() （celery.backends.base.DisabledBackend 方法） wait_for() （celery.contrib.testing.manager.ManagerMixin 方法） wait_for_pending() （celery.backends.asynchronous.AsyncBackendMixin 方法） wait_for_soft_shutdown() （celery.worker.WorkController 方法） wait_for_soft_shutdown() （celery.worker.worker.WorkController 方法） wait_until_idle() （celery.contrib.testing.manager.ManagerMixin 方法） waiting() （celery.result.ResultSet 方法） wakeup_workers() （celery.events.EventReceiver 方法） wakeup_workers() （celery.events.receiver.EventReceiver 方法） warn()（在 celery.utils.deprecated 模块中） weekday()（在 celery.utils.time 模块中） when（celery.exceptions.Retry 属性） white() （celery.utils.term.colored 方法） win（celery.events.cursesmon.CursesMonitor 属性） without_defaults() （celery.app.utils.Settings 方法） WorkController.Blueprint（celery.worker 中的类） WorkController.Blueprint（celery.worker.worker 中的类） WorkController（celery.Celery 属性） WorkController（celery.worker 中的类） WorkController（celery.worker.worker 中的类） worker-heartbeat event worker-offline event worker-online event worker_autoscaler setting worker_before_create_process signal worker_cancel_long_running_tasks_on_connection_loss setting worker_concurrency setting worker_consumer setting worker_deduplicate_successful_tasks setting worker_detect_quorum_queues setting worker_direct setting worker_direct()（在 celery.utils 模块中） worker_direct()（在 celery.utils.nodenames 模块中） worker_disable_rate_limits setting worker_enable_prefetch_count_reduction setting worker_enable_remote_control setting worker_enable_soft_shutdown_on_idle setting worker_event() （celery.events.state.State 方法） worker_executable setting worker_gid setting worker_hijack_root_logger setting worker_init signal worker_initialized（celery.loaders.base.BaseLoader 属性） worker_log_color setting worker_log_format setting

worker_logfile setting worker_lost_wait setting worker_max_memory_per_child setting worker_max_tasks_per_child setting worker_pidfile setting worker_pid（celery.worker.request.Request 属性） worker_pool setting worker_pool_restarts setting worker_prefetch_multiplier setting worker_proc_alive_timeout setting worker_process_init signal worker_process_shutdown signal worker_ready signal worker_redirect_stdouts setting worker_redirect_stdouts_level setting worker_send_task_events setting worker_shutdown signal worker_shutting_down signal worker_soft_shutdown_timeout setting worker_state_db setting worker_task_log_format setting worker_timer setting worker_timer_precision setting worker_uid setting worker_umask setting WorkerComponent（celery.worker.autoscale 中的类） WorkerLostError WorkerShutdown WorkersPool（celery.bin.worker 中的类） workers（celery.events.cursesmon.CursesMonitor 属性） WorkerTerminate Worker（celery.apps.worker 中的类） worker（celery.backends.database.models.TaskExtended 属性） Worker（celery.Celery 属性） Worker（celery.events.state 中的类） worker（celery.events.state.State.Task 属性） worker（celery.events.state.Task 属性） worker（celery.result.AsyncResult 属性） write() （celery.utils.log.LoggingProxy 方法） write_capacity_units（celery.backends.dynamodb.DynamoDBBackend 属性） write_pid() （celery.platforms.Pidfile 方法） write_stats（celery.concurrency.prefork.TaskPool 属性） writelines() （celery.utils.log.LoggingProxy 方法）

Y

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

环

环境变量 AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY C_FAKEFORK, [1], [2], [3], [4], [5], [6] C_FORCE_ROOT, [1], [2], [3] C_IMPDEBUG CELERY_BENCH CELERY_BROKER_URL CELERY_CHDIR CELERY_CONFIG_MODULE, [1], [2], [3] CELERY_CREATE_DIRS CELERY_LOADER, [1], [2], [3], [4], [5], [6] CELERY_RDB_HOST, [1], [2] CELERY_RDB_PORT, [1], [2] CELERY_RDBSIG, [1] CELERY_SU CELERY_TRACE_APP, [1], [2], [3], [4] CELERYCTL CELERYD_SU_ARGS DJANGO_SETTINGS_MODULE, [1], [2], [3], [4], [5], [6] MP_LOG, [1] NOSE_VERBOSE USE_FAST_LOCALS