This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.3.

# 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)

  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()

    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)

    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
  property lock_value
  prefix = 'kombu'
  session_ttl = 30
  timeout = 10