This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.
Etcd Transport - kombu.transport.etcd
¶
Etcd Transport module for Kombu.
It uses Etcd as a store to transport messages in Queues
It uses python-etcd for talking to Etcd’s HTTP API
Features¶
Type: Virtual
Supports Direct: Unreviewed
Supports Topic: Unreviewed
Supports Fanout: Unreviewed
Supports Priority: Unreviewed
Supports TTL: Unreviewed
Connection String¶
Connection string has the following format:
'etcd'://SERVER:PORT
Transport¶
-
class
kombu.transport.etcd.
Transport
(*args, **kwargs)[source]¶ Etcd storage Transport for Kombu.
-
class
Channel
(*args, **kwargs)¶ Etcd Channel class which talks to the Etcd.
-
index
= None¶
-
lock_ttl
= 10¶
-
property
lock_value
¶
-
prefix
= 'kombu'¶
-
session_ttl
= 30¶
-
timeout
= 10¶
-
-
default_port
= 2379¶ port number used when no port is specified.
-
driver_name
= 'python-etcd'¶ Name of driver library (e.g. ‘py-amqp’, ‘redis’).
-
driver_type
= 'etcd'¶ Type of driver, can be used to separate transports using the AMQP protocol (driver_type: ‘amqp’), Redis (driver_type: ‘redis’), etc…
-
driver_version
()[source]¶ Return the version of the etcd library.
Note
python-etcd has no __version__. This is a workaround.
-
implements
= {'asynchronous': False, 'exchange_type': frozenset({'direct'}), 'heartbeats': False}¶
-
polling_interval
= 3¶ Time to sleep between unsuccessful polls.
-
class