This document describes the current stable version of Kombu (4.0). For development docs, go here.

Etcd Transport - kombu.transport.etcd

Etcd Transport.

It uses Etcd as a store to transport messages in Queues

It uses python-etcd for talking to Etcd’s HTTP API

Transport

class kombu.transport.etcd.Transport(*args, **kwargs)

Etcd storage Transport for Kombu.

class Channel(*args, **kwargs)

Etcd Channel class which talks to the Etcd.

index = None

lock_ttl = 10

lock_value

prefix = u'kombu'

session_ttl = 30

timeout = 10

Transport.default_port = 2379

Transport.driver_name = u'python-etcd'

Transport.driver_type = u'etcd'

Transport.driver_version()

Return the version of the etcd library.

Note

python-etcd has no __version__. This is a workaround.

Transport.implements = {'async': False, 'exchange_type': frozenset([u'direct']), 'heartbeats': False}

Transport.polling_interval = 3

Transport.verify_connection(connection)

Verify the connection works.

Channel

class kombu.transport.etcd.Channel(*args, **kwargs)

Etcd Channel class which talks to the Etcd.

index = None

lock_ttl = 10

lock_value

prefix = u'kombu'

session_ttl = 30

timeout = 10