SQLAlchemy
Migrations
Use the Operations.execute
method.
First, create a migration:
alembic revision -m "electrify items"
Then execute the SQL in the upgrade
function:
# ... docstring and revision identifiers ...
from alembic import op
import sqlalchemy as sa
def upgrade():
op.execute('ALTER TABLE items ENABLE ELECTRIC')
Event sourcing
One way of consuming a change feed from Postgres in Python is to use the psycopg2.extras.LogicalReplicationConnection.
See Integrations -> Event sourcing for more information.