diff --git a/deployment/extractor_and_loader/app.py b/deployment/extractor_and_loader/app.py index 0f75d76..a8ece33 100644 --- a/deployment/extractor_and_loader/app.py +++ b/deployment/extractor_and_loader/app.py @@ -5,10 +5,10 @@ from etl.read_stuff_from_s3_example import print_hello_from_etl_module def handler(event, context): print("Outside try statment") + print_hello_from_etl_module() try: print("show me something.. anything...") s3_uri = event.get("file_location") - print_hello_from_etl_module() if not s3_uri: return { "statusCode": 400, diff --git a/deployment/extractor_and_loader_lambda.tf b/deployment/extractor_and_loader_lambda.tf index 316e212..a6ac534 100644 --- a/deployment/extractor_and_loader_lambda.tf +++ b/deployment/extractor_and_loader_lambda.tf @@ -52,7 +52,7 @@ resource "aws_lambda_function" "extractor_and_loader" { function_name = "extractor-and-loader" role = aws_iam_role.lambda_exec_role.arn package_type = "Image" - image_uri = "${aws_ecr_repository.extractor_and_loader.repository_url}:latest3" + image_uri = "${aws_ecr_repository.extractor_and_loader.repository_url}:latest" timeout = 30 } diff --git a/etl/read_stuff_from_s3_example.py b/etl/read_stuff_from_s3_example.py index 7e92635..6ffdbcc 100644 --- a/etl/read_stuff_from_s3_example.py +++ b/etl/read_stuff_from_s3_example.py @@ -41,4 +41,4 @@ def download_data_from_s3(s3_uri): return create_temp_file(data, file_name) # Example usage -download_data_from_s3("s3://retrofit-energy-assessments-dev/JAFFERSONS ENERGY CONSULTANTS/VDE001/12103116/docs & plans/77 Perryn Road, W3 7LT EPR.pdf") +# download_data_from_s3("s3://retrofit-energy-assessments-dev/JAFFERSONS ENERGY CONSULTANTS/VDE001/12103116/docs & plans/77 Perryn Road, W3 7LT EPR.pdf")