jsonb.py

>>> import sqlalchemy as sa
>>> from cureatr.model import sql
>>> t = sa.Table(
...     "cureatr.user_messages", sql.rds_metadata,
...     sa.Column("_id", sql.ObjectIdType, primary_key=True),
...     sa.Column("document", sa.dialects.postgresql.JSONB))
>>> message_id = t.c.document['message_id'].label("message_id")
>>> iid = t.c.document['iid'].label("iid")
>>> q = sa.select([message_id, iid])
>>> r = sql.rds_engine.engine.execute(q)
>>> f = r.first()
>>> f
(ObjectId('51b8ad2b51c356298207f95a'), u'cureatr')
>>> f[message_id]
ObjectId('51b8ad2b51c356298207f95a')
>>> f[iid]
u'cureatr'