kombu.transport.zookeeper¶
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.org/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]¶ -
-
Transport.
channel_errors
= (<class 'amqp.exceptions.ChannelError'>,)¶
-
Transport.
connection_errors
= (<class 'amqp.exceptions.ConnectionError'>,)¶
-
Transport.
default_port
= 2181¶
-
Transport.
driver_name
= 'kazoo'¶
-
Transport.
driver_type
= 'zookeeper'¶
-
Transport.
polling_interval
= 1¶
-