Insert Table

insert_table.py

# Insert Table
from sqlalchemy.exc import IntegrityError

y_m = y_m_generator(2010, 2018)
for y,m in y_m:
    if m<10:
        p = str(y)+'0'+str(m)
    else:
        p = str(y)+str(m)
    
    # 爬蟲並轉成 data frame
    df = monthly_sales(y,m)
    
    # 將 data frame批次寫進資料庫
    try:
        df.to_sql(name='SII_REV_{}'.format(p), con=engine, if_exists='append', index=False)
    # 若已有資料則不寫入
    except IntegrityError:
        print('catch duplicate data')