import pandas as pd from serenitas.utils.env import DAILY_DIR from serenitas.utils.db import dawn_engine def load_citco_report(fdir): df = pd.read_csv(fdir) df["row"] = df.index df.columns = df.columns.str.lower() df.columns = df.columns.str.replace(" ", "_") return df if __name__ == "__main__": fdir = DAILY_DIR / "Selene/onboarding/reporting/sample_report.csv" df = load_citco_report(fdir) df.to_sql("citco_reports", dawn_engine, if_exists="append", index=False)