索引

_

__len__() （kombu.simple.SimpleBuffer 方法）

__len__() （kombu.simple.SimpleQueue 方法） _close() （kombu.Connection 方法）

A

abcast() （kombu.pidbox.Mailbox 方法） AbstractChannel（kombu.transport.virtual 中的类） accept（kombu.asynchronous.aws.sqs.message.AsyncMessage 属性） accept（kombu.asynchronous.aws.sqs.message.AsyncRawMessage 属性） accept（kombu.asynchronous.aws.sqs.message.BaseAsyncMessage 属性） accept（kombu.compat.Consumer 属性） accept（kombu.compat.ConsumerSet 属性） accept（kombu.message.Message 属性） accept（kombu.transport.pyamqp.Channel.Message 属性） accept（kombu.transport.pyamqp.Connection.Channel.Message 属性） accept（kombu.transport.pyamqp.Message 属性） accept（kombu.transport.pyamqp.Transport.Connection.Channel.Message 属性） accept（kombu.transport.qpid.Channel.Message 属性） accept（kombu.transport.qpid.Connection.Channel.Message 属性） accept（kombu.transport.qpid.Message 属性） accept（kombu.transport.qpid.Transport.Connection.Channel.Message 属性） accept（kombu.transport.virtual.Message 属性） ack() （kombu.message.Message 方法） ack() （kombu.transport.base.Message 方法） ack() （kombu.transport.pyamqp.Connection.Channel.Message 方法） ack() （kombu.transport.qpid.Channel.QoS 方法） ack() （kombu.transport.qpid.Connection.Channel.QoS 方法） ack() （kombu.transport.qpid.Transport.Connection.Channel.QoS 方法） ack() （kombu.transport.virtual.Message 方法） ack() （kombu.transport.virtual.QoS 方法） ack_log_error() （kombu.message.Message 方法） ack_log_error() （kombu.transport.pyamqp.Connection.Channel.Message 方法） ack_log_error() （kombu.transport.virtual.Message 方法） acknowledged（kombu.message.Message 属性） acknowledged（kombu.transport.base.Message 属性） acknowledged（kombu.transport.pyamqp.Connection.Channel.Message 属性） acknowledged（kombu.transport.virtual.Message 属性） acquire() （kombu.asynchronous.semaphore.LaxBoundedSemaphore 方法） acquire() （kombu.connection.ChannelPool 方法） acquire() （kombu.connection.ConnectionPool 方法） acquire() （kombu.resource.Resource 方法） add() （kombu.asynchronous.Hub 方法） add() （kombu.asynchronous.hub.Hub 方法） add() （kombu.utils.limits.TokenBucket 方法） add_consumer() （kombu.compat.ConsumerSet 方法） add_consumer_from_dict() （kombu.compat.ConsumerSet 方法） add_note() （kombu.compat.Consumer.ContentDisallowed 方法） add_note() （kombu.compat.ConsumerSet.ContentDisallowed 方法） add_note() （kombu.transport.pyamqp.Connection.Channel.Message.MessageStateError 方法） add_note() （kombu.transport.virtual.Message.MessageStateError 方法） add_permission() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） add_permission() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） add_queue() （kombu.compat.Consumer 方法） add_queue() （kombu.compat.ConsumerSet 方法） add_queue() （kombu.Consumer 方法） add_reader() （kombu.asynchronous.Hub 方法） add_reader() （kombu.asynchronous.hub.Hub 方法） add_request() （kombu.asynchronous.http.curl.CurlClient 方法） add_writer() （kombu.asynchronous.Hub 方法） add_writer() （kombu.asynchronous.hub.Hub 方法） adjust() （kombu.clocks.LamportClock 方法） after_reply_message_received() （kombu.transport.memory.Channel 方法） after_reply_message_received() （kombu.transport.memory.Transport.Channel 方法）

after_reply_message_received() （kombu.transport.pyamqp.Connection.Channel 方法） after_reply_message_received() （kombu.transport.pyro.Channel 方法） after_reply_message_received() （kombu.transport.pyro.Transport.Channel 方法） alias（kombu.Queue 属性） annotate() （kombu.log.LogMixin 方法） append() （kombu.transport.qpid.Channel.QoS 方法） append() （kombu.transport.qpid.Connection.Channel.QoS 方法） append() （kombu.transport.qpid.Transport.Connection.Channel.QoS 方法） append() （kombu.transport.virtual.QoS 方法） apply_entry() （kombu.asynchronous.timer.Timer 方法） args（kombu.asynchronous.timer.Entry 属性） args（kombu.asynchronous.timer.Timer.Entry 属性） args（kombu.compat.Consumer.ContentDisallowed 属性） args（kombu.compat.ConsumerSet.ContentDisallowed 属性） args（kombu.transport.pyamqp.Connection.Channel.Message.MessageStateError 属性） args（kombu.transport.virtual.Message.MessageStateError 属性） as_dict() （kombu.Queue 方法） as_uri() （kombu.Connection 方法） as_uri() （kombu.connection.Connection 方法） as_uri() （kombu.transport.mongodb.Transport 方法） as_url()（在 kombu.utils.url 模块中） AsyncConnection（kombu.asynchronous.aws.connection 中的类） AsyncHTTPSConnection.Request（kombu.asynchronous.aws.connection 中的类） AsyncHTTPSConnection（kombu.asynchronous.aws.connection 中的类） AsyncMessage（kombu.asynchronous.aws.sqs.message 中的类） AsyncQueue（kombu.asynchronous.aws.sqs.queue 中的类） AsyncRawMessage（kombu.asynchronous.aws.sqs.message 中的类） AsyncSQSConnection（kombu.asynchronous.aws.sqs.connection 中的类） attrs（kombu.common.Broadcast 属性） attrs（kombu.Exchange 属性） attrs（kombu.Queue 属性） auth_mode（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） auth_mode（kombu.asynchronous.http.base.Request 属性） auth_mode（kombu.asynchronous.http.Request 属性） auth_password（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） auth_password（kombu.asynchronous.http.base.Request 属性） auth_password（kombu.asynchronous.http.Request 属性） auth_username（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） auth_username（kombu.asynchronous.http.base.Request 属性） auth_username（kombu.asynchronous.http.Request 属性） auto_declare（kombu.compat.Consumer 属性） auto_declare（kombu.compat.ConsumerSet 属性） auto_declare（kombu.compat.Publisher 属性） auto_declare（kombu.Consumer 属性） auto_declare（kombu.pools.ProducerPool.Producer 属性） auto_declare（kombu.Producer 属性） auto_decode（kombu.transport.pyamqp.Channel 属性） auto_decode（kombu.transport.pyamqp.Connection 属性） auto_decode（kombu.transport.pyamqp.Connection.Channel 属性） auto_decode（kombu.transport.pyamqp.Transport.Connection 属性） auto_decode（kombu.transport.pyamqp.Transport.Connection.Channel 属性） auto_delete（kombu.compat.Consumer 属性） auto_delete（kombu.compat.Publisher 属性） auto_delete（kombu.Exchange 属性） auto_delete（kombu.Queue 属性）, [1] autoretry() （kombu.Connection 方法） autoretry() （kombu.connection.Connection 方法） AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY

B

backend（kombu.compat.Publisher 属性） BaseAsyncMessage（kombu.asynchronous.aws.sqs.message 中的类） basic_ack() （kombu.transport.pyamqp.Connection.Channel 方法） basic_ack() （kombu.transport.qpid.Channel 方法） basic_ack() （kombu.transport.qpid.Connection.Channel 方法） basic_ack() （kombu.transport.qpid.Transport.Connection.Channel 方法） basic_ack() （kombu.transport.SLMQ.Channel 方法） basic_ack() （kombu.transport.SLMQ.Transport.Channel 方法） basic_ack() （kombu.transport.virtual.Channel 方法） basic_cancel() （kombu.transport.pyamqp.Connection.Channel 方法） basic_cancel() （kombu.transport.qpid.Channel 方法） basic_cancel() （kombu.transport.qpid.Connection.Channel 方法） basic_cancel() （kombu.transport.qpid.Transport.Connection.Channel 方法） basic_cancel() （kombu.transport.SLMQ.Channel 方法） basic_cancel() （kombu.transport.SLMQ.Transport.Channel 方法） basic_cancel() （kombu.transport.virtual.Channel 方法） basic_consume() （kombu.transport.pyamqp.Connection.Channel 方法） basic_consume() （kombu.transport.qpid.Channel 方法） basic_consume() （kombu.transport.qpid.Connection.Channel 方法） basic_consume() （kombu.transport.qpid.Transport.Connection.Channel 方法） basic_consume() （kombu.transport.SLMQ.Channel 方法） basic_consume() （kombu.transport.SLMQ.Transport.Channel 方法） basic_consume() （kombu.transport.virtual.Channel 方法） basic_get() （kombu.transport.pyamqp.Connection.Channel 方法） basic_get() （kombu.transport.qpid.Channel 方法） basic_get() （kombu.transport.qpid.Connection.Channel 方法） basic_get() （kombu.transport.qpid.Transport.Connection.Channel 方法） basic_get() （kombu.transport.virtual.Channel 方法） basic_publish() （kombu.transport.pyamqp.Connection.Channel 方法） basic_publish() （kombu.transport.qpid.Channel 方法） basic_publish() （kombu.transport.qpid.Connection.Channel 方法） basic_publish() （kombu.transport.qpid.Transport.Connection.Channel 方法） basic_publish() （kombu.transport.virtual.Channel 方法） basic_publish_confirm() （kombu.transport.pyamqp.Connection.Channel 方法） basic_qos() （kombu.transport.pyamqp.Connection.Channel 方法） basic_qos() （kombu.transport.qpid.Channel 方法） basic_qos() （kombu.transport.qpid.Connection.Channel 方法） basic_qos() （kombu.transport.qpid.Transport.Connection.Channel 方法） basic_qos() （kombu.transport.virtual.Channel 方法） basic_recover() （kombu.transport.pyamqp.Connection.Channel 方法） basic_recover() （kombu.transport.virtual.Channel 方法） basic_recover_async() （kombu.transport.pyamqp.Connection.Channel 方法） basic_reject() （kombu.transport.pyamqp.Connection.Channel 方法） basic_reject() （kombu.transport.qpid.Channel 方法） basic_reject() （kombu.transport.qpid.Connection.Channel 方法）

basic_reject() （kombu.transport.qpid.Transport.Connection.Channel 方法） basic_reject() （kombu.transport.virtual.Channel 方法） bind() （kombu.abstract.MaybeChannelBound 方法） bind() （kombu.Queue 方法） bind_to() （kombu.Exchange 方法） bind_to() （kombu.Queue 方法） binding() （kombu.Exchange 方法） binding_arguments（kombu.Queue 属性） binding_declare() （kombu.transport.virtual.BrokerState 方法） binding_delete() （kombu.transport.virtual.BrokerState 方法） bindings（kombu.transport.virtual.BrokerState 属性） blocking_read() （kombu.transport.pyamqp.Connection 方法） body_encoding（kombu.transport.qpid.Channel 属性） body_encoding（kombu.transport.qpid.Connection.Channel 属性） body_encoding（kombu.transport.qpid.Transport.Connection.Channel 属性） body（kombu.asynchronous.aws.connection.AsyncHTTPSConnection 属性） body（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） body（kombu.asynchronous.aws.sqs.message.AsyncMessage 属性） body（kombu.asynchronous.aws.sqs.message.AsyncRawMessage 属性） body（kombu.asynchronous.aws.sqs.message.BaseAsyncMessage 属性） body（kombu.asynchronous.http.base.Request 属性） body（kombu.asynchronous.http.base.Response 属性） body（kombu.asynchronous.http.Request 属性） body（kombu.asynchronous.http.Response 属性） body（kombu.message.Message 属性） body（kombu.transport.base.Message 属性） body（kombu.transport.pyamqp.Channel.Message 属性） body（kombu.transport.pyamqp.Connection.Channel.Message 属性） body（kombu.transport.pyamqp.Message 属性） body（kombu.transport.pyamqp.Transport.Connection.Channel.Message 属性） body（kombu.transport.qpid.Channel.Message 属性） body（kombu.transport.qpid.Connection.Channel.Message 属性） body（kombu.transport.qpid.Message 属性） body（kombu.transport.qpid.Transport.Connection.Channel.Message 属性） body（kombu.transport.virtual.Message 属性） broadcast_collection（kombu.transport.mongodb.Channel 属性） broadcast_collection（kombu.transport.mongodb.Transport.Channel 属性） Broadcast（kombu.common 中的类） broadcast（kombu.transport.mongodb.Channel 属性） broadcast（kombu.transport.mongodb.Transport.Channel 属性） BrokerState（kombu.transport.virtual 中的类） buffer（kombu.asynchronous.http.base.Response 属性）, [1] buffer（kombu.asynchronous.http.Response 属性）, [1] bytes_recv（kombu.transport.pyamqp.Connection 属性） bytes_sent（kombu.transport.pyamqp.Connection 属性） bytes_to_str()（在 kombu.utils.encoding 模块中）

C

ca_certs（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） ca_certs（kombu.asynchronous.http.base.Request 属性） ca_certs（kombu.asynchronous.http.Request 属性） cached_property（kombu.utils.objects 中的类） calc_queue_size（kombu.transport.mongodb.Channel 属性） calc_queue_size（kombu.transport.mongodb.Transport.Channel 属性） call() （kombu.pidbox.Mailbox 方法） call_after() （kombu.asynchronous.timer.Timer 方法） call_at() （kombu.asynchronous.Hub 方法） call_at() （kombu.asynchronous.hub.Hub 方法） call_at() （kombu.asynchronous.timer.Timer 方法） call_later() （kombu.asynchronous.Hub 方法） call_later() （kombu.asynchronous.hub.Hub 方法） call_repeatedly() （kombu.asynchronous.Hub 方法） call_repeatedly() （kombu.asynchronous.hub.Hub 方法） call_repeatedly() （kombu.asynchronous.timer.Timer 方法） call_soon() （kombu.asynchronous.Hub 方法） call_soon() （kombu.asynchronous.hub.Hub 方法） callback_for()（在 kombu.asynchronous.debug 模块中） callbacks（kombu.compat.Consumer 属性） callbacks（kombu.compat.ConsumerSet 属性） callbacks（kombu.Consumer 属性） can_cache_declaration（kombu.abstract.MaybeChannelBound 属性） can_cache_declaration（kombu.Exchange 属性） can_cache_declaration（kombu.Queue 属性） can_consume() （kombu.transport.qpid.Channel.QoS 方法） can_consume() （kombu.transport.qpid.Connection.Channel.QoS 方法） can_consume() （kombu.transport.qpid.Transport.Connection.Channel.QoS 方法） can_consume() （kombu.transport.virtual.QoS 方法） can_consume() （kombu.utils.limits.TokenBucket 方法） can_consume_max_estimate() （kombu.transport.qpid.Channel.QoS 方法） can_consume_max_estimate() （kombu.transport.qpid.Connection.Channel.QoS 方法） can_consume_max_estimate() （kombu.transport.qpid.Transport.Connection.Channel.QoS 方法） can_consume_max_estimate() （kombu.transport.virtual.QoS 方法） can_parse_url（kombu.transport.mongodb.Transport 属性） can_parse_url（kombu.transport.sqlalchemy.Transport 属性） cancel() （kombu.asynchronous.timer.Entry 方法） cancel() （kombu.asynchronous.timer.Timer 方法） cancel() （kombu.asynchronous.timer.Timer.Entry 方法） cancel() （kombu.compat.Consumer 方法） cancel() （kombu.compat.ConsumerSet 方法） cancel() （kombu.Consumer 方法） cancel() （kombu.Queue 方法） cancel_by_queue() （kombu.compat.Consumer 方法） cancel_by_queue() （kombu.compat.ConsumerSet 方法） cancel_by_queue() （kombu.Consumer 方法） canceled（kombu.asynchronous.timer.Entry 属性） canceled（kombu.asynchronous.timer.Timer.Entry 属性） cancelled（kombu.asynchronous.timer.Entry 属性） cancelled（kombu.asynchronous.timer.Timer.Entry 属性） capacity（kombu.utils.limits.TokenBucket 属性） capped_queue_size（kombu.transport.mongodb.Channel 属性） capped_queue_size（kombu.transport.mongodb.Transport.Channel 属性） cast() （kombu.pidbox.Mailbox 方法） change_message_visibility() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） change_message_visibility_batch() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） change_message_visibility_batch() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） channel() （kombu.Connection 方法） channel() （kombu.connection.Connection 方法） channel() （kombu.transport.pyamqp.Connection 方法） Channel.Message（kombu.transport.pyamqp 中的类） Channel.Message（kombu.transport.qpid 中的类） Channel.QoS（kombu.transport.qpid 中的类） channel_errors（kombu.Connection 属性） channel_errors（kombu.connection.Connection 属性） channel_errors（kombu.mixins.ConsumerMixin 属性） channel_errors（kombu.transport.base.Transport 属性） channel_errors（kombu.transport.mongodb.Transport 属性） channel_errors（kombu.transport.pyamqp.Connection 属性） channel_errors（kombu.transport.pyamqp.Transport 属性） channel_errors（kombu.transport.qpid.Transport 属性） channel_errors（kombu.transport.zookeeper.Transport 属性） channel_id（kombu.transport.pyamqp.Channel 属性） channel_id（kombu.transport.pyamqp.Connection 属性） channel_id（kombu.transport.pyamqp.Connection.Channel 属性） channel_id（kombu.transport.pyamqp.Transport.Connection 属性） channel_id（kombu.transport.pyamqp.Transport.Connection.Channel 属性） ChannelLimitExceeded ChannelPool() （kombu.Connection 方法） ChannelPool() （kombu.connection.Connection 方法） ChannelPool（kombu.connection 中的类） channel（kombu.abstract.MaybeChannelBound 属性） channel（kombu.asynchronous.aws.sqs.message.AsyncMessage 属性） channel（kombu.asynchronous.aws.sqs.message.AsyncRawMessage 属性） channel（kombu.asynchronous.aws.sqs.message.BaseAsyncMessage 属性） channel（kombu.compat.Consumer 属性） channel（kombu.compat.ConsumerSet 属性） channel（kombu.compat.Publisher 属性） channel（kombu.Consumer 属性） channel（kombu.message.Message 属性） channel（kombu.pidbox.Node 属性） channel（kombu.pools.ProducerPool.Producer 属性） channel（kombu.Producer 属性） channel（kombu.Queue 属性） channel（kombu.simple.SimpleBuffer 属性） channel（kombu.simple.SimpleQueue 属性） channel（kombu.transport.base.Message 属性） Channel（kombu.transport.consul 中的类） Channel（kombu.transport.etcd 中的类） Channel（kombu.transport.filesystem 中的类） Channel（kombu.transport.memory 中的类） Channel（kombu.transport.mongodb 中的类） Channel（kombu.transport.pyamqp 中的类） channel（kombu.transport.pyamqp.Channel.Message 属性） channel（kombu.transport.pyamqp.Connection.Channel.Message 属性） channel（kombu.transport.pyamqp.Message 属性） channel（kombu.transport.pyamqp.Transport.Connection.Channel.Message 属性） Channel（kombu.transport.pyro 中的类） Channel（kombu.transport.qpid 中的类） channel（kombu.transport.qpid.Channel.Message 属性） channel（kombu.transport.qpid.Connection.Channel.Message 属性） channel（kombu.transport.qpid.Message 属性） channel（kombu.transport.qpid.Transport.Connection.Channel.Message 属性） Channel（kombu.transport.SLMQ 中的类） Channel（kombu.transport.sqlalchemy 中的类） Channel（kombu.transport.virtual 中的类） channel（kombu.transport.virtual.Message 属性） Channel（kombu.transport.virtual.Transport 属性） Channel（kombu.transport.zookeeper 中的类） clear() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） clear() （kombu.asynchronous.semaphore.LaxBoundedSemaphore 方法） clear() （kombu.asynchronous.timer.Timer 方法） clear() （kombu.simple.SimpleBuffer 方法） clear() （kombu.simple.SimpleQueue 方法） clear() （kombu.transport.virtual.BrokerState 方法） clear_pending() （kombu.utils.limits.TokenBucket 方法） Client()（在 kombu.asynchronous.http 模块中） client_cert（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） client_cert（kombu.asynchronous.http.base.Request 属性） client_cert（kombu.asynchronous.http.Request 属性） client_heartbeat（kombu.transport.pyamqp.Connection 属性） client_key（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） client_key（kombu.asynchronous.http.base.Request 属性） client_key（kombu.asynchronous.http.Request 属性） client（kombu.transport.base.Transport 属性） client（kombu.transport.mongodb.Channel 属性） client（kombu.transport.mongodb.Transport.Channel 属性） client（kombu.transport.zookeeper.Channel 属性） client（kombu.transport.zookeeper.Transport.Channel 属性） clock（kombu.clocks.timetuple 属性） clone() （kombu.Connection 方法） clone() （kombu.connection.Connection 方法） close() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection 方法） close() （kombu.asynchronous.http.curl.CurlClient 方法） close() （kombu.asynchronous.Hub 方法） close() （kombu.asynchronous.hub.Hub 方法） close() （kombu.compat.Consumer 方法） close() （kombu.compat.ConsumerSet 方法） close() （kombu.compat.Publisher 方法） close() （kombu.Connection 方法） close() （kombu.connection.Connection 方法） close() （kombu.pools.ProducerPool.Producer 方法） close() （kombu.simple.SimpleBuffer 方法） close() （kombu.simple.SimpleQueue 方法） close() （kombu.transport.memory.Channel 方法） close() （kombu.transport.memory.Transport.Channel 方法） close() （kombu.transport.pyamqp.Connection 方法） close() （kombu.transport.pyamqp.Connection.Channel 方法） close() （kombu.transport.pyro.Channel 方法） close() （kombu.transport.pyro.Transport.Channel 方法） close() （kombu.transport.qpid.Channel 方法） close() （kombu.transport.qpid.Connection 方法） close() （kombu.transport.qpid.Connection.Channel 方法） close() （kombu.transport.qpid.Transport.Connection 方法） close() （kombu.transport.qpid.Transport.Connection.Channel 方法） close() （kombu.transport.virtual.Channel 方法）

close() （kombu.utils.scheduling.FairCycle 方法） close_after_fork（kombu.pools.ProducerPool 属性） close_after_fork（kombu.resource.Resource 属性） close_channel() （kombu.transport.base.Transport 方法） close_channel() （kombu.transport.qpid.Connection 方法） close_channel() （kombu.transport.qpid.Transport.Connection 方法） close_channel() （kombu.transport.virtual.Transport 方法） close_connection() （kombu.transport.base.Transport 方法） close_connection() （kombu.transport.pyamqp.Transport 方法） close_connection() （kombu.transport.qpid.Transport 方法） close_connection() （kombu.transport.virtual.Transport 方法） close_resource() （kombu.pools.ProducerPool 方法） close_resource() （kombu.resource.Resource 方法） codecs（kombu.transport.qpid.Channel 属性） codecs（kombu.transport.qpid.Connection.Channel 属性） codecs（kombu.transport.qpid.Transport.Connection.Channel 属性） code（kombu.asynchronous.http.base.Response 属性）, [1] code（kombu.asynchronous.http.Response 属性）, [1] collect() （kombu.connection.Connection 方法） collect() （kombu.transport.pyamqp.Connection 方法） collect() （kombu.transport.pyamqp.Connection.Channel 方法） collect_replies()（在 kombu.common 模块中） collect_resource() （kombu.resource.Resource 方法） completes_cycle() （kombu.Connection 方法） completes_cycle() （kombu.connection.Connection 方法） complete（kombu.asynchronous.http.base.Headers 属性） complete（kombu.asynchronous.http.Headers 属性） compress()（在 kombu.compression 模块中） compression（kombu.compat.Publisher 属性） compression（kombu.pools.ProducerPool.Producer 属性） compression（kombu.Producer 属性） confirm_select() （kombu.transport.pyamqp.Connection.Channel 方法） connect() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection 方法） connect() （kombu.Connection 方法） connect() （kombu.connection.Connection 方法） connect() （kombu.transport.pyamqp.Connection 方法） connect_max_retries（kombu.mixins.ConsumerMixin 属性） connect_sqs()（在 kombu.asynchronous.aws 模块中） connect_timeout（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） connect_timeout（kombu.asynchronous.http.base.Request 属性） connect_timeout（kombu.asynchronous.http.Request 属性） connect_timeout（kombu.Connection 属性） connect_timeout（kombu.connection.Connection 属性） connect_timeout（kombu.transport.mongodb.Channel 属性） connect_timeout（kombu.transport.mongodb.Transport.Channel 属性） connected（kombu.Connection 属性） connected（kombu.connection.Connection 属性） connected（kombu.transport.pyamqp.Connection 属性） Connection.Channel.Message.MessageStateError Connection.Channel.Message（kombu.transport.pyamqp 中的类） Connection.Channel.Message（kombu.transport.qpid 中的类） Connection.Channel.QoS（kombu.transport.qpid 中的类） Connection.Channel（kombu.transport.pyamqp 中的类） Connection.Channel（kombu.transport.qpid 中的类） connection_errors（kombu.Connection 属性） connection_errors（kombu.connection.Connection 属性） connection_errors（kombu.mixins.ConsumerMixin 属性） connection_errors（kombu.transport.base.Transport 属性） connection_errors（kombu.transport.mongodb.Transport 属性） connection_errors（kombu.transport.pyamqp.Connection 属性） connection_errors（kombu.transport.pyamqp.Transport 属性） connection_errors（kombu.transport.qpid.Transport 属性） connection_errors（kombu.transport.SLMQ.Transport 属性） connection_errors（kombu.transport.sqlalchemy.Transport 属性） connection_errors（kombu.transport.zookeeper.Transport 属性） ConnectionLimitExceeded ConnectionPool（kombu.connection 中的类） Connection（kombu 中的类） connection（kombu.compat.Consumer 属性） connection（kombu.compat.ConsumerSet 属性） connection（kombu.compat.Publisher 属性） Connection（kombu.connection 中的类） connection（kombu.Connection 属性） connection（kombu.connection.Connection 属性） connection（kombu.Consumer 属性） connection（kombu.pidbox.Mailbox 属性） connection（kombu.pools.ProducerPool.Producer 属性） connection（kombu.Producer 属性） Connection（kombu.transport.pyamqp 中的类） connection（kombu.transport.pyamqp.Channel 属性） connection（kombu.transport.pyamqp.Connection 属性） connection（kombu.transport.pyamqp.Connection.Channel 属性） connection（kombu.transport.pyamqp.Transport.Connection 属性） connection（kombu.transport.pyamqp.Transport.Connection.Channel 属性） Connection（kombu.transport.qpid 中的类） conninfo（kombu.transport.SLMQ.Channel 属性） conninfo（kombu.transport.SLMQ.Transport.Channel 属性） consume() （kombu.compat.Consumer 方法） consume() （kombu.compat.ConsumerSet 方法） consume() （kombu.Consumer 方法） consume() （kombu.mixins.ConsumerMixin 方法） consume() （kombu.Queue 方法） consume() （kombu.utils.scheduling.round_robin_cycle 方法） consume() （kombu.utils.scheduling.sorted_cycle 方法） Consumer() （kombu.Connection 方法） Consumer() （kombu.connection.Connection 方法） Consumer() （kombu.mixins.ConsumerMixin 方法） Consumer() （kombu.pidbox.Node 方法） Consumer() （kombu.transport.pyamqp.Connection.Channel 方法） Consumer.ContentDisallowed consumer_arguments（kombu.Queue 属性） consumer_context() （kombu.mixins.ConsumerMixin 方法） ConsumerMixin（kombu.mixins 中的类） ConsumerProducerMixin（kombu.mixins 中的类） ConsumerSet.ContentDisallowed ConsumerSet（kombu.compat 中的类） Consumer（kombu 中的类） Consumer（kombu.compat 中的类） consumer（kombu.simple.SimpleBuffer 属性） consumer（kombu.simple.SimpleQueue 属性） consuming_from() （kombu.compat.Consumer 方法） consuming_from() （kombu.compat.ConsumerSet 方法） consuming_from() （kombu.Consumer 方法） content_encoding（kombu.asynchronous.aws.sqs.message.AsyncMessage 属性） content_encoding（kombu.asynchronous.aws.sqs.message.AsyncRawMessage 属性） content_encoding（kombu.asynchronous.aws.sqs.message.BaseAsyncMessage 属性） content_encoding（kombu.message.Message 属性） content_encoding（kombu.transport.base.Message 属性） content_encoding（kombu.transport.pyamqp.Channel.Message 属性） content_encoding（kombu.transport.pyamqp.Connection.Channel.Message 属性） content_encoding（kombu.transport.pyamqp.Message 属性） content_encoding（kombu.transport.pyamqp.Transport.Connection.Channel.Message 属性） content_encoding（kombu.transport.qpid.Channel.Message 属性） content_encoding（kombu.transport.qpid.Connection.Channel.Message 属性） content_encoding（kombu.transport.qpid.Message 属性） content_encoding（kombu.transport.qpid.Transport.Connection.Channel.Message 属性） content_encoding（kombu.transport.virtual.Message 属性） content_type（kombu.asynchronous.aws.sqs.message.AsyncMessage 属性） content_type（kombu.asynchronous.aws.sqs.message.AsyncRawMessage 属性） content_type（kombu.asynchronous.aws.sqs.message.BaseAsyncMessage 属性） content_type（kombu.message.Message 属性） content_type（kombu.transport.base.Message 属性） content_type（kombu.transport.pyamqp.Channel.Message 属性） content_type（kombu.transport.pyamqp.Connection.Channel.Message 属性） content_type（kombu.transport.pyamqp.Message 属性） content_type（kombu.transport.pyamqp.Transport.Connection.Channel.Message 属性） content_type（kombu.transport.qpid.Channel.Message 属性） content_type（kombu.transport.qpid.Connection.Channel.Message 属性） content_type（kombu.transport.qpid.Message 属性） content_type（kombu.transport.qpid.Transport.Connection.Channel.Message 属性） content_type（kombu.transport.virtual.Message 属性） content（kombu.asynchronous.http.base.Response 属性） content（kombu.asynchronous.http.Response 属性） control_folder（kombu.transport.filesystem.Channel 属性） control_folder（kombu.transport.filesystem.Transport.Channel 属性） coro()（在 kombu.utils.compat 模块中） count() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） count_slow() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） create() （kombu.pools.PoolGroup 方法） create_channel() （kombu.transport.base.Transport 方法） create_channel() （kombu.transport.pyamqp.Transport 方法） create_channel() （kombu.transport.qpid.Transport 方法） create_channel() （kombu.transport.virtual.Transport 方法） create_connection() （kombu.mixins.ConsumerMixin 方法） create_loop() （kombu.asynchronous.Hub 方法） create_loop() （kombu.asynchronous.hub.Hub 方法） create_producer() （kombu.pools.ProducerPool 方法） create_queue() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） create_transport() （kombu.Connection 方法） create_transport() （kombu.connection.Connection 方法） critical() （kombu.log.LogMixin 方法） CurlClient（kombu.asynchronous.http.curl 中的类） Curl（kombu.asynchronous.http.curl.CurlClient 属性） cycle（kombu.Connection 属性） cycle（kombu.connection.Connection 属性） Cycle（kombu.transport.virtual.Transport 属性） cycle（kombu.transport.virtual.Transport 属性）

D

data_folder_in（kombu.transport.filesystem.Channel 属性） data_folder_in（kombu.transport.filesystem.Transport.Channel 属性） data_folder_out（kombu.transport.filesystem.Channel 属性） data_folder_out（kombu.transport.filesystem.Transport.Channel 属性） debug() （kombu.log.LogMixin 方法） declare() （kombu.compat.Consumer 方法） declare() （kombu.compat.ConsumerSet 方法） declare() （kombu.compat.Publisher 方法） declare() （kombu.Consumer 方法） declare() （kombu.Exchange 方法） declare() （kombu.pools.ProducerPool.Producer 方法） declare() （kombu.Producer 方法） declare() （kombu.Queue 方法） declared_entities（kombu.Connection 属性） declared_entities（kombu.connection.Connection 属性） decode() （kombu.message.Message 方法） decode() （kombu.transport.base.Message 方法） decode() （kombu.transport.pyamqp.Connection.Channel.Message 方法） decode() （kombu.transport.virtual.Message 方法） decode_body() （kombu.transport.qpid.Channel 方法） decode_body() （kombu.transport.qpid.Connection.Channel 方法） decode_body() （kombu.transport.qpid.Transport.Connection.Channel 方法） decompress()（在 kombu.compression 模块中） default() （kombu.utils.json.JSONEncoder 方法） default_channel（kombu.Connection 属性） default_channel（kombu.connection.Connection 属性） default_connection_params（kombu.transport.pyamqp.Transport 属性） default_connection_params（kombu.transport.qpid.Transport 属性） default_database（kombu.transport.mongodb.Channel 属性） default_database（kombu.transport.mongodb.Transport.Channel 属性） default_encode()（在 kombu.utils.encoding 模块中） default_encoding()（在 kombu.utils.encoding 模块中） default_encoding_file()（在 kombu.utils.encoding 模块中） default_hostname（kombu.transport.mongodb.Channel 属性） default_hostname（kombu.transport.mongodb.Transport.Channel 属性） default_ports（kombu.asynchronous.aws.connection.AsyncHTTPSConnection 属性） default_port（kombu.transport.base.Transport 属性） default_port（kombu.transport.consul.Transport 属性） default_port（kombu.transport.etcd.Transport 属性） default_port（kombu.transport.filesystem.Transport 属性） default_port（kombu.transport.mongodb.Channel 属性） default_port（kombu.transport.mongodb.Transport 属性） default_port（kombu.transport.mongodb.Transport.Channel 属性） default_port（kombu.transport.pyamqp.Transport 属性） default_port（kombu.transport.pyro.Transport 属性） default_port（kombu.transport.SLMQ.Transport 属性） default_port（kombu.transport.sqlalchemy.Transport 属性） default_port（kombu.transport.virtual.Transport 属性） default_port（kombu.transport.zookeeper.Transport 属性） default_ssl_port（kombu.transport.pyamqp.Transport 属性） DEFAULT_TRANSPORT()（在 kombu.transport 模块中） default_visibility_timeout（kombu.transport.SLMQ.Channel 属性） default_visibility_timeout（kombu.transport.SLMQ.Transport.Channel 属性） delete() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） delete() （kombu.Exchange 方法） delete() （kombu.Queue 方法） delete_message() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） delete_message() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） delete_message() （kombu.transport.SLMQ.Channel 方法） delete_message() （kombu.transport.SLMQ.Transport.Channel 方法） delete_message_batch() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） delete_message_batch() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） delete_message_from_handle() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） delete_queue() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） deleter() （kombu.utils.objects.cached_property 方法） deliver() （kombu.transport.virtual.exchange.DirectExchange 方法） deliver() （kombu.transport.virtual.exchange.FanoutExchange 方法） deliver() （kombu.transport.virtual.exchange.TopicExchange 方法） delivery_info（kombu.asynchronous.aws.sqs.message.AsyncMessage 属性） delivery_info（kombu.asynchronous.aws.sqs.message.AsyncRawMessage 属性） delivery_info（kombu.asynchronous.aws.sqs.message.BaseAsyncMessage 属性） delivery_info（kombu.message.Message 属性） delivery_info（kombu.transport.base.Message 属性） delivery_info（kombu.transport.pyamqp.Channel.Message 属性） delivery_info（kombu.transport.pyamqp.Connection.Channel.Message 属性） delivery_info（kombu.transport.pyamqp.Message 属性） delivery_info（kombu.transport.pyamqp.Transport.Connection.Channel.Message 属性） delivery_info（kombu.transport.qpid.Channel.Message 属性） delivery_info（kombu.transport.qpid.Connection.Channel.Message 属性）

delivery_info（kombu.transport.qpid.Message 属性） delivery_info（kombu.transport.qpid.Transport.Connection.Channel.Message 属性） delivery_info（kombu.transport.virtual.Message 属性） delivery_mode（kombu.Exchange 属性） delivery_tag（kombu.asynchronous.aws.sqs.message.AsyncMessage 属性） delivery_tag（kombu.asynchronous.aws.sqs.message.AsyncRawMessage 属性） delivery_tag（kombu.asynchronous.aws.sqs.message.BaseAsyncMessage 属性） delivery_tag（kombu.message.Message 属性） delivery_tag（kombu.transport.base.Message 属性） delivery_tag（kombu.transport.pyamqp.Channel.Message 属性） delivery_tag（kombu.transport.pyamqp.Connection.Channel.Message 属性） delivery_tag（kombu.transport.pyamqp.Message 属性） delivery_tag（kombu.transport.pyamqp.Transport.Connection.Channel.Message 属性） delivery_tag（kombu.transport.qpid.Channel.Message 属性） delivery_tag（kombu.transport.qpid.Connection.Channel.Message 属性） delivery_tag（kombu.transport.qpid.Message 属性） delivery_tag（kombu.transport.qpid.Transport.Connection.Channel.Message 属性） delivery_tag（kombu.transport.virtual.Message 属性） detect_environment()（在 kombu.utils.compat 模块中） dictfilter()（在 kombu.utils.functional 模块中） DirectExchange（kombu.transport.virtual.exchange 中的类） disable_insecure_serializers()（在 kombu 模块中） discard_all() （kombu.compat.Consumer 方法） discard_all() （kombu.compat.ConsumerSet 方法） dispatch() （kombu.pidbox.Node 方法） dispatch_from_message() （kombu.pidbox.Node 方法） dispatch_method() （kombu.transport.pyamqp.Connection 方法） dispatch_method() （kombu.transport.pyamqp.Connection.Channel 方法） do_restore（kombu.transport.memory.Channel 属性） do_restore（kombu.transport.memory.Transport.Channel 属性） do_restore（kombu.transport.virtual.Channel 属性） domain_format（kombu.transport.SLMQ.Channel 属性） domain_format（kombu.transport.SLMQ.Transport.Channel 属性） drain_consumer()（在 kombu.common 模块中） drain_events() （kombu.Connection 方法） drain_events() （kombu.connection.Connection 方法） drain_events() （kombu.transport.base.Transport 方法） drain_events() （kombu.transport.pyamqp.Connection 方法） drain_events() （kombu.transport.pyamqp.Transport 方法） drain_events() （kombu.transport.qpid.Transport 方法） drain_events() （kombu.transport.virtual.Channel 方法） drain_events() （kombu.transport.virtual.Transport 方法） driver_name（kombu.transport.consul.Transport 属性） driver_name（kombu.transport.etcd.Transport 属性） driver_name（kombu.transport.filesystem.Transport 属性） driver_name（kombu.transport.memory.Transport 属性） driver_name（kombu.transport.mongodb.Transport 属性） driver_name（kombu.transport.pyamqp.Transport 属性） driver_name（kombu.transport.pyro.Transport 属性） driver_name（kombu.transport.qpid.Transport 属性） driver_name（kombu.transport.sqlalchemy.Transport 属性） driver_name（kombu.transport.zookeeper.Transport 属性） driver_type（kombu.transport.consul.Transport 属性） driver_type（kombu.transport.etcd.Transport 属性） driver_type（kombu.transport.filesystem.Transport 属性） driver_type（kombu.transport.memory.Transport 属性） driver_type（kombu.transport.mongodb.Transport 属性） driver_type（kombu.transport.pyamqp.Transport 属性） driver_type（kombu.transport.pyro.Transport 属性） driver_type（kombu.transport.qpid.Transport 属性） driver_type（kombu.transport.sqlalchemy.Transport 属性） driver_type（kombu.transport.zookeeper.Transport 属性） driver_version() （kombu.transport.consul.Transport 方法） driver_version() （kombu.transport.etcd.Transport 方法） driver_version() （kombu.transport.filesystem.Transport 方法） driver_version() （kombu.transport.memory.Transport 方法） driver_version() （kombu.transport.mongodb.Transport 方法） driver_version() （kombu.transport.pyamqp.Transport 方法） driver_version() （kombu.transport.pyro.Transport 方法） driver_version() （kombu.transport.sqlalchemy.Transport 方法） driver_version() （kombu.transport.zookeeper.Transport 方法） DummyLock（kombu.asynchronous.semaphore 中的类） dump() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） dumps()（在 kombu.serialization 模块中） dumps()（在 kombu.utils.json 模块中） durable（kombu.compat.Consumer 属性） durable（kombu.compat.Publisher 属性） durable（kombu.Exchange 属性） durable（kombu.Queue 属性）, [1]

E

effective_url（kombu.asynchronous.http.base.Response 属性）, [1] effective_url（kombu.asynchronous.http.Response 属性）, [1] emergency_dump_state()（在 kombu.utils.div 模块中） enable_insecure_serializers()（在 kombu 模块中） encode() （kombu.asynchronous.aws.sqs.message.AsyncMessage 方法） encode_body() （kombu.transport.qpid.Channel 方法） encode_body() （kombu.transport.qpid.Connection.Channel 方法） encode_body() （kombu.transport.qpid.Transport.Connection.Channel 方法） encoders()（在 kombu.compression 模块中） endheaders() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection 方法） ensure() （kombu.Connection 方法） ensure() （kombu.connection.Connection 方法） ensure_bytes()（在 kombu.utils.encoding 模块中） ensure_connection() （kombu.Connection 方法） ensure_connection() （kombu.connection.Connection 方法） enter_after() （kombu.asynchronous.timer.Timer 方法） enter_at() （kombu.asynchronous.timer.Timer 方法） entity_name() （kombu.transport.SLMQ.Channel 方法） entity_name() （kombu.transport.SLMQ.Transport.Channel 方法） entrypoints()（在 kombu.utils.compat 模块中） Entry（kombu.asynchronous.timer 中的类） eqhash()（在 kombu.utils.collections 模块中） EqualityDict（kombu.utils.collections 中的类） equivalent() （kombu.transport.virtual.exchange.ExchangeType 方法） error() （kombu.log.LogMixin 方法） errors（kombu.message.Message 属性） errors（kombu.transport.pyamqp.Connection.Channel.Message 属性） errors（kombu.transport.virtual.Message 属性） error（kombu.asynchronous.http.base.Response 属性）, [1] error（kombu.asynchronous.http.Response 属性）, [1] ERR（kombu.asynchronous.Hub 属性） ERR（kombu.asynchronous.hub.Hub 属性） escape_regex()（在 kombu.utils.text 模块中） establish_connection() （kombu.mixins.ConsumerMixin 方法） establish_connection() （kombu.transport.base.Transport 方法） establish_connection() （kombu.transport.pyamqp.Transport 方法）

establish_connection() （kombu.transport.qpid.Transport 方法） establish_connection() （kombu.transport.virtual.Transport 方法） evaluate() （kombu.utils.functional.lazy 方法） eventloop()（在 kombu.common 模块中） events（kombu.transport.memory.Channel 属性） events（kombu.transport.memory.Transport.Channel 属性） exchange_bind() （kombu.transport.pyamqp.Connection.Channel 方法） exchange_declare() （kombu.transport.pyamqp.Connection.Channel 方法） exchange_declare() （kombu.transport.qpid.Channel 方法） exchange_declare() （kombu.transport.qpid.Connection.Channel 方法） exchange_declare() （kombu.transport.qpid.Transport.Connection.Channel 方法） exchange_declare() （kombu.transport.virtual.Channel 方法） exchange_delete() （kombu.transport.pyamqp.Connection.Channel 方法） exchange_delete() （kombu.transport.qpid.Channel 方法） exchange_delete() （kombu.transport.qpid.Connection.Channel 方法） exchange_delete() （kombu.transport.qpid.Transport.Connection.Channel 方法） exchange_delete() （kombu.transport.virtual.Channel 方法） exchange_opts（kombu.simple.SimpleBuffer 属性） exchange_opts（kombu.simple.SimpleQueue 属性） exchange_types（kombu.transport.virtual.Channel 属性） exchange_type（kombu.compat.Consumer 属性） exchange_type（kombu.compat.Publisher 属性） exchange_unbind() （kombu.transport.pyamqp.Connection.Channel 方法） exchanges（kombu.transport.virtual.BrokerState 属性） ExchangeType（kombu.transport.virtual.exchange 中的类） Exchange（kombu 中的类） exchange（kombu.compat.Consumer 属性） exchange（kombu.compat.Publisher 属性） exchange（kombu.pidbox.Mailbox 属性） exchange（kombu.pools.ProducerPool.Producer 属性） exchange（kombu.Producer 属性） exchange（kombu.Queue 属性）, [1] exclusive（kombu.compat.Consumer 属性） exclusive（kombu.Queue 属性）, [1] expected_time() （kombu.utils.limits.TokenBucket 方法） expires（kombu.Queue 属性） extra_context() （kombu.mixins.ConsumerMixin 方法）

F

failover_strategies（kombu.connection.Connection 属性） failover_strategy（kombu.Connection 属性） failover_strategy（kombu.connection.Connection 属性） FairCycle（kombu.utils.scheduling 中的类） FanoutExchange（kombu.transport.virtual.exchange 中的类） fetch() （kombu.compat.Consumer 方法） fileno()（在 kombu.utils.compat 模块中） fill_rate（kombu.utils.limits.TokenBucket 属性） fire_timers() （kombu.asynchronous.Hub 方法） fire_timers() （kombu.asynchronous.hub.Hub 方法） flow() （kombu.compat.Consumer 方法） flow() （kombu.compat.ConsumerSet 方法） flow() （kombu.Consumer 方法） flow() （kombu.transport.pyamqp.Connection.Channel 方法） flow() （kombu.transport.virtual.Channel 方法）

fmatch_best()（在 kombu.utils.text 模块中） fmatch_iter()（在 kombu.utils.text 模块中） follow_redirects（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） follow_redirects（kombu.asynchronous.http.base.Request 属性） follow_redirects（kombu.asynchronous.http.Request 属性） force_close_all() （kombu.connection.ChannelPool 方法） force_close_all() （kombu.connection.ConnectionPool 方法） force_close_all() （kombu.resource.Resource 方法） forward() （kombu.clocks.LamportClock 方法） frame_writer（kombu.transport.pyamqp.Connection 属性） from_dict()（kombu.Queue 类方法） from_transport_options（kombu.transport.mongodb.Channel 属性） from_transport_options（kombu.transport.mongodb.Transport.Channel 属性） from_utf8()（在 kombu.utils.encoding 模块中） fun（kombu.asynchronous.timer.Entry 属性） fun（kombu.asynchronous.timer.Timer.Entry 属性）

G

get() （kombu.Queue 方法） get() （kombu.simple.SimpleBuffer 方法） get() （kombu.simple.SimpleQueue 方法） get() （kombu.transport.qpid.Channel.QoS 方法） get() （kombu.transport.qpid.Connection.Channel.QoS 方法） get() （kombu.transport.qpid.Transport.Connection.Channel.QoS 方法） get() （kombu.transport.virtual.QoS 方法） get() （kombu.utils.scheduling.FairCycle 方法） get_all_queues() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） get_attributes() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） get_bindings() （kombu.transport.pyamqp.Connection.Channel 方法） get_consumers() （kombu.mixins.ConsumerMixin 方法） get_dead_letter_source_queues() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） get_decoder()（在 kombu.compression 模块中） get_default_encoding_file()（在 kombu.utils.encoding 模块中） get_encoder()（在 kombu.compression 模块中） get_event_loop()（在 kombu.asynchronous 模块中） get_event_loop()（在 kombu.asynchronous.hub 模块中） get_heartbeat_interval() （kombu.connection.Connection 方法） get_heartbeat_interval() （kombu.transport.pyamqp.Transport 方法） get_http_connection() （kombu.asynchronous.aws.connection.AsyncConnection 方法） get_limit()（在 kombu.pools 模块中） get_logger() （kombu.log.LogMixin 方法） get_loglevel() （kombu.log.LogMixin 方法） get_loglevel()（在 kombu.log 模块中） get_manager() （kombu.Connection 方法） get_manager() （kombu.connection.Connection 方法） get_manager() （kombu.transport.pyamqp.Transport 方法）

get_manager()（在 kombu.utils.amq_manager 模块中） get_messages() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） get_now() （kombu.transport.mongodb.Channel 方法） get_now() （kombu.transport.mongodb.Transport.Channel 方法） get_nowait() （kombu.simple.SimpleBuffer 方法） get_nowait() （kombu.simple.SimpleQueue 方法） get_qpid_connection() （kombu.transport.qpid.Connection 方法） get_qpid_connection() （kombu.transport.qpid.Transport.Connection 方法） get_queue() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） get_queue() （kombu.pidbox.Mailbox 方法） get_queue_attributes() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） get_queue_url() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） get_reply_queue() （kombu.pidbox.Mailbox 方法） get_table() （kombu.transport.filesystem.Channel 方法） get_table() （kombu.transport.filesystem.Transport.Channel 方法） get_table() （kombu.transport.mongodb.Channel 方法） get_table() （kombu.transport.mongodb.Transport.Channel 方法） get_table() （kombu.transport.virtual.Channel 方法） get_timeout() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） get_transport_cls() （kombu.Connection 方法） get_transport_cls() （kombu.connection.Connection 方法） get_transport_cls()（在 kombu.transport 模块中） getrequest() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection 方法） getresponse() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection 方法） global_state（kombu.transport.filesystem.Transport 属性） global_state（kombu.transport.memory.Transport 属性） global_state（kombu.transport.pyro.Transport 属性） grow() （kombu.asynchronous.semaphore.LaxBoundedSemaphore 方法）

H

handle() （kombu.pidbox.Node 方法） handle_call() （kombu.pidbox.Node 方法） handle_cast() （kombu.pidbox.Node 方法） handle_error() （kombu.asynchronous.timer.Timer 方法） handle_message() （kombu.pidbox.Node 方法） handler() （kombu.pidbox.Node 方法） handlers（kombu.pidbox.Node 属性） has_binding() （kombu.transport.virtual.BrokerState 方法） HashedSeq（kombu.utils.collections 中的类） hashvalue（kombu.utils.collections.HashedSeq 属性） headers（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） headers（kombu.asynchronous.aws.sqs.message.AsyncMessage 属性） headers（kombu.asynchronous.aws.sqs.message.AsyncRawMessage 属性） headers（kombu.asynchronous.aws.sqs.message.BaseAsyncMessage 属性） Headers（kombu.asynchronous.http 中的类） Headers（kombu.asynchronous.http.base 中的类） headers（kombu.asynchronous.http.base.Request 属性） headers（kombu.asynchronous.http.base.Response 属性）, [1] headers（kombu.asynchronous.http.Request 属性） headers（kombu.asynchronous.http.Response 属性）, [1] headers（kombu.message.Message 属性） headers（kombu.transport.base.Message 属性） headers（kombu.transport.pyamqp.Channel.Message 属性）

headers（kombu.transport.pyamqp.Connection.Channel.Message 属性） headers（kombu.transport.pyamqp.Message 属性） headers（kombu.transport.pyamqp.Transport.Connection.Channel.Message 属性） headers（kombu.transport.qpid.Channel.Message 属性） headers（kombu.transport.qpid.Connection.Channel.Message 属性） headers（kombu.transport.qpid.Message 属性） headers（kombu.transport.qpid.Transport.Connection.Channel.Message 属性） headers（kombu.transport.virtual.Message 属性） heartbeat_check() （kombu.Connection 方法） heartbeat_check() （kombu.connection.Connection 方法） heartbeat_check() （kombu.transport.pyamqp.Transport 方法） heartbeat_tick() （kombu.transport.pyamqp.Connection 方法） heartbeat（kombu.Connection 属性） heartbeat（kombu.connection.Connection 属性） heartbeat（kombu.transport.pyamqp.Connection 属性） hostname（kombu.Connection 属性） hostname（kombu.connection.Connection 属性） hostname（kombu.pidbox.Node 属性） hostname（kombu.utils.url.urlparts 属性） host（kombu.Connection 属性） host（kombu.connection.Connection 属性） Hub（kombu.asynchronous 中的类） Hub（kombu.asynchronous.hub 中的类）

I

id（kombu.clocks.timetuple 属性） id（kombu.transport.sqlalchemy.models.Message 属性） id（kombu.transport.sqlalchemy.models.Queue 属性） implements（kombu.transport.etcd.Transport 属性） implements（kombu.transport.filesystem.Transport 属性） implements（kombu.transport.memory.Transport 属性） implements（kombu.transport.mongodb.Transport 属性） implements（kombu.transport.pyamqp.Transport 属性） implements（kombu.transport.qpid.Transport 属性） incr() （kombu.utils.functional.LRUCache 方法） index（kombu.transport.consul.Channel 属性） index（kombu.transport.consul.Transport.Channel 属性） index（kombu.transport.etcd.Channel 属性） index（kombu.transport.etcd.Transport.Channel 属性） info() （kombu.Connection 方法） info() （kombu.connection.Connection 方法） info() （kombu.log.LogMixin 方法） insured()（在 kombu.common 模块中）

is_alive() （kombu.transport.pyamqp.Connection 方法） is_bound（kombu.abstract.MaybeChannelBound 属性） is_closing（kombu.transport.pyamqp.Channel 属性） is_closing（kombu.transport.pyamqp.Connection 属性） is_closing（kombu.transport.pyamqp.Connection.Channel 属性） is_closing（kombu.transport.pyamqp.Transport.Connection 属性） is_closing（kombu.transport.pyamqp.Transport.Connection.Channel 属性） is_enabled_for() （kombu.log.LogMixin 方法） is_evented（kombu.Connection 属性） is_evented（kombu.connection.Connection 属性） is_list()（在 kombu.utils.functional 模块中） items() （kombu.utils.functional.LRUCache 方法） iterconsume() （kombu.compat.Consumer 方法） iterconsume() （kombu.compat.ConsumerSet 方法） iteritems() （kombu.utils.functional.LRUCache 方法） iterkeys() （kombu.utils.functional.LRUCache 方法） itermessages()（在 kombu.common 模块中） iterqueue() （kombu.compat.Consumer 方法） itervalues() （kombu.utils.functional.LRUCache 方法）

J

JSONEncoder（kombu.utils.json 中的类）

K

key_to_pattern() （kombu.transport.virtual.exchange.TopicExchange 方法） keys() （kombu.utils.functional.LRUCache 方法） kombu 模块 kombu.abstract 模块 kombu.asynchronous 模块 kombu.asynchronous.aws 模块 kombu.asynchronous.aws.connection 模块 kombu.asynchronous.aws.sqs 模块 kombu.asynchronous.aws.sqs.connection 模块 kombu.asynchronous.aws.sqs.message 模块 kombu.asynchronous.aws.sqs.queue 模块 kombu.asynchronous.debug 模块 kombu.asynchronous.http 模块 kombu.asynchronous.http.base 模块 kombu.asynchronous.http.curl 模块 kombu.asynchronous.hub 模块 kombu.asynchronous.semaphore 模块 kombu.asynchronous.timer 模块 kombu.clocks 模块 kombu.common 模块 kombu.compat 模块 kombu.compression 模块 kombu.connection 模块 kombu.exceptions 模块 kombu.log 模块 kombu.matcher 模块 kombu.message 模块 kombu.mixins 模块 kombu.pidbox 模块 kombu.pools 模块 kombu.resource 模块 kombu.serialization 模块 kombu.simple 模块 kombu.transport 模块 kombu.transport.base 模块

kombu.transport.consul 模块 kombu.transport.etcd 模块 kombu.transport.filesystem 模块 kombu.transport.memory 模块 kombu.transport.mongodb 模块 kombu.transport.pyamqp 模块 kombu.transport.pyro 模块 kombu.transport.qpid 模块 kombu.transport.SLMQ 模块 kombu.transport.sqlalchemy 模块 kombu.transport.sqlalchemy.models 模块 kombu.transport.virtual 模块 kombu.transport.virtual.exchange 模块 kombu.transport.zookeeper 模块 kombu.utils.amq_manager 模块 kombu.utils.collections 模块 kombu.utils.compat 模块 kombu.utils.debug 模块 kombu.utils.div 模块 kombu.utils.encoding 模块 kombu.utils.eventio 模块 kombu.utils.functional 模块 kombu.utils.imports 模块 kombu.utils.json 模块 kombu.utils.limits 模块 kombu.utils.objects 模块 kombu.utils.scheduling 模块 kombu.utils.text 模块 kombu.utils.time 模块 kombu.utils.url 模块 kombu.utils.uuid 模块 KOMBU_LOG_CHANNEL KOMBU_LOG_CONNECTION, [1] KOMBU_LOG_DEBUG, [1], [2] kwargs（kombu.asynchronous.timer.Entry 属性） kwargs（kombu.asynchronous.timer.Timer.Entry 属性）

L

LamportClock（kombu.clocks 中的类） last_heartbeat_received（kombu.transport.pyamqp.Connection 属性） last_heartbeat_sent（kombu.transport.pyamqp.Connection 属性） LaxBoundedSemaphore（kombu.asynchronous.semaphore 中的类） lazy（kombu.utils.functional 中的类） library_properties（kombu.transport.pyamqp.Connection 属性） LifoQueue（kombu.resource 中的类） LimitExceeded LimitExceeded（kombu.connection.ChannelPool 属性） LimitExceeded（kombu.connection.ConnectionPool 属性） limit（kombu.resource.Resource 属性） list_first()（在 kombu.asynchronous.aws.sqs.queue 模块中） listen() （kombu.pidbox.Node 方法） load() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） load_from_file() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） load_from_filename() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） load_from_s3() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） loads()（在 kombu.serialization 模块中） loads()（在 kombu.utils.json 模块中） lock_name（kombu.transport.consul.Channel 属性）

lock_name（kombu.transport.consul.Transport.Channel 属性） lock_ttl（kombu.transport.etcd.Channel 属性） lock_ttl（kombu.transport.etcd.Transport.Channel 属性） lock_value（kombu.transport.etcd.Channel 属性） lock_value（kombu.transport.etcd.Transport.Channel 属性） log() （kombu.log.LogMixin 方法） logger_name（kombu.log.LogMixin 属性） logger（kombu.log.LogMixin 属性） login_method（kombu.Connection 属性） login_method（kombu.connection.Connection 属性） LogMixin（kombu.log 中的类） Logwrapped（kombu.utils.debug 中的类） lookup() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） lookup() （kombu.transport.virtual.exchange.DirectExchange 方法） lookup() （kombu.transport.virtual.exchange.ExchangeType 方法） lookup() （kombu.transport.virtual.exchange.FanoutExchange 方法） lookup() （kombu.transport.virtual.exchange.TopicExchange 方法） loop（kombu.asynchronous.Hub 属性） loop（kombu.asynchronous.hub.Hub 属性） LRUCache（kombu.utils.functional 中的类）

M

Mailbox（kombu.pidbox 中的类） mailbox（kombu.pidbox.Node 属性） manager（kombu.Connection 属性） manager（kombu.connection.Connection 属性） match() （kombu.matcher.MatcherRegistry 方法） match()（在 kombu.matcher 模块中） matcher_pattern_first（kombu.matcher.MatcherRegistry 属性） MatcherNotInstalled MatcherRegistry.MatcherNotInstalled MatcherRegistry（kombu.matcher 中的类） max_length_bytes（kombu.Queue 属性） max_length（kombu.Queue 属性） max_priority（kombu.Queue 属性） max_redirects（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） max_redirects（kombu.asynchronous.http.base.Request 属性） max_redirects（kombu.asynchronous.http.Request 属性） maybe_bind() （kombu.abstract.MaybeChannelBound 方法） maybe_bind() （kombu.Exchange 方法） maybe_bind() （kombu.Queue 方法） maybe_close_channel() （kombu.Connection 方法） maybe_close_channel() （kombu.connection.Connection 方法） maybe_conn_error() （kombu.mixins.ConsumerMixin 方法） maybe_declare() （kombu.compat.Publisher 方法） maybe_declare() （kombu.pools.ProducerPool.Producer 方法） maybe_declare() （kombu.Producer 方法） maybe_declare()（在 kombu.common 模块中） maybe_evaluate()（在 kombu.utils.functional 模块中） maybe_fileno()（在 kombu.utils.compat 模块中） maybe_list()（在 kombu.utils.functional 模块中） maybe_s_to_ms()（在 kombu.utils.time 模块中） maybe_sanitize_url()（在 kombu.utils.url 模块中） maybe_switch_next() （kombu.Connection 方法） maybe_switch_next() （kombu.connection.Connection 方法）

MaybeChannelBound（kombu.abstract 中的类） memoize()（在 kombu.utils.functional 模块中） Message() （kombu.Exchange 方法） Message.MessageStateError, [1] message_cls（kombu.transport.sqlalchemy.Channel 属性） message_cls（kombu.transport.sqlalchemy.Transport.Channel 属性） message_to_python() （kombu.transport.pyamqp.Channel 方法） message_to_python() （kombu.transport.pyamqp.Connection.Channel 方法） message_to_python() （kombu.transport.pyamqp.Transport.Connection.Channel 方法） message_to_python() （kombu.transport.virtual.Channel 方法） message_ttl（kombu.Queue 属性） messages_collection（kombu.transport.mongodb.Channel 属性） messages_collection（kombu.transport.mongodb.Transport.Channel 属性） MessageStateError messages（kombu.transport.mongodb.Channel 属性） messages（kombu.transport.mongodb.Transport.Channel 属性） Message（kombu.message 中的类） Message（kombu.transport.base 中的类） Message（kombu.transport.pyamqp 中的类） Message（kombu.transport.qpid 中的类） Message（kombu.transport.sqlalchemy.models 中的类） Message（kombu.transport.virtual 中的类） Message（kombu.transport.virtual.Channel 属性） method_queue（kombu.transport.pyamqp.Channel 属性） method_queue（kombu.transport.pyamqp.Connection 属性） method_queue（kombu.transport.pyamqp.Connection.Channel 属性） method_queue（kombu.transport.pyamqp.Transport.Connection 属性） method_queue（kombu.transport.pyamqp.Transport.Connection.Channel 属性） method（kombu.asynchronous.aws.connection.AsyncHTTPSConnection 属性） method（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） method（kombu.asynchronous.http.base.Request 属性） method（kombu.asynchronous.http.Request 属性） multi_call() （kombu.pidbox.Mailbox 方法）

N

namespace（kombu.pidbox.Mailbox 属性） name（kombu.Exchange 属性）, [1] name（kombu.Queue 属性）, [1] name（kombu.transport.sqlalchemy.models.Queue 属性） negotiate_capabilities（kombu.transport.pyamqp.Connection 属性） nested()（在 kombu.utils.compat 模块中） network_interface（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） network_interface（kombu.asynchronous.http.base.Request 属性） network_interface（kombu.asynchronous.http.Request 属性） new() （kombu.pools.ProducerPool 方法） no_ack_consumers（kombu.transport.pyamqp.Connection.Channel 属性）

no_ack（kombu.compat.Consumer 属性） no_ack（kombu.compat.ConsumerSet 属性） no_ack（kombu.Consumer 属性） no_ack（kombu.Queue 属性） no_ack（kombu.simple.SimpleBuffer 属性） no_ack（kombu.simple.SimpleQueue 属性） no_declare（kombu.Exchange 属性） no_declare（kombu.Queue 属性） Node() （kombu.pidbox.Mailbox 方法） Node（kombu.pidbox 中的类） NotBoundError

O

object_hook()（在 kombu.utils.json 模块中） obj（kombu.clocks.timetuple 属性） on_callback_error() （kombu.asynchronous.Hub 方法） on_callback_error() （kombu.asynchronous.hub.Hub 方法） on_close（kombu.asynchronous.Hub 属性） on_close（kombu.asynchronous.hub.Hub 属性） on_connection_error() （kombu.mixins.ConsumerMixin 方法） on_connection_revived() （kombu.mixins.ConsumerMixin 方法） on_consume_end() （kombu.mixins.ConsumerMixin 方法） on_consume_end() （kombu.mixins.ConsumerProducerMixin 方法） on_consume_ready() （kombu.mixins.ConsumerMixin 方法） on_declared（kombu.Queue 属性） on_decode_error() （kombu.mixins.ConsumerMixin 方法） on_decode_error（kombu.compat.Consumer 属性） on_decode_error（kombu.compat.ConsumerSet 属性） on_decode_error（kombu.Consumer 属性） on_error（kombu.asynchronous.timer.Timer 属性） on_header（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） on_header（kombu.asynchronous.http.base.Request 属性） on_header（kombu.asynchronous.http.Request 属性） on_inbound_frame（kombu.transport.pyamqp.Connection 属性） on_inbound_method() （kombu.transport.pyamqp.Connection 方法）

on_iteration() （kombu.mixins.ConsumerMixin 方法） on_message（kombu.compat.Consumer 属性） on_message（kombu.compat.ConsumerSet 属性） on_message（kombu.Consumer 属性） on_prepare（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） on_prepare（kombu.asynchronous.http.base.Request 属性） on_prepare（kombu.asynchronous.http.Request 属性） on_readable() （kombu.asynchronous.http.curl.CurlClient 方法） on_readable() （kombu.transport.qpid.Transport 方法） on_ready（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） on_ready（kombu.asynchronous.http.base.Request 属性） on_ready（kombu.asynchronous.http.Request 属性） on_return（kombu.compat.Publisher 属性） on_return（kombu.pools.ProducerPool.Producer 属性） on_return（kombu.Producer 属性） on_stream（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） on_stream（kombu.asynchronous.http.base.Request 属性） on_stream（kombu.asynchronous.http.Request 属性） on_timeout（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） on_timeout（kombu.asynchronous.http.base.Request 属性） on_timeout（kombu.asynchronous.http.Request 属性） on_writable() （kombu.asynchronous.http.curl.CurlClient 方法） open() （kombu.transport.pyamqp.Connection.Channel 方法）

P

parse_ssl_cert_reqs()（在 kombu.utils.url 模块中） parse_url()（在 kombu.utils.url 模块中） passive（kombu.Exchange 属性） password（kombu.Connection 属性） password（kombu.connection.Connection 属性） password（kombu.utils.url.urlparts 属性） path（kombu.asynchronous.aws.connection.AsyncHTTPSConnection 属性） path（kombu.utils.url.urlparts 属性） payload（kombu.message.Message 属性） payload（kombu.transport.base.Message 属性） payload（kombu.transport.pyamqp.Connection.Channel.Message 属性） payload（kombu.transport.sqlalchemy.models.Message 属性） payload（kombu.transport.virtual.Message 属性） PERSISTENT_DELIVERY_MODE（kombu.Exchange 属性） PICKLE_PROTOCOL, [1] poll()（在 kombu.utils.eventio 模块中） poller（kombu.asynchronous.Hub 属性） poller（kombu.asynchronous.hub.Hub 属性） polling_interval（kombu.transport.etcd.Transport 属性） polling_interval（kombu.transport.mongodb.Transport 属性） polling_interval（kombu.transport.qpid.Transport 属性） polling_interval（kombu.transport.SLMQ.Transport 属性） polling_interval（kombu.transport.virtual.Transport 属性） polling_interval（kombu.transport.zookeeper.Transport 属性） Pool() （kombu.Connection 方法） Pool() （kombu.connection.Connection 方法） PoolGroup（kombu.pools 中的类） pop() （kombu.utils.limits.TokenBucket 方法） popitem() （kombu.utils.functional.LRUCache 方法） port（kombu.Connection 属性） port（kombu.connection.Connection 属性） port（kombu.utils.url.urlparts 属性） prefetch_count（kombu.compat.Consumer 属性） prefetch_count（kombu.compat.ConsumerSet 属性） prefetch_count（kombu.transport.virtual.QoS 属性） prefix（kombu.transport.consul.Channel 属性） prefix（kombu.transport.consul.Transport.Channel 属性） prefix（kombu.transport.etcd.Channel 属性） prefix（kombu.transport.etcd.Transport.Channel 属性） prepare() （kombu.pools.ProducerPool 方法） prepare() （kombu.resource.Resource 方法） prepare_bind() （kombu.transport.virtual.exchange.ExchangeType 方法） prepare_bind() （kombu.transport.virtual.exchange.TopicExchange 方法） prepare_message() （kombu.transport.pyamqp.Channel 方法） prepare_message() （kombu.transport.pyamqp.Connection.Channel 方法） prepare_message() （kombu.transport.pyamqp.Transport.Connection.Channel 方法） prepare_message() （kombu.transport.qpid.Channel 方法） prepare_message() （kombu.transport.qpid.Connection.Channel 方法） prepare_message() （kombu.transport.qpid.Transport.Connection.Channel 方法） prepare_message() （kombu.transport.virtual.Channel 方法） prepare_queue_arguments() （kombu.transport.mongodb.Channel 方法） prepare_queue_arguments() （kombu.transport.mongodb.Transport.Channel 方法） prepare_queue_arguments() （kombu.transport.pyamqp.Channel 方法） prepare_queue_arguments() （kombu.transport.pyamqp.Connection.Channel 方法） prepare_queue_arguments() （kombu.transport.pyamqp.Transport.Connection.Channel 方法）

prev_recv（kombu.transport.pyamqp.Connection 属性） prev_sent（kombu.transport.pyamqp.Connection 属性） priority_cycle（kombu.utils.scheduling 中的类） process_next() （kombu.compat.Consumer 方法） processed_folder（kombu.transport.filesystem.Channel 属性） processed_folder（kombu.transport.filesystem.Transport.Channel 属性） Producer() （kombu.Connection 方法） Producer() （kombu.connection.Connection 方法） Producer() （kombu.transport.pyamqp.Connection.Channel 方法） producer_connection（kombu.mixins.ConsumerProducerMixin 属性） ProducerPool.Producer（kombu.pools 中的类） ProducerPool（kombu.pools 中的类） Producer（kombu 中的类） producer（kombu.mixins.ConsumerProducerMixin 属性） producer（kombu.simple.SimpleBuffer 属性） producer（kombu.simple.SimpleQueue 属性） properties（kombu.asynchronous.aws.sqs.message.AsyncMessage 属性） properties（kombu.asynchronous.aws.sqs.message.AsyncRawMessage 属性） properties（kombu.asynchronous.aws.sqs.message.BaseAsyncMessage 属性） properties（kombu.message.Message 属性） properties（kombu.transport.base.Message 属性） properties（kombu.transport.pyamqp.Channel.Message 属性） properties（kombu.transport.pyamqp.Connection.Channel.Message 属性） properties（kombu.transport.pyamqp.Message 属性） properties（kombu.transport.pyamqp.Transport.Connection.Channel.Message 属性） properties（kombu.transport.qpid.Channel.Message 属性） properties（kombu.transport.qpid.Connection.Channel.Message 属性） properties（kombu.transport.qpid.Message 属性） properties（kombu.transport.qpid.Transport.Connection.Channel.Message 属性） properties（kombu.transport.virtual.Message 属性） proxy_host（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） proxy_host（kombu.asynchronous.http.base.Request 属性） proxy_host（kombu.asynchronous.http.Request 属性） proxy_password（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） proxy_password（kombu.asynchronous.http.base.Request 属性） proxy_password（kombu.asynchronous.http.Request 属性） proxy_port（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） proxy_port（kombu.asynchronous.http.base.Request 属性） proxy_port（kombu.asynchronous.http.Request 属性） proxy_username（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） proxy_username（kombu.asynchronous.http.base.Request 属性） proxy_username（kombu.asynchronous.http.Request 属性） publish() （kombu.compat.Publisher 方法） publish() （kombu.Exchange 方法） publish() （kombu.pools.ProducerPool.Producer 方法） publish() （kombu.Producer 方法） Publisher（kombu.compat 中的类） purge() （kombu.compat.Consumer 方法） purge() （kombu.compat.ConsumerSet 方法） purge() （kombu.Consumer 方法） purge() （kombu.Queue 方法） put() （kombu.simple.SimpleBuffer 方法） put() （kombu.simple.SimpleQueue 方法） putheader() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection 方法） putrequest() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection 方法）

Q

qos() （kombu.compat.Consumer 方法） qos() （kombu.compat.ConsumerSet 方法） qos() （kombu.Consumer 方法） qos_semantics_matches_spec() （kombu.transport.pyamqp.Transport 方法） qos_semantics_matches_spec（kombu.connection.Connection 属性） qos（kombu.transport.qpid.Channel 属性） qos（kombu.transport.qpid.Connection.Channel 属性） qos（kombu.transport.qpid.Transport.Connection.Channel 属性） QoS（kombu.transport.virtual 中的类） qos（kombu.transport.virtual.Channel 属性） qsize() （kombu.simple.SimpleBuffer 方法） qsize() （kombu.simple.SimpleQueue 方法） query（kombu.utils.url.urlparts 属性） Queue.ContentDisallowed queue_arguments（kombu.Queue 属性） queue_bind() （kombu.Queue 方法） queue_bind() （kombu.transport.pyamqp.Connection.Channel 方法） queue_bind() （kombu.transport.qpid.Channel 方法） queue_bind() （kombu.transport.qpid.Connection.Channel 方法） queue_bind() （kombu.transport.qpid.Transport.Connection.Channel 方法） queue_bind() （kombu.transport.virtual.Channel 方法） queue_bindings() （kombu.transport.virtual.BrokerState 方法） queue_bindings_delete() （kombu.transport.virtual.BrokerState 方法） queue_cls（kombu.transport.sqlalchemy.Channel 属性） queue_cls（kombu.transport.sqlalchemy.Transport.Channel 属性） queue_declare() （kombu.Queue 方法） queue_declare() （kombu.transport.pyamqp.Connection.Channel 方法） queue_declare() （kombu.transport.qpid.Channel 方法） queue_declare() （kombu.transport.qpid.Connection.Channel 方法） queue_declare() （kombu.transport.qpid.Transport.Connection.Channel 方法） queue_declare() （kombu.transport.virtual.Channel 方法） queue_delete() （kombu.transport.mongodb.Channel 方法） queue_delete() （kombu.transport.mongodb.Transport.Channel 方法） queue_delete() （kombu.transport.pyamqp.Connection.Channel 方法） queue_delete() （kombu.transport.qpid.Channel 方法）

queue_delete() （kombu.transport.qpid.Connection.Channel 方法） queue_delete() （kombu.transport.qpid.Transport.Connection.Channel 方法） queue_delete() （kombu.transport.virtual.Channel 方法） queue_index（kombu.transport.virtual.BrokerState 属性） queue_name_prefix（kombu.transport.SLMQ.Channel 属性） queue_name_prefix（kombu.transport.SLMQ.Transport.Channel 属性） queue_opts（kombu.simple.SimpleBuffer 属性） queue_opts（kombu.simple.SimpleQueue 属性） queue_purge() （kombu.transport.pyamqp.Connection.Channel 方法） queue_purge() （kombu.transport.qpid.Channel 方法） queue_purge() （kombu.transport.qpid.Connection.Channel 方法） queue_purge() （kombu.transport.qpid.Transport.Connection.Channel 方法） queue_purge() （kombu.transport.virtual.Channel 方法） queue_unbind() （kombu.Queue 方法） queue_unbind() （kombu.transport.pyamqp.Connection.Channel 方法） queue_unbind() （kombu.transport.qpid.Channel 方法） queue_unbind() （kombu.transport.qpid.Connection.Channel 方法） queue_unbind() （kombu.transport.qpid.Transport.Connection.Channel 方法） queues() （kombu.transport.pyro.Channel 方法） queues() （kombu.transport.pyro.Transport.Channel 方法） queues_collection（kombu.transport.mongodb.Channel 属性） queues_collection（kombu.transport.mongodb.Transport.Channel 属性） queues（kombu.compat.Consumer 属性） queues（kombu.compat.ConsumerSet 属性） queues（kombu.Consumer 属性） queues（kombu.transport.memory.Channel 属性） queues（kombu.transport.memory.Transport.Channel 属性） queues（kombu.transport.mongodb.Channel 属性） queues（kombu.transport.mongodb.Transport.Channel 属性） Queue（kombu 中的类） queue（kombu.asynchronous.timer.Timer 属性） queue（kombu.compat.Consumer 属性） queue（kombu.simple.SimpleBuffer 属性） queue（kombu.simple.SimpleQueue 属性） Queue（kombu.transport.sqlalchemy.models 中的类）

R

raise_for_error() （kombu.asynchronous.http.base.Response 方法） raise_for_error() （kombu.asynchronous.http.Response 方法） raw_encode()（在 kombu.serialization 模块中） read() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） READ（kombu.asynchronous.Hub 属性） READ（kombu.asynchronous.hub.Hub 属性） receive() （kombu.compat.Consumer 方法） receive() （kombu.compat.ConsumerSet 方法） receive() （kombu.Consumer 方法） receive_message() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） recover() （kombu.compat.Consumer 方法） recover() （kombu.compat.ConsumerSet 方法） recover() （kombu.Consumer 方法） recoverable_channel_errors（kombu.Connection 属性） recoverable_channel_errors（kombu.connection.Connection 属性） recoverable_channel_errors（kombu.transport.base.Transport 属性） recoverable_channel_errors（kombu.transport.pyamqp.Connection 属性） recoverable_channel_errors（kombu.transport.pyamqp.Transport 属性） recoverable_channel_errors（kombu.transport.qpid.Transport 属性） recoverable_connection_errors（kombu.Connection 属性） recoverable_connection_errors（kombu.connection.Connection 属性） recoverable_connection_errors（kombu.transport.base.Transport 属性） recoverable_connection_errors（kombu.transport.pyamqp.Connection 属性） recoverable_connection_errors（kombu.transport.pyamqp.Transport 属性） recoverable_connection_errors（kombu.transport.qpid.Transport 属性） register() （kombu.matcher.MatcherRegistry 方法） register()（在 kombu.compression 模块中） register()（在 kombu.matcher 模块中） register()（在 kombu.serialization 模块中） register_callback() （kombu.compat.Consumer 方法） register_callback() （kombu.compat.ConsumerSet 方法） register_callback() （kombu.Consumer 方法） register_glob()（在 kombu.matcher 模块中） register_group()（在 kombu.pools 模块中） register_pcre()（在 kombu.matcher 模块中） register_type()（在 kombu.utils.json 模块中） register_with_event_loop() （kombu.Connection 方法） register_with_event_loop() （kombu.connection.Connection 方法） register_with_event_loop() （kombu.transport.pyamqp.Transport 方法） register_with_event_loop() （kombu.transport.qpid.Transport 方法） registry()（在 kombu.matcher 模块中） registry()（在 kombu.serialization 模块中） reject() （kombu.message.Message 方法） reject() （kombu.transport.base.Message 方法） reject() （kombu.transport.pyamqp.Connection.Channel.Message 方法） reject() （kombu.transport.qpid.Channel.QoS 方法） reject() （kombu.transport.qpid.Connection.Channel.QoS 方法） reject() （kombu.transport.qpid.Transport.Connection.Channel.QoS 方法） reject() （kombu.transport.virtual.Message 方法） reject() （kombu.transport.virtual.QoS 方法） reject_log_error() （kombu.message.Message 方法） reject_log_error() （kombu.transport.pyamqp.Connection.Channel.Message 方法） reject_log_error() （kombu.transport.virtual.Message 方法） release() （kombu.asynchronous.semaphore.LaxBoundedSemaphore 方法） release() （kombu.compat.Publisher 方法） release() （kombu.Connection 方法） release() （kombu.connection.ChannelPool 方法） release() （kombu.connection.Connection 方法） release() （kombu.connection.ConnectionPool 方法） release() （kombu.pools.ProducerPool 方法） release() （kombu.pools.ProducerPool.Producer 方法） release() （kombu.resource.Resource 方法） release_resource() （kombu.resource.Resource 方法） remove() （kombu.asynchronous.Hub 方法） remove() （kombu.asynchronous.hub.Hub 方法） remove_permission() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） remove_permission() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） remove_reader() （kombu.asynchronous.Hub 方法） remove_reader() （kombu.asynchronous.hub.Hub 方法）

remove_writer() （kombu.asynchronous.Hub 方法） remove_writer() （kombu.asynchronous.hub.Hub 方法） replace() （kombu.resource.Resource 方法） reply() （kombu.pidbox.Node 方法） reply_exchange（kombu.pidbox.Mailbox 属性） repr_active() （kombu.asynchronous.Hub 方法） repr_active() （kombu.asynchronous.hub.Hub 方法） repr_active()（在 kombu.asynchronous.debug 模块中） repr_events() （kombu.asynchronous.Hub 方法） repr_events() （kombu.asynchronous.hub.Hub 方法） repr_events()（在 kombu.asynchronous.debug 模块中） repr_flag()（在 kombu.asynchronous.debug 模块中） repr_readers()（在 kombu.asynchronous.debug 模块中） repr_writers()（在 kombu.asynchronous.debug 模块中） request() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection 方法） request_timeout（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） request_timeout（kombu.asynchronous.http.base.Request 属性） request_timeout（kombu.asynchronous.http.Request 属性） Request（kombu.asynchronous.http 中的类） Request（kombu.asynchronous.http.base 中的类） request（kombu.asynchronous.http.base.Response 属性）, [1] request（kombu.asynchronous.http.Response 属性）, [1] requeue() （kombu.message.Message 方法） requeue() （kombu.transport.base.Message 方法） requeue() （kombu.transport.pyamqp.Connection.Channel.Message 方法） requeue() （kombu.transport.virtual.Message 方法） reset() （kombu.asynchronous.Hub 方法） reset() （kombu.asynchronous.hub.Hub 方法） reset()（在 kombu.pools 模块中） resize() （kombu.resource.Resource 方法） resolve_aliases（kombu.connection.Connection 属性） resolve_transport()（在 kombu.transport 模块中） Resource.LimitExceeded Resource（kombu.resource 中的类） Response（kombu.asynchronous.aws.connection.AsyncHTTPSConnection 属性） Response（kombu.asynchronous.http 中的类） Response（kombu.asynchronous.http.base 中的类） restart_limit（kombu.mixins.ConsumerMixin 属性） restore_at_shutdown（kombu.transport.virtual.QoS 属性） restore_unacked() （kombu.transport.virtual.QoS 方法） restore_unacked_once() （kombu.transport.virtual.QoS 方法） restore_visible() （kombu.transport.virtual.QoS 方法） retry_over_time()（在 kombu.utils.functional 模块中） revive() （kombu.abstract.MaybeChannelBound 方法） revive() （kombu.compat.Consumer 方法） revive() （kombu.compat.ConsumerSet 方法） revive() （kombu.compat.Publisher 方法） revive() （kombu.Connection 方法） revive() （kombu.connection.Connection 方法） revive() （kombu.Consumer 方法） revive() （kombu.pools.ProducerPool.Producer 方法） revive() （kombu.Producer 方法） rotate() （kombu.utils.scheduling.priority_cycle 方法） rotate() （kombu.utils.scheduling.round_robin_cycle 方法） round_robin_cycle（kombu.utils.scheduling 中的类） routing_collection（kombu.transport.mongodb.Channel 属性） routing_collection（kombu.transport.mongodb.Transport.Channel 属性） routing_key（kombu.compat.Consumer 属性） routing_key（kombu.compat.Publisher 属性） routing_key（kombu.pools.ProducerPool.Producer 属性） routing_key（kombu.Producer 属性） routing_key（kombu.Queue 属性）, [1] routing（kombu.transport.mongodb.Channel 属性） routing（kombu.transport.mongodb.Transport.Channel 属性） run() （kombu.mixins.ConsumerMixin 方法） run_forever() （kombu.asynchronous.Hub 方法） run_forever() （kombu.asynchronous.hub.Hub 方法） run_once() （kombu.asynchronous.Hub 方法） run_once() （kombu.asynchronous.hub.Hub 方法）

S

safe_repr()（在 kombu.utils.encoding 模块中） safe_str()（在 kombu.utils.encoding 模块中） sanitize_url()（在 kombu.utils.url 模块中） save() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） save_to_file() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） save_to_filename() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） save_to_s3() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） scheduler（kombu.asynchronous.Hub 属性） scheduler（kombu.asynchronous.hub.Hub 属性） schedule（kombu.asynchronous.timer.Timer 属性） scheme（kombu.utils.url.urlparts 属性） send() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection 方法） send() （kombu.compat.Publisher 方法） send_heartbeat() （kombu.transport.pyamqp.Connection 方法） send_message() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） send_message_batch() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） send_method() （kombu.transport.pyamqp.Connection 方法） send_method() （kombu.transport.pyamqp.Connection.Channel 方法） send_reply()（在 kombu.common 模块中） sent_at（kombu.transport.sqlalchemy.models.Message 属性） serializable() （kombu.transport.qpid.Channel.Message 方法） serializable() （kombu.transport.qpid.Connection.Channel.Message 方法） serializable() （kombu.transport.qpid.Message 方法） serializable() （kombu.transport.qpid.Transport.Connection.Channel.Message 方法） serializable() （kombu.transport.virtual.Message 方法） SerializerNotInstalled serializer（kombu.compat.Publisher 属性） serializer（kombu.pools.ProducerPool.Producer 属性） serializer（kombu.Producer 属性） server_capabilities（kombu.transport.pyamqp.Connection 属性） server_heartbeat（kombu.transport.pyamqp.Connection 属性） session_ttl（kombu.transport.consul.Channel 属性） session_ttl（kombu.transport.consul.Transport.Channel 属性） session_ttl（kombu.transport.etcd.Channel 属性） session_ttl（kombu.transport.etcd.Transport.Channel 属性） session（kombu.transport.sqlalchemy.Channel 属性） session（kombu.transport.sqlalchemy.Transport.Channel 属性） set_attribute() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） set_debuglevel() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection 方法） set_default_encoding_file()（在 kombu.utils.encoding 模块中） set_event_loop()（在 kombu.asynchronous 模块中） set_event_loop()（在 kombu.asynchronous.hub 模块中） set_limit()（在 kombu.pools 模块中） set_queue_attribute() （kombu.asynchronous.aws.sqs.connection.AsyncSQSConnection 方法） set_timeout() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） setter() （kombu.utils.objects.cached_property 方法） setup() （kombu.pools.ProducerPool 方法）

setup() （kombu.resource.Resource 方法） setup_logging()（在 kombu.log 模块中） setup_logging()（在 kombu.utils.debug 模块中） shared_queues（kombu.transport.pyro.Channel 属性） shared_queues（kombu.transport.pyro.Transport 属性） shared_queues（kombu.transport.pyro.Transport.Channel 属性） should_stop（kombu.mixins.ConsumerMixin 属性） shrink() （kombu.asynchronous.semaphore.LaxBoundedSemaphore 方法） SimpleBuffer() （kombu.Connection 方法） SimpleBuffer() （kombu.connection.Connection 方法） SimpleBuffer（kombu.simple 中的类） SimpleQueue() （kombu.Connection 方法） SimpleQueue() （kombu.connection.Connection 方法） SimpleQueue（kombu.simple 中的类） slmq（kombu.transport.SLMQ.Channel 属性） slmq（kombu.transport.SLMQ.Transport.Channel 属性） sock（kombu.transport.pyamqp.Connection 属性） sort_heap() （kombu.clocks.LamportClock 方法） sorted_cycle（kombu.utils.scheduling 中的类） ssl（kombu.Connection 属性） ssl（kombu.connection.Connection 属性） ssl（kombu.transport.mongodb.Channel 属性） ssl（kombu.transport.mongodb.Transport.Channel 属性） state（kombu.pidbox.Node 属性） state（kombu.transport.virtual.Channel 属性） state（kombu.transport.virtual.Transport 属性） status_code（kombu.asynchronous.http.base.Response 属性） status_code（kombu.asynchronous.http.Response 属性） status（kombu.asynchronous.http.base.Response 属性）, [1] status（kombu.asynchronous.http.Response 属性）, [1] stop() （kombu.asynchronous.Hub 方法） stop() （kombu.asynchronous.hub.Hub 方法） stop() （kombu.asynchronous.timer.Timer 方法） store_processed（kombu.transport.filesystem.Channel 属性） store_processed（kombu.transport.filesystem.Transport.Channel 属性） str_to_bytes()（在 kombu.utils.encoding 模块中） supports_exchange_type() （kombu.connection.Connection 方法） supports_fanout（kombu.transport.filesystem.Channel 属性） supports_fanout（kombu.transport.filesystem.Transport.Channel 属性） supports_fanout（kombu.transport.memory.Channel 属性） supports_fanout（kombu.transport.memory.Transport.Channel 属性） supports_fanout（kombu.transport.mongodb.Channel 属性） supports_fanout（kombu.transport.mongodb.Transport.Channel 属性） supports_heartbeats（kombu.Connection 属性） supports_heartbeats（kombu.connection.Connection 属性） switch() （kombu.Connection 方法） switch() （kombu.connection.Connection 方法） symbol_by_name()（在 kombu.utils.imports 模块中）

T

then() （kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 方法） then() （kombu.asynchronous.http.base.Request 方法） then() （kombu.asynchronous.http.Request 方法） then() （kombu.transport.pyamqp.Connection 方法） then() （kombu.transport.pyamqp.Connection.Channel 方法） TimeoutError timeout（kombu.transport.consul.Channel 属性） timeout（kombu.transport.consul.Transport.Channel 属性） timeout（kombu.transport.etcd.Channel 属性） timeout（kombu.transport.etcd.Transport.Channel 属性） Timer.Entry（kombu.asynchronous.timer 中的类） Timer（kombu.asynchronous.timer 中的类） timestamp（kombu.clocks.timetuple 属性） timestamp（kombu.utils.limits.TokenBucket 属性） timetuple（kombu.clocks 中的类） to_timestamp()（在 kombu.asynchronous.timer 模块中） TokenBucket（kombu.utils.limits 中的类） TopicExchange（kombu.transport.virtual.exchange 中的类） TRANSIENT_DELIVERY_MODE（kombu.Exchange 属性） Transport() （kombu.transport.pyamqp.Connection 方法） Transport.Channel（kombu.transport.consul 中的类） Transport.Channel（kombu.transport.etcd 中的类） Transport.Channel（kombu.transport.filesystem 中的类） Transport.Channel（kombu.transport.memory 中的类） Transport.Channel（kombu.transport.mongodb 中的类） Transport.Channel（kombu.transport.pyro 中的类） Transport.Channel（kombu.transport.SLMQ 中的类） Transport.Channel（kombu.transport.sqlalchemy 中的类） Transport.Channel（kombu.transport.zookeeper 中的类） Transport.Connection.Channel.Message（kombu.transport.pyamqp 中的类） Transport.Connection.Channel.Message（kombu.transport.qpid 中的类） Transport.Connection.Channel.QoS（kombu.transport.qpid 中的类） Transport.Connection.Channel（kombu.transport.pyamqp 中的类） Transport.Connection.Channel（kombu.transport.qpid 中的类） Transport.Connection（kombu.transport.pyamqp 中的类） Transport.Connection（kombu.transport.qpid 中的类） TRANSPORT_ALIASES()（在 kombu.transport 模块中）

transport_options（kombu.connection.Connection 属性） transport_options（kombu.transport.filesystem.Channel 属性） transport_options（kombu.transport.filesystem.Transport.Channel 属性） transport_options（kombu.transport.SLMQ.Channel 属性） transport_options（kombu.transport.SLMQ.Transport.Channel 属性） transport（kombu.Connection 属性） transport（kombu.connection.Connection 属性） Transport（kombu.transport.base 中的类） Transport（kombu.transport.consul 中的类） Transport（kombu.transport.etcd 中的类） Transport（kombu.transport.filesystem 中的类） Transport（kombu.transport.memory 中的类） Transport（kombu.transport.mongodb 中的类） Transport（kombu.transport.pyamqp 中的类） transport（kombu.transport.pyamqp.Connection 属性） Transport（kombu.transport.pyro 中的类） Transport（kombu.transport.qpid 中的类） Transport（kombu.transport.SLMQ 中的类） Transport（kombu.transport.sqlalchemy 中的类） Transport（kombu.transport.virtual 中的类） Transport（kombu.transport.zookeeper 中的类） tref（kombu.asynchronous.timer.Entry 属性） tref（kombu.asynchronous.timer.Timer.Entry 属性） ttl（kombu.transport.mongodb.Channel 属性） ttl（kombu.transport.mongodb.Transport.Channel 属性） tx_commit() （kombu.transport.pyamqp.Connection.Channel 方法） tx_rollback() （kombu.transport.pyamqp.Connection.Channel 方法） tx_select() （kombu.transport.pyamqp.Connection.Channel 方法） typeof() （kombu.transport.qpid.Channel 方法） typeof() （kombu.transport.qpid.Connection.Channel 方法） typeof() （kombu.transport.qpid.Transport.Connection.Channel 方法） typeof() （kombu.transport.virtual.Channel 方法） type（kombu.Exchange 属性）, [1] type（kombu.pidbox.Mailbox 属性） type（kombu.transport.virtual.exchange.DirectExchange 属性） type（kombu.transport.virtual.exchange.ExchangeType 属性） type（kombu.transport.virtual.exchange.FanoutExchange 属性） type（kombu.transport.virtual.exchange.TopicExchange 属性）

U

unbind_from() （kombu.Exchange 方法） unbind_from() （kombu.Queue 方法） unregister() （kombu.matcher.MatcherRegistry 方法） unregister()（在 kombu.matcher 模块中） unregister()（在 kombu.serialization 模块中） update() （kombu.utils.functional.LRUCache 方法） update() （kombu.utils.scheduling.round_robin_cycle 方法） uri_prefix（kombu.Connection 属性） uri_prefix（kombu.connection.Connection 属性） URL url_to_parts()（在 kombu.utils.url 模块中） urlparts（kombu.utils.url 中的类） url（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性）

url（kombu.asynchronous.http.base.Request 属性） url（kombu.asynchronous.http.Request 属性） use_gzip（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） use_gzip（kombu.asynchronous.http.base.Request 属性） use_gzip（kombu.asynchronous.http.Request 属性） user_agent（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） user_agent（kombu.asynchronous.http.base.Request 属性） user_agent（kombu.asynchronous.http.Request 属性） userid（kombu.Connection 属性） userid（kombu.connection.Connection 属性） username（kombu.utils.url.urlparts 属性） uuid()（在 kombu.common 模块中） uuid()（在 kombu.utils.uuid 模块中）

V

validate_cert（kombu.asynchronous.aws.connection.AsyncHTTPSConnection.Request 属性） validate_cert（kombu.asynchronous.http.base.Request 属性） validate_cert（kombu.asynchronous.http.Request 属性） values() （kombu.utils.functional.LRUCache 方法） value（kombu.clocks.LamportClock 属性） verify_connection() （kombu.transport.consul.Transport 方法） verify_connection() （kombu.transport.etcd.Transport 方法） verify_connection() （kombu.transport.pyamqp.Transport 方法）

verify_runtime_environment() （kombu.transport.qpid.Transport 方法） version_string_as_tuple()（在 kombu.utils.text 模块中） version（kombu.transport.sqlalchemy.models.Message 属性） VHOST virtual_host（kombu.Connection 属性） virtual_host（kombu.connection.Connection 属性） visibility_timeout（kombu.transport.SLMQ.Channel 属性） visibility_timeout（kombu.transport.SLMQ.Transport.Channel 属性） visible（kombu.transport.sqlalchemy.models.Message 属性）

W

wait() （kombu.compat.Consumer 方法） wait() （kombu.transport.pyamqp.Connection 方法） wait() （kombu.transport.pyamqp.Connection.Channel 方法） warn() （kombu.log.LogMixin 方法） when_bound() （kombu.abstract.MaybeChannelBound 方法） when_bound() （kombu.Queue 方法） wildcards（kombu.transport.virtual.exchange.TopicExchange 属性）

with_traceback() （kombu.compat.Consumer.ContentDisallowed 方法） with_traceback() （kombu.compat.ConsumerSet.ContentDisallowed 方法） with_traceback() （kombu.transport.pyamqp.Connection.Channel.Message.MessageStateError 方法） with_traceback() （kombu.transport.virtual.Message.MessageStateError 方法） write() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） write_batch() （kombu.asynchronous.aws.sqs.queue.AsyncQueue 方法） WRITE（kombu.asynchronous.Hub 属性） WRITE（kombu.asynchronous.hub.Hub 属性）

模

模块 kombu kombu.abstract kombu.asynchronous kombu.asynchronous.aws kombu.asynchronous.aws.connection kombu.asynchronous.aws.sqs kombu.asynchronous.aws.sqs.connection kombu.asynchronous.aws.sqs.message kombu.asynchronous.aws.sqs.queue kombu.asynchronous.debug kombu.asynchronous.http kombu.asynchronous.http.base kombu.asynchronous.http.curl kombu.asynchronous.hub kombu.asynchronous.semaphore kombu.asynchronous.timer kombu.clocks kombu.common kombu.compat kombu.compression kombu.connection kombu.exceptions kombu.log kombu.matcher kombu.message kombu.mixins kombu.pidbox kombu.pools kombu.resource kombu.serialization kombu.simple kombu.transport kombu.transport.base kombu.transport.consul kombu.transport.etcd kombu.transport.filesystem kombu.transport.memory kombu.transport.mongodb kombu.transport.pyamqp kombu.transport.pyro kombu.transport.qpid kombu.transport.SLMQ kombu.transport.sqlalchemy kombu.transport.sqlalchemy.models kombu.transport.virtual kombu.transport.virtual.exchange kombu.transport.zookeeper kombu.utils.amq_manager kombu.utils.collections kombu.utils.compat kombu.utils.debug kombu.utils.div kombu.utils.encoding kombu.utils.eventio kombu.utils.functional kombu.utils.imports kombu.utils.json kombu.utils.limits kombu.utils.objects kombu.utils.scheduling kombu.utils.text kombu.utils.time kombu.utils.url kombu.utils.uuid

环

环境变量 AWS_ACCESS_KEY_ID AWS_SECRET_ACCESS_KEY KOMBU_LOG_CHANNEL KOMBU_LOG_CONNECTION, [1] KOMBU_LOG_DEBUG, [1], [2] PICKLE_PROTOCOL, [1] URL VHOST