diff options
| author | lian-manonog <lian.manonog@gmail.com> | 2024-08-27 10:46:03 +0100 |
|---|---|---|
| committer | lian-manonog <lian.manonog@gmail.com> | 2024-08-27 10:46:03 +0100 |
| commit | c68f63fa3aebcf9b77c24d6e2aec91a4ff4950bb (patch) | |
| tree | 85c6aa5c26856c5fe99e97d77d3128a862c54620 /src | |
| parent | 72ebda950c84d7b519db9a236b35a7fafcbb1899 (diff) | |
| download | de-project-bentley-c68f63fa3aebcf9b77c24d6e2aec91a4ff4950bb.tar.gz de-project-bentley-c68f63fa3aebcf9b77c24d6e2aec91a4ff4950bb.zip | |
wip: refactored fact payment function
Diffstat (limited to 'src')
| -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 |