diff options
| -rw-r--r-- | src/dataframes.py | 14 | ||||
| -rw-r--r-- | src/transform_lambda.py | 3 |
2 files changed, 9 insertions, 8 deletions
diff --git a/src/dataframes.py b/src/dataframes.py index d0479f1..94eb509 100644 --- a/src/dataframes.py +++ b/src/dataframes.py @@ -71,14 +71,12 @@ def create_fact_purchase_orders(dict_of_df): 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 + df_payment["created_date"] = df_payment["created_at"].date() + df_payment["created_time"] = df_payment["created_at"].time + df_payment["last_updated_date"] = df_payment["last_updated"].date() + df_payment["last_updated_time"] = df_payment["last_updated"].time + df_payment["payment_date"] = pd.to_datetime( + df_payment["payment_date"], format="%Y-%m-%d") fact_payment = df_payment.loc[ :, [ diff --git a/src/transform_lambda.py b/src/transform_lambda.py index 57e9042..565b4ee 100644 --- a/src/transform_lambda.py +++ b/src/transform_lambda.py @@ -211,3 +211,6 @@ def list_existing_s3_files(bucket_name, client=boto3.client("s3")): raise e return existing_files + +if __name__ == '__main__': + lambda_handler({}, '')
\ No newline at end of file |