This document describes the current stable version of Kombu (4.2). 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))