ADD Changes in lambda functions to horizontally scale, instead of try…

…ing to process a large amount of files in one lambda

Refer to task #54

src/pds/ingress/pds-nucleus-datasync-completion-trigger.py

@@ -36,7 +36,7 @@
 
 
 def lambda_handler(event, context):
-    """ Lambda Handler """
+    """ Lambda Handler - The entry point of lambda """
 
     logger.info(f"Lambda Request ID: {context.aws_request_id}")
     logger.info(f"Event: {event}")

src/pds/ingress/pds-nucleus-datasync-completion.py

@@ -34,14 +34,12 @@
 rds_data = boto3.client('rds-data')
 
 def lambda_handler(event, context):
-    """ Lambda Handler """
+    """ Lambda Handler - The entry point of lambda """
 
     logger.info(f"Lambda Request ID: {context.aws_request_id}")
     logger.info(f"Event: {event}")
 
-    json_event = json.dumps(event)
-    transfer_report = json.loads(json_event)
-    content_object = s3.Object('pds-nucleus-datassync-reports', str(transfer_report["s3_key"]))
+    content_object = s3.Object('pds-nucleus-datassync-reports', str(event["s3_key"]))
     transfer_report_file_content = content_object.get()['Body'].read().decode('utf-8')
     transfer_report_json_content = json.loads(transfer_report_file_content)
     verified_file_obj_list = transfer_report_json_content['Verified']

src/pds/ingress/pds-nucleus-product-completion-checker.py

@@ -43,7 +43,7 @@
 replace_prefix = efs_mount_path
 
 def lambda_handler(event, context):
-    """ Main lambda handler """
+    """ Lambda Handler - The entry point of lambda """
 
     logger.setLevel(logging.DEBUG)
     logger.addHandler(logging.StreamHandler())