This document describes the current stable version of Kombu (4.2). 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
session
can_parse_url = True
connection_errors = (<class 'sqlalchemy.exc.OperationalError'>,)
default_port = 0
driver_name = 'sqlalchemy'
driver_type = 'sql'
driver_version()[source]

Channel

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

The channel class.

message_cls[source]
queue_cls[source]
session