blob: 8bfc38aea3cc4cc498411b3923d5d8415149313b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
|
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)
|
