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

Consul Transport - kombu.transport.consul

Consul Transport module for Kombu.

Features

It uses Consul.io’s Key/Value store to transport messages in Queues

It uses python-consul for talking to Consul’s HTTP API

Features

  • Type: Native

  • Supports Direct: Yes

  • Supports Topic: Unreviewed

  • Supports Fanout: Unreviewed

  • Supports Priority: Unreviewed

  • Supports TTL: Unreviewed

Connection String

Connection string has the following format:

consul://CONSUL_ADDRESS[:PORT]

Transport

class kombu.transport.consul.Transport(*args, **kwargs)[source]

Consul K/V storage Transport for Kombu.

class Channel(*args, **kwargs)

Consul Channel class which talks to the Consul Key/Value store.

index = None
property lock_name
prefix = 'kombu'
session_ttl = 30
timeout = '10s'
default_port = 8500

port number used when no port is specified.

driver_name = 'consul'

Name of driver library (e.g. ‘py-amqp’, ‘redis’).

driver_type = 'consul'

Type of driver, can be used to separate transports using the AMQP protocol (driver_type: ‘amqp’), Redis (driver_type: ‘redis’), etc…

driver_version()[source]
verify_connection(connection)[source]

Channel

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

Consul Channel class which talks to the Consul Key/Value store.

index = None
property lock_name
prefix = 'kombu'
session_ttl = 30
timeout = '10s'