Skip to content

Instantly share code, notes, and snippets.

@dtheodor
dtheodor / listen_sqla.py
Last active February 17, 2025 19:04
Listen for pg_notify with SQL Alchemy + Psycopg2
import select
import datetime
import psycopg2
import psycopg2.extensions
from sqlalchemy import create_engine, text
engine = create_engine("postgresql+psycopg2://vagrant@/postgres")