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.
-
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
-
connection_errors
= (<class 'sqlalchemy.exc.OperationalError'>,)
-
default_port
= 0
-
driver_name
= 'sqlalchemy'
-
driver_type
= 'sql'
-
driver_version
()[source]
-
class
kombu.transport.sqlalchemy.
Channel
(connection, **kwargs)[source]
The channel class.
-
message_cls
[source]
-
queue_cls
[source]
-
property
session