This document describes the current stable version of Kombu (4.1). For development docs, go here.
SQLAlchemy Transport Model - kombu.transport.sqlalchemy.models
¶
Kombu transport using SQLAlchemy as the message store.
Models¶
-
class
kombu.transport.sqlalchemy.models.
Queue
(name)[source]¶ The queue class.
-
id
= Column(None, Integer(), table=None, primary_key=True, nullable=False, default=Sequence('queue_id_sequence'))¶
-
name
= Column(None, String(length=200), table=None)¶
-
-
class
kombu.transport.sqlalchemy.models.
Message
(payload, queue)[source]¶ The message class.
-
id
= Column(None, Integer(), table=None, primary_key=True, nullable=False, default=Sequence('message_id_sequence'))¶
-
visible
= Column(None, Boolean(), table=None, default=ColumnDefault(True))¶
-
sent_at
= Column('timestamp', DateTime(), table=None, onupdate=ColumnDefault(<function datetime.now>))¶
-
payload
= Column(None, Text(), table=None, nullable=False)¶
-
version
= Column(None, SmallInteger(), table=None, nullable=False, default=ColumnDefault(1))¶
-