This document describes the current stable version of Kombu (5.0). For development docs, go here.
Zookeeper Transport - kombu.transport.zookeeper
¶
Zookeeper transport.
- copyright:
2010 - 2013 by Mahendra M.
- 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'>,)¶
Tuple of errors that can happen due to channel/method failure.
- connection_errors = (<class 'amqp.exceptions.ConnectionError'>,)¶
Tuple of errors that can happen due to connection failure.
- default_port = 2181¶
port number used when no port is specified.
- driver_name = 'kazoo'¶
Name of driver library (e.g. ‘py-amqp’, ‘redis’).
- driver_type = 'zookeeper'¶
Type of driver, can be used to separate transports using the AMQP protocol (driver_type: ‘amqp’), Redis (driver_type: ‘redis’), etc…
- polling_interval = 1¶
Time to sleep between unsuccessful polls.