This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.

MongoDB传输- kombu.transport.mongodb

Kombu的MongoDB传输模块。

功能

  • 类型：虚拟

  • 支持Direct：是

  • 支持主题：是

  • 支持扇出：支持

  • 支持优先级：是

  • 支持TTL：支持

连接字符串

Unreviewed

交通选择

  • connect_timeout,

  • ssl ，

  • ttl ，

  • capped_queue_size,

  • default_hostname,

  • default_port,

  • default_database,

  • messages_collection,

  • routing_collection,

  • broadcast_collection,

  • queues_collection,

  • calc_queue_size,

运输

class kombu.transport.mongodb.Transport(client, **kwargs)[源代码]

MongoDB传输。

class Channel(*vargs, **kwargs)

MongoDB频道。

property broadcast
broadcast_collection = 'messages.broadcast'
calc_queue_size = True
capped_queue_size = 100000
property 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()

以UTC为单位返回当前时间。

get_table(exchange)

获取以下项的绑定表 exchange 。

property messages
messages_collection = 'messages'
prepare_queue_arguments(arguments, **kwargs)
queue_delete(queue, **kwargs)

删除队列。

property queues
queues_collection = 'messages.queues'
property routing
routing_collection = 'messages.routing'
ssl = False
supports_fanout = True

如果通道支持扇出交换，则设置标志。

ttl = False
as_uri(uri: str, include_password=False, mask='**') → str[源代码]

自定义URI的显示格式。

can_parse_url = True

在以下情况下设置为True Connection 应原封不动地传递URL。

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'

驱动程序库的名称(例如‘py-amqp’、‘redis’)。

driver_type = 'mongodb'

驱动程序的类型，可用于使用AMQP协议(DRIVER_TYPE：‘AMQP’)、Redis(DRIVER_TYPE：‘REDIS’)等来分隔传输...

driver_version()[源代码]
implements = {'asynchronous': False, 'exchange_type': frozenset({'direct', 'fanout', 'topic'}), 'heartbeats': False}
polling_interval = 1

在不成功的民意调查之间睡觉的时间到了。

渠道

class kombu.transport.mongodb.Channel(*vargs, **kwargs)[源代码]

MongoDB频道。

property broadcast
broadcast_collection = 'messages.broadcast'
calc_queue_size = True
capped_queue_size = 100000
property 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()[源代码]

以UTC为单位返回当前时间。

get_table(exchange)[源代码]

获取以下项的绑定表 exchange 。

property messages
messages_collection = 'messages'
prepare_queue_arguments(arguments, **kwargs)[源代码]
queue_delete(queue, **kwargs)[源代码]

删除队列。

property queues
queues_collection = 'messages.queues'
property routing
routing_collection = 'messages.routing'
ssl = False
supports_fanout = True

如果通道支持扇出交换，则设置标志。

ttl = False