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

动物园饲养员运输- kombu.transport.zookeeper

昆布动物园饲养员运输舱。

基于动物园饲养员的交通工具。此传输使用内置的基于kazoo ZooKeeper的队列实现。

References

Limitations 此队列不提供可靠的消费。条目在被处理之前从队列中移除。因此，如果发生错误，消费者必须重新排队该项目，否则它将丢失。

功能

  • 类型：虚拟

  • 支持Direct：是

  • 支持主题：是

  • 支持扇出：否

  • 支持优先级：是

  • 支持TTL：否

连接字符串

以下列方式连接到ZooKeeper节点：

zookeeper://SERVER:PORT/VHOST

<vhost>成为所有其他znode的基础。这样我们就可以像使用vhost一样使用它。

交通选择

运输

class kombu.transport.zookeeper.Transport(*args, **kwargs)[源代码]

动物园饲养员运输车。

class Channel(connection, **kwargs)

动物园看守人频道。

property client
channel_errors = (<class 'amqp.exceptions.ChannelError'>,)

由于通道/方法故障而可能发生的错误元组。

connection_errors = (<class 'amqp.exceptions.ConnectionError'>,)

由于连接故障而可能发生的错误的元组。

default_port = 2181

未指定端口时使用的端口号。

driver_name = 'kazoo'

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

driver_type = 'zookeeper'

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

driver_version()[源代码]
polling_interval = 1

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

渠道

class kombu.transport.zookeeper.Channel(connection, **kwargs)[源代码]

动物园看守人频道。

property client