From 8e20c5c0f43d0f0c4983c8895396de7f62b7c390 Mon Sep 17 00:00:00 2001 From: lian-manonog Date: Fri, 23 Aug 2024 11:06:43 +0100 Subject: Deleted the fact_table schema py files Completed Lambda_handler for transform_lambda - and other helper functions. Testing is still to be done. Need to implement lambda layer to share helper functions across all lambdas --- src/fact_payment.py | 30 ------------------------------ 1 file changed, 30 deletions(-) delete mode 100644 src/fact_payment.py (limited to 'src/fact_payment.py') diff --git a/src/fact_payment.py b/src/fact_payment.py deleted file mode 100644 index 92de67c..0000000 --- a/src/fact_payment.py +++ /dev/null @@ -1,30 +0,0 @@ -import pandas as pd - -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 - -def create_fact_payment(dict_of_df): - df_payment = dict_of_df["payment"] - df_payment.index.name = "payment_record_id" - df_payment["created_date"] = pd.to_datetime(df_payment["created_at"]).dt.date - df_payment["created_time"] = pd.to_datetime(df_payment["created_at"]).dt.time - df_payment["last_updated_date"] = pd.to_datetime(df_payment["last_updated"]).dt.date - df_payment["last_updated_time"] = pd.to_datetime(df_payment["last_updated"]).dt.time - fact_payment = df_payment.loc[:,[ - "payment_record_id", - "payment_id", - "created_date", - "created_time", - "last_updated_date", - "last_updated_time", - "transaction_id", - "counterparty_id", - "payment_amount", - "currency_id", - "payment_type_id", - "paid", - "payment_date" - ]] - return fact_payment -- cgit v1.2.3