This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.3.
Zookeeper Transport - kombu.transport.zookeeper
¶
Zookeeper transport.
copyright: |
|
---|---|
license: | BSD, see LICENSE for more details. |
Synopsis
Connects to a zookeeper node as <server>:<port>/<vhost> The <vhost> becomes the base for all the other znodes. So we can use it like a vhost.
This uses the built-in kazoo recipe for queues
References
- https://zookeeper.apache.org/doc/trunk/recipes.html#sc_recipes_Queues
- https://kazoo.readthedocs.io/en/latest/api/recipe/queue.html
Limitations This queue does not offer reliable consumption. An entry is removed from the queue prior to being processed. So if an error occurs, the consumer has to re-queue the item or it will be lost.
Transport¶
-
class
kombu.transport.zookeeper.
Transport
(*args, **kwargs)[source]¶ Zookeeper Transport.
-
channel_errors
= (<class 'amqp.exceptions.ChannelError'>,)¶
-
connection_errors
= (<class 'amqp.exceptions.ConnectionError'>,)¶
-
default_port
= 2181¶
-
driver_name
= u'kazoo'¶
-
driver_type
= u'zookeeper'¶
-
polling_interval
= 1¶
-