diff options
Diffstat (limited to 'src/dataframes.py')
| -rw-r--r-- | src/dataframes.py | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/src/dataframes.py b/src/dataframes.py index 737ee2a..fc84f48 100644 --- a/src/dataframes.py +++ b/src/dataframes.py @@ -16,6 +16,7 @@ import requests # dim_counterparty + def create_fact_sales_order(dict_of_df): df_sales = dict_of_df["sales_order"] df_sales.index.name = "sales_record_id" @@ -94,6 +95,7 @@ def create_fact_payment(dict_of_df): return fact_payment + # test passed @@ -105,17 +107,15 @@ def create_dim_transaction(dict_of_df): # test passed - - def create_dim_location(dict_of_df): df_loc = ( dict_of_df["address"] .drop(labels=["created_at", "last_updated"], axis=1) .rename(columns={"address_id": "location_id"}) - ) return df_loc + def create_dim_counterparty(dict_of_df): df_prefixed_address = dict_of_df["address"].add_prefix( "counterparty_legal_", axis=1 @@ -163,8 +163,6 @@ def create_dim_date(dict_of_df): # tests passed - - def scrape_currency_names(): response = requests.get("https://www.xe.com/currency/").content soup = BeautifulSoup(response, "html.parser") @@ -177,7 +175,6 @@ def scrape_currency_names(): ) return df_cur - # tests passed @@ -191,13 +188,13 @@ def create_dim_currency(dict_of_df, names=scrape_currency_names()): # tests passed - def create_dim_payment_type(dict_of_df): df_payment_type = dict_of_df["payment_type"] dim_payment_type = df_payment_type.loc[:, ["payment_type_id", "payment_type_name"]] return dim_payment_type + # tests passed @@ -209,8 +206,8 @@ def create_dim_design(dict_of_df): return dim_design -# tests passed +# tests passed def create_dim_staff(dict_of_df): staff_department = pd.merge( |