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.

verify_connection(connection)[source]

Verify the connection works.

Channel

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

Etcd Channel class which talks to the Etcd.

index = None
lock_ttl = 10
property lock_value
prefix = 'kombu'
session_ttl = 30
timeout = 10