trigger.py

import sqlalchemy
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker

import datetime

Base = declarative_base()

engine = create_engine('postgresql://postgres:@localhost/testing')
session = sessionmaker(bind=engine)()

class Test(Base):
    __tablename__ = 'testing'

    id = sqlalchemy.Column(sqlalchemy.Integer, primary_key=True)
    dt = sqlalchemy.Column(sqlalchemy.DateTime(timezone=True))

Base.metadata.create_all(engine)

session.add(Test(dt=datetime.datetime(2011, 1, 1)))
session.add(Test(dt=datetime.datetime(2011, 6, 1)))
session.commit()
session.flush()

import pandas as pd
df = pd.read_sql_table('testing', engine)