This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.5.
MongoDB Transport - kombu.transport.mongodb
¶
MongoDB transport.
- copyright
2010 - 2013 by Flavio Percoco Premoli.
- license
BSD, see LICENSE for more details.
Transport¶
-
class
kombu.transport.mongodb.
Transport
(client, **kwargs)[source]¶ MongoDB Transport.
-
class
Channel
(*vargs, **kwargs)¶ MongoDB Channel.
-
broadcast
¶
-
broadcast_collection
= 'messages.broadcast'¶
-
calc_queue_size
= True¶
-
capped_queue_size
= 100000¶
-
client
¶
-
connect_timeout
= None¶
-
default_database
= 'kombu_default'¶
-
default_hostname
= '127.0.0.1'¶
-
default_port
= 27017¶
-
from_transport_options
= ('body_encoding', 'deadletter_queue', 'connect_timeout', 'ssl', 'ttl', 'capped_queue_size', 'default_hostname', 'default_port', 'default_database', 'messages_collection', 'routing_collection', 'broadcast_collection', 'queues_collection', 'calc_queue_size')¶
-
get_now
()¶ Return current time in UTC.
-
get_table
(exchange)¶ Get table of bindings for exchange.
-
messages
¶
-
messages_collection
= 'messages'¶
-
queue_delete
(queue, **kwargs)¶ Delete queue.
-
queues
¶
-
queues_collection
= 'messages.queues'¶
-
routing
¶
-
routing_collection
= 'messages.routing'¶
-
ssl
= False¶
-
supports_fanout
= True¶
-
ttl
= False¶
-
-
can_parse_url
= True¶
-
channel_errors
= (<class 'amqp.exceptions.ChannelError'>, <class 'pymongo.errors.ConnectionFailure'>, <class 'pymongo.errors.OperationFailure'>)¶
-
connection_errors
= (<class 'amqp.exceptions.ConnectionError'>, <class 'pymongo.errors.ConnectionFailure'>)¶
-
default_port
= 27017¶
-
driver_name
= 'pymongo'¶
-
driver_type
= 'mongodb'¶
-
implements
= {'asynchronous': False, 'exchange_type': frozenset({'direct', 'fanout', 'topic'}), 'heartbeats': False}¶
-
polling_interval
= 1¶
-
class
Channel¶
-
class
kombu.transport.mongodb.
Channel
(*vargs, **kwargs)[source]¶ MongoDB Channel.
-
broadcast_collection
= 'messages.broadcast'¶
-
calc_queue_size
= True¶
-
capped_queue_size
= 100000¶
-
connect_timeout
= None¶
-
default_database
= 'kombu_default'¶
-
default_hostname
= '127.0.0.1'¶
-
default_port
= 27017¶
-
from_transport_options
= ('body_encoding', 'deadletter_queue', 'connect_timeout', 'ssl', 'ttl', 'capped_queue_size', 'default_hostname', 'default_port', 'default_database', 'messages_collection', 'routing_collection', 'broadcast_collection', 'queues_collection', 'calc_queue_size')¶
-
messages_collection
= 'messages'¶
-
queues_collection
= 'messages.queues'¶
-
routing_collection
= 'messages.routing'¶
-
ssl
= False¶
-
supports_fanout
= True¶
-
ttl
= False¶
-