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

SQLAlchemy Transport Model - kombu.transport.sqlalchemy

Kombu transport using SQLAlchemy as the message store.

Transport

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

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

Channel

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

The channel class.

message_cls

queue_cls

session