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'>, <class 'kazoo.exceptions.RuntimeInconsistency'>, <class 'kazoo.exceptions.DataInconsistency'>, <class 'kazoo.exceptions.BadArgumentsError'>, <class 'kazoo.exceptions.MarshallingError'>, <class 'kazoo.exceptions.UnimplementedError'>, <class 'kazoo.exceptions.OperationTimeoutError'>, <class 'kazoo.exceptions.APIError'>, <class 'kazoo.exceptions.NoNodeError'>, <class 'kazoo.exceptions.NoAuthError'>, <class 'kazoo.exceptions.NodeExistsError'>, <class 'kazoo.exceptions.NoChildrenForEphemeralsError'>, <class 'kazoo.exceptions.NotEmptyError'>, <class 'kazoo.exceptions.SessionExpiredError'>, <class 'kazoo.exceptions.InvalidCallbackError'>, <class 'socket.error'>)¶
-
Transport.
connection_errors
= (<class 'amqp.exceptions.ConnectionError'>, <class 'kazoo.exceptions.SystemZookeeperError'>, <class 'kazoo.exceptions.ConnectionLoss'>, <class 'kazoo.exceptions.MarshallingError'>, <class 'kazoo.exceptions.UnimplementedError'>, <class 'kazoo.exceptions.OperationTimeoutError'>, <class 'kazoo.exceptions.NoAuthError'>, <class 'kazoo.exceptions.InvalidACLError'>, <class 'kazoo.exceptions.AuthFailedError'>, <class 'kazoo.exceptions.SessionExpiredError'>)¶
-
Transport.
default_port
= 2181¶
-
Transport.
driver_name
= 'kazoo'¶
-
Transport.
driver_type
= 'zookeeper'¶
-
Transport.
polling_interval
= 1¶
-