diff options
| author | bulve-ad <78788030+bulve-ad@users.noreply.github.com> | 2024-08-23 17:25:29 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-08-23 17:25:29 +0100 |
| commit | 8f75a47d01daf94999ee94a6c658adab6ca63c1d (patch) | |
| tree | 64b5bb5010b9124ae612dcc7e7cb75400fa07241 /src/dataframes.py | |
| parent | 30525f27ba1d20c65216cbe58a62953b8f1fe947 (diff) | |
| parent | f1e10e1a2f573c152b19a630577a71ce9aff2bb4 (diff) | |
| download | de-project-bentley-8f75a47d01daf94999ee94a6c658adab6ca63c1d.tar.gz de-project-bentley-8f75a47d01daf94999ee94a6c658adab6ca63c1d.zip | |
Merge branch 'test/test_transform_lambda' into test/dataframes
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( |