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

SQLAlchemy Transport Model - kombu.transport.sqlalchemy

Kombu transport using SQLAlchemy as the message store.

Transport

class kombu.transport.sqlalchemy.Transport(client, **kwargs)[source]

The transport class.

class Channel(connection, **kwargs)

The channel class.

message_cls
queue_cls
property session
can_parse_url = True

Set to True if Connection should pass the URL unmodified.

connection_errors = (<class 'sqlalchemy.exc.OperationalError'>,)

Tuple of errors that can happen due to connection failure.

default_port = 0

port number used when no port is specified.

driver_name = 'sqlalchemy'

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

driver_type = 'sql'

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

driver_version()[source]

Channel

class kombu.transport.sqlalchemy.Channel(connection, **kwargs)[source]

The channel class.

message_cls[source]
queue_cls[source]
property session