In [15]:

    

import psycopg2

conn = psycopg2.connect(service='firecares')


    

In [12]:

    

with conn.cursor() as c:
    c.execute("""
create table if not exists department_population_samples (
    id serial primary key,
    department_id integer not null,
    population integer,
    sample_date timestamp with time zone not null default now()
);
""")
    
conn.commit()


    

In [17]:

    

with conn.cursor() as c:
    c.execute("""select id, population from firestation_firedepartment;""")
    res = c.fetchall()


    

In [19]:

    

with conn.cursor() as c:
    for r in res:
        c.execute("insert into department_population_samples (department_id, population) values (%(dept)s, %(pop)s)",
                 dict(dept=r[0], pop=r[1]))

conn.commit()