kombu.transport.redis¶
Redis transport.
Transport¶
-
class
kombu.transport.redis.
Transport
(*args, **kwargs)[source]¶ -
class
Channel
(*args, **kwargs)¶ -
class
QoS
(*args, **kwargs)¶ -
ack
(delivery_tag)¶
-
append
(message, delivery_tag)¶
-
pipe_or_acquire
(*args, **kwds)¶
-
reject
(delivery_tag, requeue=False)¶
-
restore_at_shutdown
= True¶
-
restore_by_tag
(tag, client=None, leftmost=False)¶
-
restore_unacked
(client=None)¶
-
restore_visible
(start=0, num=10, interval=10)¶
-
unacked_index_key
¶
-
unacked_key
¶
-
unacked_mutex_expire
¶
-
unacked_mutex_key
¶
-
visibility_timeout
¶
-
-
Transport.Channel.
ack_emulation
= True¶
-
Transport.Channel.
active_queues
¶ Set of queues being consumed from (excluding fanout queues).
-
Transport.Channel.
async_pool
¶
-
Transport.Channel.
basic_cancel
(consumer_tag)¶
-
Transport.Channel.
basic_consume
(queue, *args, **kwargs)¶
-
Transport.Channel.
client
¶ Client used to publish messages, BRPOP etc.
-
Transport.Channel.
close
()¶
-
Transport.Channel.
conn_or_acquire
(*args, **kwds)¶
-
Transport.Channel.
fanout_patterns
= False¶
-
Transport.Channel.
fanout_prefix
= False¶
-
Transport.Channel.
from_transport_options
= (u'body_encoding', u'deadletter_queue', 'ack_emulation', 'unacked_key', 'unacked_index_key', 'unacked_mutex_key', 'unacked_mutex_expire', 'visibility_timeout', 'unacked_restore_limit', 'fanout_prefix', 'fanout_patterns', 'socket_timeout', 'socket_connect_timeout', 'socket_keepalive', 'socket_keepalive_options', 'queue_order_strategy', 'max_connections', 'priority_steps')¶
-
Transport.Channel.
get_table
(exchange)¶
-
Transport.Channel.
keyprefix_fanout
= '/{db}.'¶
-
Transport.Channel.
keyprefix_queue
= '_kombu.binding.%s'¶
-
Transport.Channel.
max_connections
= 10¶
-
Transport.Channel.
pool
¶
-
Transport.Channel.
priority
(n)¶
-
Transport.Channel.
priority_steps
= [0, 3, 6, 9]¶
-
Transport.Channel.
sep
= '\x06\x16'¶
-
Transport.Channel.
socket_connect_timeout
= None¶
-
Transport.Channel.
socket_keepalive
= None¶
-
Transport.Channel.
socket_keepalive_options
= None¶
-
Transport.Channel.
socket_timeout
= None¶
-
Transport.Channel.
subclient
¶ Pub/Sub connection used to consume fanout queues.
-
Transport.Channel.
supports_fanout
= True¶
-
Transport.Channel.
unacked_index_key
= 'unacked_index'¶
-
Transport.Channel.
unacked_key
= 'unacked'¶
-
Transport.Channel.
unacked_mutex_expire
= 300¶
-
Transport.Channel.
unacked_mutex_key
= 'unacked_mutex'¶
-
Transport.Channel.
unacked_restore_limit
= None¶
-
Transport.Channel.
visibility_timeout
= 3600¶
-
class
-
Transport.
default_port
= 6379¶
-
Transport.
driver_name
= 'redis'¶
-
Transport.
driver_type
= 'redis'¶
-
Transport.
polling_interval
= None¶
-
Transport.
supports_ev
= True¶
-
class
Channel¶
-
class
kombu.transport.redis.
Channel
(*args, **kwargs)[source]¶ -
class
QoS
(*args, **kwargs)¶ -
ack
(delivery_tag)¶
-
append
(message, delivery_tag)¶
-
pipe_or_acquire
(*args, **kwds)¶
-
reject
(delivery_tag, requeue=False)¶
-
restore_at_shutdown
= True¶
-
restore_by_tag
(tag, client=None, leftmost=False)¶
-
restore_unacked
(client=None)¶
-
restore_visible
(start=0, num=10, interval=10)¶
-
unacked_index_key
¶
-
unacked_key
¶
-
unacked_mutex_expire
¶
-
unacked_mutex_key
¶
-
visibility_timeout
¶
-
-
Channel.
ack_emulation
= True¶
-
Channel.
active_queues
¶ Set of queues being consumed from (excluding fanout queues).
-
Channel.
async_pool
¶
-
Channel.
fanout_patterns
= False¶ If enabled the fanout exchange will support patterns in routing and binding keys (like a topic exchange but using PUB/SUB). This will be enabled by default in a future version.
-
Channel.
fanout_prefix
= False¶ Transport option to enable disable fanout keyprefix. Should be enabled by default, but that is not backwards compatible. Can also be string, in which case it changes the default prefix (‘/{db}.’) into to something else. The prefix must include a leading slash and a trailing dot.
-
Channel.
from_transport_options
= (u'body_encoding', u'deadletter_queue', 'ack_emulation', 'unacked_key', 'unacked_index_key', 'unacked_mutex_key', 'unacked_mutex_expire', 'visibility_timeout', 'unacked_restore_limit', 'fanout_prefix', 'fanout_patterns', 'socket_timeout', 'socket_connect_timeout', 'socket_keepalive', 'socket_keepalive_options', 'queue_order_strategy', 'max_connections', 'priority_steps')¶
-
Channel.
keyprefix_fanout
= '/{db}.'¶
-
Channel.
keyprefix_queue
= '_kombu.binding.%s'¶
-
Channel.
max_connections
= 10¶
-
Channel.
pool
¶
-
Channel.
priority_steps
= [0, 3, 6, 9]¶
-
Channel.
sep
= '\x06\x16'¶
-
Channel.
socket_connect_timeout
= None¶
-
Channel.
socket_keepalive
= None¶
-
Channel.
socket_keepalive_options
= None¶
-
Channel.
socket_timeout
= None¶
-
Channel.
supports_fanout
= True¶
-
Channel.
unacked_index_key
= 'unacked_index'¶
-
Channel.
unacked_key
= 'unacked'¶
-
Channel.
unacked_mutex_expire
= 300¶
-
Channel.
unacked_mutex_key
= 'unacked_mutex'¶
-
Channel.
unacked_restore_limit
= None¶
-
Channel.
visibility_timeout
= 3600¶
-
class