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.
- 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…