diff options
| author | lian-manonog <lian.manonog@gmail.com> | 2024-08-23 11:06:43 +0100 |
|---|---|---|
| committer | lian-manonog <lian.manonog@gmail.com> | 2024-08-23 11:06:43 +0100 |
| commit | 8e20c5c0f43d0f0c4983c8895396de7f62b7c390 (patch) | |
| tree | 9163d4c1a12990a51286f57b3cf5518e36650eba /src/fact_payment.py | |
| parent | 1ba7230de96092e9f401067317d0dfaf881b971b (diff) | |
| download | de-project-bentley-8e20c5c0f43d0f0c4983c8895396de7f62b7c390.tar.gz de-project-bentley-8e20c5c0f43d0f0c4983c8895396de7f62b7c390.zip | |
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
Diffstat (limited to 'src/fact_payment.py')
| -rw-r--r-- | src/fact_payment.py | 30 |
1 files changed, 0 insertions, 30 deletions
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 |